status_updater

Documentation

Index

• func New(kubeClient kubernetes.Interface, kaiClient kai.Interface, ...) *defaultStatusUpdater
• type Interface
• type PodGroupsSync

Functions

func New

func New(
	kubeClient kubernetes.Interface,
	kaiClient kai.Interface,
	recorder record.EventRecorder,
	numberOfWorkers int,
	detailedFitErrors bool,
	nodePoolLabelKey string,
) *defaultStatusUpdater

Types

type Interface

type Interface interface {
	PodGroupsSync
	Evicted(evictedPodGroup *enginev2alpha2.PodGroup, evictionMetadata eviction_info.EvictionMetadata, message string)
	PreBind(pod *v1.Pod)
	Bound(pod *v1.Pod, hostname string, bindError error, nodePoolName string) error
	Pipelined(pod *v1.Pod, message string)
	PatchPodLabels(pod *v1.Pod, labels map[string]interface{})
	RecordJobStatusEvent(job *podgroup_info.PodGroupInfo) error

	Run(stopCh <-chan struct{})
}

type PodGroupsSync

type PodGroupsSync interface {
	SyncPodGroupsWithPendingUpdates(podGroups []*enginev2alpha2.PodGroup)
}