workloads

package

Go to main page

Versions in this module

v0

v0.42.1

Sep 23, 2022

v0.42.0

Jan 8, 2022

v0.41.0

Dec 7, 2021

Changes in this version

+ func GetLifecycleSpec(preStop *userconfig.PreStop) *kcore.Lifecycle

v0.40.0

Aug 4, 2021

Changes in this version

+ func HasReadinessProbesTargetingPort(containers []*userconfig.Container, targetPort int32) bool

v0.39.1

Jul 21, 2021

v0.39.0

Jul 20, 2021

v0.38.0

Jul 6, 2021

Changes in this version

+ var BaseEnvVars = []kcore.EnvVar

+ func BaseClusterEnvVars() []kcore.EnvFromSource

v0.37.0

Jun 24, 2021

Changes in this version

+ const DequeuerContainerName

+ const GatewayContainerName

+ const ProxyContainerName

v0.36.0

Jun 8, 2021

Changes in this version

+ func APIConfigMount(name string) kcore.VolumeMount

+ func APIConfigVolume(name string) kcore.Volume

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

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

+ func BatchContainers(api spec.API, job *spec.BatchJob) ([]kcore.Container, []kcore.Volume)

+ func ClientConfigMount() kcore.VolumeMount

+ func ClientConfigVolume() kcore.Volume

+ func ClusterConfigMount() kcore.VolumeMount

+ func ClusterConfigVolume() kcore.Volume

+ func CortexMount() kcore.VolumeMount

+ func CortexVolume() kcore.Volume

+ func GetProbeSpec(probe *userconfig.Probe) *kcore.Probe

+ func GetReadinessProbesFromContainers(containers []*userconfig.Container) map[string]kcore.Probe

+ func KubexitMount() kcore.VolumeMount

+ func KubexitVolume() kcore.Volume

+ func MntMount() kcore.VolumeMount

+ func MntVolume() kcore.Volume

+ func RealtimeContainers(api spec.API) ([]kcore.Container, []kcore.Volume)

+ func ShmMount(volumeName string) kcore.VolumeMount

+ func ShmVolume(q resource.Quantity, volumeName string) kcore.Volume

+ type ConfigMapConfig struct

+ BatchJob *spec.BatchJob

+ Probes map[string]kcore.Probe

+ TaskJob *spec.TaskJob

+ func (c *ConfigMapConfig) GenerateConfigMapData() (map[string]string, error)

v0.35.0

May 11, 2021

Changes in this version

+ const APIContainerName

+ const APISpecPath

+ const BatchSpecPath

+ const DefaultPortInt32

+ const DefaultPortStr

+ const DefaultRequestMonitorPortInt32

+ const DefaultRequestMonitorPortStr

+ const ServiceAccountName

+ const TaskSpecPath

+ 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)

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