workloads

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: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ProxyContainerName    = "proxy"
	DequeuerContainerName = "dequeuer"
	GatewayContainerName  = "gateway"
)
View Source
const (
	ServiceAccountName = "default"
)

Variables

View Source
var BaseEnvVars = []kcore.EnvVar{
	{
		Name:  "CORTEX_VERSION",
		Value: consts.CortexVersion,
	},
	{
		Name:  "CORTEX_LOG_LEVEL",
		Value: strings.ToUpper(userconfig.InfoLogLevel.String()),
	},
}

Functions

func APIConfigMount added in v0.36.0

func APIConfigMount(name string) kcore.VolumeMount

func APIConfigVolume added in v0.36.0

func APIConfigVolume(name string) kcore.Volume

func AsyncContainers added in v0.36.0

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

func BaseClusterEnvVars added in v0.38.0

func BaseClusterEnvVars() []kcore.EnvFromSource

func BatchContainers added in v0.36.0

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

func ClientConfigMount added in v0.36.0

func ClientConfigMount() kcore.VolumeMount

func ClientConfigVolume added in v0.36.0

func ClientConfigVolume() kcore.Volume

func ClusterConfigMount added in v0.36.0

func ClusterConfigMount() kcore.VolumeMount

func ClusterConfigVolume added in v0.36.0

func ClusterConfigVolume() kcore.Volume

func CortexMount added in v0.36.0

func CortexMount() kcore.VolumeMount

func CortexVolume added in v0.36.0

func CortexVolume() kcore.Volume

func GenerateNodeAffinities

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

func GenerateResourceTolerations

func GenerateResourceTolerations() []kcore.Toleration

func GetLifecycleSpec added in v0.41.0

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

func GetProbeSpec added in v0.36.0

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

func GetReadinessProbesFromContainers added in v0.36.0

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

func HasReadinessProbesTargetingPort added in v0.40.0

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

func K8sName

func K8sName(apiName string) string

func KubexitInitContainer

func KubexitInitContainer() kcore.Container

func KubexitMount added in v0.36.0

func KubexitMount() kcore.VolumeMount

func KubexitVolume added in v0.36.0

func KubexitVolume() kcore.Volume

func MntMount added in v0.36.0

func MntMount() kcore.VolumeMount

func MntVolume added in v0.36.0

func MntVolume() kcore.Volume

func NodeSelectors

func NodeSelectors() map[string]string

func RealtimeContainers added in v0.36.0

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

func ShmMount added in v0.36.0

func ShmMount(volumeName string) kcore.VolumeMount

func ShmVolume added in v0.36.0

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

func TaskContainers

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

Types

type ConfigMapConfig added in v0.36.0

type ConfigMapConfig struct {
	BatchJob *spec.BatchJob
	TaskJob  *spec.TaskJob
	Probes   map[string]kcore.Probe
}

func (*ConfigMapConfig) GenerateConfigMapData added in v0.36.0

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

Jump to

Keyboard shortcuts

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