helpers

Documentation

Index

• Variables
• func CreateOrUpdateConfigMap(job *vcbatch.Job, kubeClients kubernetes.Interface, data map[string]string, ...) error
• func CreateOrUpdateSecret(job *vcbatch.Job, kubeClients kubernetes.Interface, data map[string][]byte, ...) error
• func DeleteConfigmap(job *vcbatch.Job, kubeClients kubernetes.Interface, cmName string) error
• func DeleteSecret(job *vcbatch.Job, kubeClients kubernetes.Interface, secretName string) error
• func GeneratePodgroupName(pod *v1.Pod) string
• func StartHealthz(healthzBindAddress, name string, caCertData, certData, certKeyData []byte) error

Variables

var CommandKind = vcbus.SchemeGroupVersion.WithKind("Command")

CommandKind creates command GroupVersionKind.

var JobFlowKind = flow.SchemeGroupVersion.WithKind("JobFlow")

JobFlowKind creates jobflow GroupVersionKind.

var JobKind = vcbatch.SchemeGroupVersion.WithKind("Job")

JobKind creates job GroupVersionKind.

var JobTemplateKind = flow.SchemeGroupVersion.WithKind("JobTemplate")

JobTemplateKind creates jobtemplate GroupVersionKind.

var V1beta1QueueKind = schedulerv1beta1.SchemeGroupVersion.WithKind("Queue")

V1beta1QueueKind is queue kind with v1alpha2 version.

Functions

func CreateOrUpdateConfigMap

func CreateOrUpdateConfigMap(job *vcbatch.Job, kubeClients kubernetes.Interface, data map[string]string, cmName string) error

CreateOrUpdateConfigMap creates config map if not present or updates config map if necessary.

func CreateOrUpdateSecret

func CreateOrUpdateSecret(job *vcbatch.Job, kubeClients kubernetes.Interface, data map[string][]byte, secretName string) error

CreateOrUpdateSecret creates secret if not present or updates secret if necessary

func DeleteConfigmap

func DeleteConfigmap(job *vcbatch.Job, kubeClients kubernetes.Interface, cmName string) error

DeleteConfigmap deletes the config map resource.

func DeleteSecret

func DeleteSecret(job *vcbatch.Job, kubeClients kubernetes.Interface, secretName string) error

DeleteSecret delete secret.

func GeneratePodgroupName

func GeneratePodgroupName(pod *v1.Pod) string

GeneratePodgroupName generate podgroup name of normal pod.

func StartHealthz

func StartHealthz(healthzBindAddress, name string, caCertData, certData, certKeyData []byte) error

StartHealthz register healthz interface.