operator

package
v0.42.1 Latest Latest
Warning

This package is not in the latest version of its module.

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

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.