config

package

v0.31.0 Latest Latest Go to latest Published: Mar 17, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AWSInstancesMetadata() []aws.InstanceMetadata
func Bucket() string
func BucketPath(key string) string
func ClusterName() string
func DeleteBucketDir(dir string, continueIfFailure bool) error
func DeleteBucketFile(file string) error
func DeleteBucketPrefix(prefix string, continueIfFailure bool) error
func GCPManagedConfigOrNil() *clusterconfig.GCPManagedConfig
func ImageDownloader() string
func Init() error
func IsBucketFile(fileKey string) (bool, error)
func IsManaged() bool
func ListBucketDir(dir string, maxResults *int64) ([]*storage.ObjectAttrs, []*s3.Object, error)
func ListBucketDirOneLevel(dir string, maxResults *int64) ([]string, error)
func ListBucketPrefix(prefix string, maxResults *int64) ([]*storage.ObjectAttrs, []*s3.Object, error)
func ManagedConfigOrNil() *clusterconfig.ManagedConfig
func ReadBytesFromBucket(key string) ([]byte, error)
func ReadJSONFromBucket(objPtr interface{}, key string) error
func Telemetry() bool
func UploadBytesToBucket(data []byte, key string) error
func UploadJSONToBucket(obj interface{}, key string) error
func UploadStringToBucket(str string, key string) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Provider         types.ProviderType
	OperatorMetadata *clusterconfig.OperatorMetadata

	CoreConfig *clusterconfig.CoreConfig

	GCPCoreConfig *clusterconfig.GCPCoreConfig

	AWS             *aws.Client
	GCP             *gcp.Client
	K8s             *k8s.Client
	K8sIstio        *k8s.Client
	K8sAllNamspaces *k8s.Client
	Prometheus      promv1.API
)

Functions ¶

func AWSInstancesMetadata ¶ added in v0.31.0

func AWSInstancesMetadata() []aws.InstanceMetadata

func Bucket ¶ added in v0.24.0

func Bucket() string

func BucketPath ¶ added in v0.24.0

func BucketPath(key string) string

func ClusterName ¶ added in v0.24.0

func ClusterName() string

func DeleteBucketDir ¶ added in v0.24.0

func DeleteBucketDir(dir string, continueIfFailure bool) error

func DeleteBucketFile ¶ added in v0.27.0

func DeleteBucketFile(file string) error

func DeleteBucketPrefix ¶ added in v0.27.0

func DeleteBucketPrefix(prefix string, continueIfFailure bool) error

func GCPManagedConfigOrNil ¶ added in v0.28.0

func GCPManagedConfigOrNil() *clusterconfig.GCPManagedConfig

func ImageDownloader ¶ added in v0.24.0

func ImageDownloader() string

func Init ¶

func Init() error

func IsBucketFile ¶ added in v0.24.0

func IsBucketFile(fileKey string) (bool, error)

func IsManaged ¶ added in v0.28.0

func IsManaged() bool

func ListBucketDir ¶ added in v0.27.0

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

func ListBucketDirOneLevel ¶ added in v0.24.0

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

func ListBucketPrefix ¶ added in v0.27.0

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

func ManagedConfigOrNil ¶ added in v0.28.0

func ManagedConfigOrNil() *clusterconfig.ManagedConfig

func ReadBytesFromBucket ¶ added in v0.25.0

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

func ReadJSONFromBucket ¶ added in v0.24.0

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

func Telemetry ¶

func Telemetry() bool

func UploadBytesToBucket ¶ added in v0.24.0

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

func UploadJSONToBucket ¶ added in v0.24.0

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

func UploadStringToBucket ¶ added in v0.27.0

func UploadStringToBucket(str string, key string) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL