workloads

Documentation

Index

• Constants
• func AsyncGatewayContainers(api spec.API, queueURL string, volumeMounts []kcore.VolumeMount) kcore.Container
• func AsyncPythonHandlerContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume)
• func AsyncTensorflowHandlerContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume)
• func BatchInitContainer(api *spec.API, job *spec.BatchJob) kcore.Container
• func DefaultVolumes() []kcore.Volume
• func FileExistsProbe(fileName string) *kcore.Probe
• func GenerateNodeAffinities(apiNodeGroups []string) *kcore.Affinity
• func GenerateResourceTolerations() []kcore.Toleration
• func InitContainer(api *spec.API) kcore.Container
• func K8sName(apiName string) string
• func KubexitInitContainer() kcore.Container
• func NodeSelectors() map[string]string
• func PythonHandlerContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
• func PythonHandlerJobContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
• func RequestMonitorContainer(api *spec.API) kcore.Container
• func TaskContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
• func TaskInitContainer(api *spec.API, job *spec.TaskJob) kcore.Container
• func TensorFlowHandlerContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)
• func TensorFlowHandlerJobContainers(api *spec.API) ([]kcore.Container, []kcore.Volume)

Constants

const (
	DefaultPortInt32               = int32(8888)
	DefaultPortStr                 = "8888"
	DefaultRequestMonitorPortStr   = "15000"
	DefaultRequestMonitorPortInt32 = int32(15000)
	APIContainerName               = "api"
	ServiceAccountName             = "default"
	APISpecPath                    = "/mnt/spec/spec.json"
	TaskSpecPath                   = "/mnt/spec/task.json"
	BatchSpecPath                  = "/mnt/spec/batch.json"
)

Functions

func AsyncGatewayContainers

func AsyncGatewayContainers(api spec.API, queueURL string, volumeMounts []kcore.VolumeMount) kcore.Container

func AsyncPythonHandlerContainers

func AsyncPythonHandlerContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume)

func AsyncTensorflowHandlerContainers

func AsyncTensorflowHandlerContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume)

func BatchInitContainer

func BatchInitContainer(api *spec.API, job *spec.BatchJob) kcore.Container

func DefaultVolumes

func DefaultVolumes() []kcore.Volume

func FileExistsProbe

func FileExistsProbe(fileName string) *kcore.Probe

func GenerateNodeAffinities

func GenerateNodeAffinities(apiNodeGroups []string) *kcore.Affinity

func GenerateResourceTolerations

func GenerateResourceTolerations() []kcore.Toleration

func InitContainer

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

for async and realtime apis

func K8sName

func K8sName(apiName string) string

func KubexitInitContainer

func KubexitInitContainer() kcore.Container

func NodeSelectors

func NodeSelectors() map[string]string

func PythonHandlerContainers

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

func PythonHandlerJobContainers

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

func RequestMonitorContainer

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

func TaskContainers

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

func TaskInitContainer

func TaskInitContainer(api *spec.API, job *spec.TaskJob) kcore.Container

func TensorFlowHandlerContainers

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

func TensorFlowHandlerJobContainers

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