job

Documentation

Index

• Constants
• func MatchingLabels(name string) client.MatchingLabels
• func New(cfg *config.Config, nodeName, id, serviceIP string, owner runtime.Object, ...) (*corev1.Pod, error)
• type CustomPodEnv

Constants

const (

	// EnvCallbackServiceName env var name of the callback service name
	EnvCallbackServiceName = "CALLBACK_SERVICE_NAME"
	// EnvCallbackServicePort env var name of the callback service port
	EnvCallbackServicePort = "CALLBACK_SERVICE_PORT"
	// EnvCallbackServiceResultURL env var name of the callback service result endpoint
	EnvCallbackServiceResultURL = "CALLBACK_SERVICE_RESULT_URL"
	// EnvCallbackServiceFileURL env var name of the callback service file endpoint
	EnvCallbackServiceFileURL = "CALLBACK_SERVICE_FILE_URL"
	// EnvCallbackServiceEventURL env var name of the callback service event endpoint
	EnvCallbackServiceEventURL = "CALLBACK_SERVICE_EVENT_URL"
)

Functions

func MatchingLabels

func MatchingLabels(name string) client.MatchingLabels

MatchingLabels the filter match labels for a job

func New

func New(cfg *config.Config, nodeName, id, serviceIP string, owner runtime.Object, extender ...CustomPodEnv) (*corev1.Pod, error)

New create a new job

Types

type CustomPodEnv

type CustomPodEnv interface {
	// ExtendEnv extend the env for the job pod
	ExtendEnv(cfg *config.Config, nodeName string, id string, serviceIP string, containers corev1.Container) []corev1.EnvVar
}

CustomPodEnv interface