operator

package

v0.42.1 Latest Latest Go to latest Published: Sep 23, 2022 License: Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func APIEndpoint(api *spec.API) (string, error)
func APIEndpointFromResource(deployedResource *DeployedResource) (string, error)
func APILoadBalancerURL() (string, error)
func APILogURL(api spec.API) (string, error)
func BatchJobLogURL(apiName string, jobStatus status.BatchJobStatus) (string, error)
func ClusterTelemetry() error
func CostBreakdown() error
func DeleteEvictedPods() error
func DownloadAPISpec(apiName string, apiID string) (*spec.API, error)
func DownloadAPISpecs(apiNames []string, apiIDs []string) ([]spec.API, error)
func DownloadBatchJobSpec(jobKey spec.JobKey) (*spec.BatchJob, error)
func DownloadTaskJobSpec(jobKey spec.JobKey) (*spec.TaskJob, error)
func ErrorCortexInstallationBroken() error
func ErrorHandler(cronName string) func(error)
func ErrorInvalidOperatorLogLevel(provided string, loglevels []string) error
func ErrorLoadBalancerInitializing() error
func GetJobLogger(jobKey spec.JobKey) (*zap.SugaredLogger, error)
func GetJobLoggerFromSpec(apiSpec *spec.API, jobKey spec.JobKey) (*zap.SugaredLogger, error)
func GetRealtimeAPILogger(apiName string, apiID string) (*zap.SugaredLogger, error)
func GetRealtimeAPILoggerFromSpec(apiSpec *spec.API) (*zap.SugaredLogger, error)
func LoadBalancerURL() (string, error)
func StreamLogsFromRandomPod(podSearchLabels map[string]string, socket *websocket.Conn)
func TaskJobLogURL(apiName string, jobStatus status.TaskJobStatus) (string, error)
func UpdateMemoryCapacityConfigMap() (map[string]kresource.Quantity, error)
type DeployedResource
- func (deployedResourced *DeployedResource) ID() string

Constants ¶

View Source

const (
	ErrCortexInstallationBroken = "operator.cortex_installation_broken"
	ErrLoadBalancerInitializing = "operator.load_balancer_initializing"
	ErrInvalidOperatorLogLevel  = "operator.invalid_operator_log_level"
)

Variables ¶

This section is empty.

Functions ¶

func APIEndpoint ¶ added in v0.19.0

func APIEndpoint(api *spec.API) (string, error)

func APIEndpointFromResource ¶ added in v0.40.0

func APIEndpointFromResource(deployedResource *DeployedResource) (string, error)

func APILoadBalancerURL ¶ added in v0.18.0

func APILoadBalancerURL() (string, error)

APILoadBalancerURL returns the http endpoint of the ingress load balancer for deployed APIs

func APILogURL ¶ added in v0.36.0

func APILogURL(api spec.API) (string, error)

func BatchJobLogURL ¶ added in v0.36.0

func BatchJobLogURL(apiName string, jobStatus status.BatchJobStatus) (string, error)

func ClusterTelemetry ¶ added in v0.32.0

func ClusterTelemetry() error

func CostBreakdown ¶ added in v0.40.0

func CostBreakdown() error

func DeleteEvictedPods ¶ added in v0.19.0

func DeleteEvictedPods() error

func DownloadAPISpec ¶

func DownloadAPISpec(apiName string, apiID string) (*spec.API, error)

func DownloadAPISpecs ¶

func DownloadAPISpecs(apiNames []string, apiIDs []string) ([]spec.API, error)

func DownloadBatchJobSpec ¶ added in v0.27.0

func DownloadBatchJobSpec(jobKey spec.JobKey) (*spec.BatchJob, error)

func DownloadTaskJobSpec ¶ added in v0.27.0

func DownloadTaskJobSpec(jobKey spec.JobKey) (*spec.TaskJob, error)

func ErrorCortexInstallationBroken ¶

func ErrorCortexInstallationBroken() error

func ErrorHandler ¶ added in v0.19.0

func ErrorHandler(cronName string) func(error)

func ErrorInvalidOperatorLogLevel ¶ added in v0.27.0

func ErrorInvalidOperatorLogLevel(provided string, loglevels []string) error

func ErrorLoadBalancerInitializing ¶

func ErrorLoadBalancerInitializing() error

func GetJobLogger ¶ added in v0.27.0

func GetJobLogger(jobKey spec.JobKey) (*zap.SugaredLogger, error)

func GetJobLoggerFromSpec ¶ added in v0.27.0

func GetJobLoggerFromSpec(apiSpec *spec.API, jobKey spec.JobKey) (*zap.SugaredLogger, error)

func GetRealtimeAPILogger ¶ added in v0.27.0

func GetRealtimeAPILogger(apiName string, apiID string) (*zap.SugaredLogger, error)

func GetRealtimeAPILoggerFromSpec ¶ added in v0.27.0

func GetRealtimeAPILoggerFromSpec(apiSpec *spec.API) (*zap.SugaredLogger, error)

func LoadBalancerURL ¶ added in v0.29.0

func LoadBalancerURL() (string, error)

LoadBalancerURL returns the http endpoint of the ingress load balancer for the operator

func StreamLogsFromRandomPod ¶ added in v0.27.0

func StreamLogsFromRandomPod(podSearchLabels map[string]string, socket *websocket.Conn)

func TaskJobLogURL ¶ added in v0.36.0

func TaskJobLogURL(apiName string, jobStatus status.TaskJobStatus) (string, error)

func UpdateMemoryCapacityConfigMap ¶ added in v0.19.0

func UpdateMemoryCapacityConfigMap() (map[string]kresource.Quantity, error)

Types ¶

type DeployedResource ¶ added in v0.19.0

type DeployedResource struct {
	userconfig.Resource
	VirtualService *istioclientnetworking.VirtualService
}

func (*DeployedResource) ID ¶ added in v0.23.0

func (deployedResourced *DeployedResource) ID() string

Source Files ¶

View all Source files

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