job

Documentation

Index

• func InitJobController(stop chan struct{}, kubeClient kubernetes.Interface) error
• type Controller
  • func GetJobController() Controller

Functions

func InitJobController

func InitJobController(stop chan struct{}, kubeClient kubernetes.Interface) error

InitJobController init job controller

Types

type Controller

type Controller interface {
	ExecJob(job *corev1.Pod, logger io.Writer, result *channels.RingChannel) error
	GetJob(string) (*corev1.Pod, error)
	GetServiceJobs(serviceID string) ([]*corev1.Pod, error)
	DeleteJob(job string)
}

Controller build job controller

func GetJobController

func GetJobController() Controller

GetJobController get job controller