operator

package

v0.28.0 Latest Latest Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 36 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 ¶

Constants
Variables
func APIEndpoint(api *spec.API) (string, error)
func APILoadBalancerURL() (string, error)
func DefaultVolumes() []kcore.Volume
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 FileExistsProbe(fileName string) *kcore.Probe
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 InitContainer(api *spec.API) kcore.Container
func InstanceTelemetryAWS() error
func InstanceTelemetryGCP() error
func K8sName(apiName string) string
func NodeSelectors() map[string]string
func ONNXPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
func PythonPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
func RequestMonitorContainer(api *spec.API) kcore.Container
func StreamLogsFromRandomPod(podSearchLabels map[string]string, socket *websocket.Conn)
func TaskContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
func TaskInitContainer(api *spec.API) kcore.Container
func TensorFlowPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
func UpdateMemoryCapacityConfigMap() (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"
)

View Source

const (
	DefaultPortInt32               = int32(8888)
	DefaultPortStr                 = "8888"
	DefaultRequestMonitorPortStr   = "15000"
	DefaultRequestMonitorPortInt32 = int32(15000)
	APIContainerName               = "api"
)

Variables ¶

View Source

var Tolerations = []kcore.Toleration{
	{
		Key:      "workload",
		Operator: kcore.TolerationOpEqual,
		Value:    "true",
		Effect:   kcore.TaintEffectNoSchedule,
	},
	{
		Key:      "nvidia.com/gpu",
		Operator: kcore.TolerationOpExists,
		Effect:   kcore.TaintEffectNoSchedule,
	},
	{
		Key:      "aws.amazon.com/neuron",
		Operator: kcore.TolerationOpEqual,
		Value:    "true",
		Effect:   kcore.TaintEffectNoSchedule,
	},
}

Functions ¶

func APIEndpoint ¶ added in v0.19.0

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

func APILoadBalancerURL ¶ added in v0.18.0

func APILoadBalancerURL() (string, error)

APILoadBalancerURL returns http endpoint of cluster ingress load balancer

func DefaultVolumes ¶ added in v0.19.0

func DefaultVolumes() []kcore.Volume

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 FileExistsProbe ¶ added in v0.19.0

func FileExistsProbe(fileName string) *kcore.Probe

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 InitContainer ¶ added in v0.19.0

func InitContainer(api *spec.API) kcore.Container

func InstanceTelemetryAWS ¶ added in v0.24.0

func InstanceTelemetryAWS() error

func InstanceTelemetryGCP ¶ added in v0.24.0

func InstanceTelemetryGCP() error

func K8sName ¶ added in v0.19.0

func K8sName(apiName string) string

func NodeSelectors ¶ added in v0.28.0

func NodeSelectors() map[string]string

func ONNXPredictorContainers ¶ added in v0.19.0

func ONNXPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)

func PythonPredictorContainers ¶ added in v0.19.0

func PythonPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)

func RequestMonitorContainer ¶ added in v0.19.0

func RequestMonitorContainer(api *spec.API) kcore.Container

func StreamLogsFromRandomPod ¶ added in v0.27.0

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

func TaskContainers ¶ added in v0.27.0

func TaskContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)

func TaskInitContainer ¶ added in v0.27.0

func TaskInitContainer(api *spec.API) kcore.Container

func TensorFlowPredictorContainers ¶ added in v0.19.0

func TensorFlowPredictorContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)

func UpdateMemoryCapacityConfigMap ¶ added in v0.19.0

func UpdateMemoryCapacityConfigMap() (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