helpers

Documentation

Index

• Variables
• func ControlledBy(obj interface{}, gvk schema.GroupVersionKind) bool
• func CreateConfigMapIfNotExist(job *vcbatch.Job, kubeClients kubernetes.Interface, data map[string]string, ...) error
• func CreateSecret(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 GetController(obj interface{}) types.UID
• func StartHealthz(healthzBindAddress, name string) error

Variables

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

CommandKind creates command GroupVersionKind

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

JobKind creates job GroupVersionKind

var V1alpha2QueueKind = schedulerv1alpha2.SchemeGroupVersion.WithKind("Queue")

V1alpha2QueueKind is queue kind with v1alpha2 version

Functions

func ControlledBy

func ControlledBy(obj interface{}, gvk schema.GroupVersionKind) bool

ControlledBy controlled by

func CreateConfigMapIfNotExist

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

CreateConfigMapIfNotExist creates config map resource if not present

func CreateSecret

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

CreateSecret create secret

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 GetController

func GetController(obj interface{}) types.UID

GetController returns the controller uid

func StartHealthz

func StartHealthz(healthzBindAddress, name string) error

StartHealthz register healthz interface