Documentation ¶
Index ¶
- Constants
- Variables
- func APIConfigMount(name string) kcore.VolumeMount
- func APIConfigVolume(name string) kcore.Volume
- func AsyncContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume)
- func BaseClusterEnvVars() []kcore.EnvFromSource
- 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 GenerateNodeAffinities(apiNodeGroups []string) *kcore.Affinity
- func GenerateResourceTolerations() []kcore.Toleration
- func GetLifecycleSpec(preStop *userconfig.PreStop) *kcore.Lifecycle
- func GetProbeSpec(probe *userconfig.Probe) *kcore.Probe
- func GetReadinessProbesFromContainers(containers []*userconfig.Container) map[string]kcore.Probe
- func HasReadinessProbesTargetingPort(containers []*userconfig.Container, targetPort int32) bool
- func K8sName(apiName string) string
- func KubexitInitContainer() kcore.Container
- func KubexitMount() kcore.VolumeMount
- func KubexitVolume() kcore.Volume
- func MntMount() kcore.VolumeMount
- func MntVolume() kcore.Volume
- func NodeSelectors() map[string]string
- func RealtimeContainers(api spec.API) ([]kcore.Container, []kcore.Volume)
- func ShmMount(volumeName string) kcore.VolumeMount
- func ShmVolume(q resource.Quantity, volumeName string) kcore.Volume
- func TaskContainers(api spec.API, job *spec.JobKey) ([]kcore.Container, []kcore.Volume)
- type ConfigMapConfig
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 AsyncContainers ¶ added in v0.36.0
func BaseClusterEnvVars ¶ added in v0.38.0
func BaseClusterEnvVars() []kcore.EnvFromSource
func BatchContainers ¶ added in v0.36.0
func ClientConfigMount ¶ added in v0.36.0
func ClientConfigMount() kcore.VolumeMount
func ClientConfigVolume ¶ added in v0.36.0
func ClusterConfigMount ¶ added in v0.36.0
func ClusterConfigMount() kcore.VolumeMount
func ClusterConfigVolume ¶ added in v0.36.0
func CortexMount ¶ added in v0.36.0
func CortexMount() kcore.VolumeMount
func CortexVolume ¶ added in v0.36.0
func GenerateNodeAffinities ¶
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 KubexitInitContainer ¶
func KubexitMount ¶ added in v0.36.0
func KubexitMount() kcore.VolumeMount
func KubexitVolume ¶ added in v0.36.0
func MntMount ¶ added in v0.36.0
func MntMount() kcore.VolumeMount
func NodeSelectors ¶
func RealtimeContainers ¶ added in v0.36.0
func ShmMount ¶ added in v0.36.0
func ShmMount(volumeName string) kcore.VolumeMount
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)
Click to show internal directories.
Click to hide internal directories.