workloads

package

v0.42.1 Latest Latest Go to latest Published: Sep 23, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

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
- func (c *ConfigMapConfig) GenerateConfigMapData() (map[string]string, error)

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)

Source Files ¶

View all Source files

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