job

Documentation

Index

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

Functions

func InitJobController

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

InitJobController init job controller

Types

type Controller

type Controller interface {
	ExecJob(ctx context.Context, job *corev1.Pod, logger io.Writer, result *channels.RingChannel) error
	GetJob(string) (*corev1.Pod, error)
	GetServiceJobs(serviceID string) ([]*corev1.Pod, error)
	DeleteJob(job string)
	GetLanguageBuildSetting(lang code.Lang, name string) string
	GetDefaultLanguageBuildSetting(lang code.Lang) string
}

Controller build job controller

func GetJobController

func GetJobController() Controller

GetJobController get job controller