controller

Documentation

Index

• Constants
• func FindOwnerReferenceName(ownerReferences []metav1.OwnerReference) string
• type Controller
  • func New(name string, conf *rest.Config, cluster *schema.Cluster) (Controller, error)
  • func NewJobGC() Controller
  • func NewJobSync() Controller
  • func NewQueueSync() Controller
• type FinishedJobInfo
• type JobGarbageCollector
  • func (j *JobGarbageCollector) GetDynamicInformer(gvr schema.GroupVersionResource) cache.SharedIndexInformer
  • func (j *JobGarbageCollector) GetDynamicLister(gvr schema.GroupVersionResource) cache.GenericLister
  • func (j *JobGarbageCollector) Initialize(opt *k8s.DynamicClientOption) error
  • func (j *JobGarbageCollector) Name() string
  • func (j *JobGarbageCollector) Run(stopCh <-chan struct{})
• type JobSync
  • func (j *JobSync) Initialize(opt *k8s.DynamicClientOption) error
  • func (j *JobSync) Name() string
  • func (j *JobSync) Run(stopCh <-chan struct{})
• type JobSyncInfo
  • func (js *JobSyncInfo) String() string
• type QueueSync
  • func (qs *QueueSync) Initialize(opt *k8s.DynamicClientOption) error
  • func (qs *QueueSync) Name() string
  • func (qs *QueueSync) Run(stopCh <-chan struct{})
• type QueueSyncInfo
• type TaskSyncInfo

Constants

const (
	JobSyncControllerName = "JobSync"
	DefaultSyncRetryTimes = 3
)

const (
	DefaultJobPendingTTLSeconds = 300

	RuntimeStatusKey = "status"

	PodInitializing   = "PodInitializing"
	ContainerCreating = "ContainerCreating"
)

const (
	DefaultJobTTLSeconds = 600
)

const (
	JobGCControllerName = "JobGarbageCollector"
)

const (
	QueueSyncControllerName = "QueueSync"
)

Functions

func FindOwnerReferenceName

func FindOwnerReferenceName(ownerReferences []metav1.OwnerReference) string

Types

type Controller

type Controller interface {
	Name() string
	Initialize(opt *k8s.DynamicClientOption) error
	Run(stopCh <-chan struct{})
}

Controller interface for kubernetes job sync, job gc, and queue sync

func New

func New(name string, conf *rest.Config, cluster *schema.Cluster) (Controller, error)

func NewJobGC

func NewJobGC() Controller

func NewJobSync

func NewJobSync() Controller

func NewQueueSync

func NewQueueSync() Controller

type FinishedJobInfo

type FinishedJobInfo struct {
	Namespace          string
	Name               string
	OwnerName          string
	OwnerReferences    []metav1.OwnerReference
	Duration           time.Duration
	LastTransitionTime metav1.Time
	GVK                schema.GroupVersionKind
}

type JobGarbageCollector

type JobGarbageCollector struct {
	sync.Mutex

	WaitedCleanQueue workqueue.DelayingInterface
	// contains filtered or unexported fields
}

func (*JobGarbageCollector) GetDynamicInformer

func (j *JobGarbageCollector) GetDynamicInformer(gvr schema.GroupVersionResource) cache.SharedIndexInformer

func (*JobGarbageCollector) GetDynamicLister

func (j *JobGarbageCollector) GetDynamicLister(gvr schema.GroupVersionResource) cache.GenericLister

func (*JobGarbageCollector) Initialize

func (j *JobGarbageCollector) Initialize(opt *k8s.DynamicClientOption) error

func (*JobGarbageCollector) Name

func (j *JobGarbageCollector) Name() string

func (*JobGarbageCollector) Run

func (j *JobGarbageCollector) Run(stopCh <-chan struct{})

type JobSync

type JobSync struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*JobSync) Initialize

func (j *JobSync) Initialize(opt *k8s.DynamicClientOption) error

func (*JobSync) Name

func (j *JobSync) Name() string

func (*JobSync) Run

func (j *JobSync) Run(stopCh <-chan struct{})

type JobSyncInfo

type JobSyncInfo struct {
	ID            string
	Namespace     string
	ParentJobID   string
	GVK           schema.GroupVersionKind
	Status        commonschema.JobStatus
	RuntimeInfo   interface{}
	RuntimeStatus interface{}
	Message       string
	Action        commonschema.ActionType
	RetryTimes    int
}

func (*JobSyncInfo) String

func (js *JobSyncInfo) String() string

type QueueSync

type QueueSync struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*QueueSync) Initialize

func (qs *QueueSync) Initialize(opt *k8s.DynamicClientOption) error

func (*QueueSync) Name

func (qs *QueueSync) Name() string

func (*QueueSync) Run

func (qs *QueueSync) Run(stopCh <-chan struct{})

type QueueSyncInfo

type QueueSyncInfo struct {
	Name        string
	Namespace   string
	Labels      map[string]string
	Status      string
	QuotaType   string
	MaxResource *resources.Resource
	MinResource *resources.Resource
	Action      commonschema.ActionType
	Message     string
	RetryTimes  int
}

type TaskSyncInfo

type TaskSyncInfo struct {
	ID         string
	Name       string
	Namespace  string
	JobID      string
	NodeName   string
	MemberRole commonschema.MemberRole
	Status     commonschema.TaskStatus
	Message    string
	PodStatus  interface{}
	Action     commonschema.ActionType
	RetryTimes int
}