observer

Apr 15, 2021

Changes in this version

type EventType

+ const Succeeded

Feb 12, 2021

Changes in this version

+ type EventType string

+ const Create

+ const Delete

+ const Failed

+ const Running

+ const Suceeded

+ const Update

+ type ObservableJob struct

+ Event EventType

+ Exclusive bool

+ Job *batchv1.Job

+ JobType v1alpha1.JobType

+ Repository string

+ type ObservableJobCallback func(ObservableJob)

+ type Observer struct

+ func GetObserver() *Observer

+ func (o *Observer) GetJobByName(jobName string) ObservableJob

+ func (o *Observer) GetJobsByRepository(repository string) []ObservableJob

+ func (o *Observer) GetUpdateChannel() chan ObservableJob

+ func (o *Observer) IsAnyJobRunning(repository string) bool

+ func (o *Observer) IsConcurrentJobsLimitReached(jobType v1alpha1.JobType, limit int) bool

+ func (o *Observer) IsExclusiveJobRunning(repository string) bool

+ func (o *Observer) RegisterCallback(name string, callback ObservableJobCallback)