config

Mar 30, 2021

Changes in this version

+ var InstancesMetadata []aws.InstanceMetadata

+ var ManagedConfig *clusterconfig.ManagedConfig

Mar 17, 2021

Changes in this version

+ func AWSInstancesMetadata() []aws.InstanceMetadata

Feb 3, 2021

Changes in this version

+ var CoreConfig *clusterconfig.CoreConfig

+ var GCPCoreConfig *clusterconfig.GCPCoreConfig

+ var OperatorMetadata *clusterconfig.OperatorMetadata

+ var Prometheus promv1.API

+ func AWSInstanceMetadataOrNil() *aws.InstanceMetadata

+ func GCPManagedConfigOrNil() *clusterconfig.GCPManagedConfig

+ func IsManaged() bool

+ func ManagedConfigOrNil() *clusterconfig.ManagedConfig

Jan 20, 2021

Changes in this version

+ func DeleteBucketFile(file string) error

+ func DeleteBucketPrefix(prefix string, continueIfFailure bool) error

+ func ListBucketDir(dir string, maxResults *int64) ([]*storage.ObjectAttrs, []*s3.Object, error)

+ func ListBucketPrefix(prefix string, maxResults *int64) ([]*storage.ObjectAttrs, []*s3.Object, error)

+ func UploadStringToBucket(str string, key string) error

Dec 23, 2020

Changes in this version

+ func ReadBytesFromBucket(key string) ([]byte, error)

Dec 9, 2020

Changes in this version

+ var GCP *gcp.Client

+ var GCPCluster *clusterconfig.InternalGCPConfig

+ var Provider types.ProviderType

+ func Bucket() string

+ func BucketPath(key string) string

+ func ClusterID() string

+ func ClusterName() string

+ func DeleteBucketDir(dir string, continueIfFailure bool) error

+ func ImageDownloader() string

+ func IsBucketFile(fileKey string) (bool, error)

+ func IsOperatorInCluster() bool

+ func ListBucketDirOneLevel(dir string, maxResults *int64) ([]string, error)

+ func OperatorID() string

+ func ReadJSONFromBucket(objPtr interface{}, key string) error

+ func UploadBytesToBucket(data []byte, key string) error

+ func UploadJSONToBucket(obj interface{}, key string) error

Jun 24, 2020

Changes in this version

+ const ErrNoAPIGateway

+ const ErrNoVPCLink

+ const ErrNoVPCLinkIntegration

+ func ErrorNoAPIGateway() error

+ func ErrorNoVPCLink() error

+ func ErrorNoVPCLinkIntegration() error

May 22, 2020

Changes in this version

+ var K8sAllNamspaces *k8s.Client

Jan 22, 2020

Changes in this version

+ var K8s *k8s.Client

+ var K8sIstio *k8s.Client

Nov 5, 2019

Changes in this version

+ var Cluster *clusterconfig.InternalClusterConfig

Sep 24, 2019

Changes in this version

+ var IstioKubernetes *k8s.Client

type CortexConfig

+ DownloaderImage string

Jul 30, 2019

Changes in this version

type CortexConfig

+ ONNXServeImageGPU string

Jul 8, 2019

Changes in this version

type CortexConfig

+ ONNXServeImage string

Jun 14, 2019

Changes in this version

+ var AWS *aws.Client

+ var Argo *argo.Client

+ var Cortex *CortexConfig

+ var Kubernetes *k8s.Client

+ var Spark *spark.Client

+ var Telemetry *telemetry.Client

+ func Init() error

+ type CortexConfig struct

+ APIVersion string

+ Bucket string

+ EnableTelemetry bool

+ ID string

+ LogGroup string

+ Namespace string

+ OperatorImage string

+ OperatorInCluster bool

+ PythonPackagerImage string

+ Region string

+ SparkImage string

+ TFAPIImage string

+ TFServeImage string

+ TFServeImageGPU string

+ TFTrainImage string

+ TFTrainImageGPU string

+ TelemetryURL string