jobs

Feb 27, 2023

Changes in this version

type JobInfo

+ ExecuteCount int

+ LastExecuteTime time.Time

type SchedulerConfig

+ BlockingExecution bool

+ WorkerLimit int

Feb 6, 2023

Changes in this version

type Job

+ func NewBasicJob(name string, jobFunc JobCallback) Job

Oct 3, 2022

Changes in this version

type JobGroup

+ func (jg *JobGroup) GetStatusRegistry() status.Registry

Sep 8, 2022

Changes in this version

type JobConfig

+ func (in *JobConfig) DeepCopy() *JobConfig

+ func (in *JobConfig) DeepCopyInto(out *JobConfig)

type JobGroupConfig

+ func (in *JobGroupConfig) DeepCopy() *JobGroupConfig

+ func (in *JobGroupConfig) DeepCopyInto(out *JobGroupConfig)

type SchedulerConfig

+ func (in *SchedulerConfig) DeepCopy() *SchedulerConfig

+ func (in *SchedulerConfig) DeepCopyInto(out *SchedulerConfig)

Aug 31, 2022

Changes in this version

+ func Module() fx.Option

+ type BasicJob struct

+ JobFunc JobCallback

+ func (job *BasicJob) Execute(ctx context.Context) (proto.Message, error)

+ func (job *BasicJob) JobWatchers() JobWatchers

+ func (job *BasicJob) Name() string

+ type BodyProvider func() io.Reader

+ type GroupWatcher interface

+ OnJobCompleted func(name string, status *statusv1.Status, jobStats JobStats)

+ OnJobDeregistered func(name string)

+ OnJobRegistered func(name string)

+ OnJobScheduled func(name string)

+ type GroupWatchers []GroupWatcher

+ func (gws GroupWatchers) OnJobCompleted(name string, status *statusv1.Status, jobStats JobStats)

+ func (gws GroupWatchers) OnJobDeregistered(name string)

+ func (gws GroupWatchers) OnJobRegistered(name string)

+ func (gws GroupWatchers) OnJobScheduled(name string)

+ type HTTPJob struct

+ func NewHTTPJob(config HTTPJobConfig) *HTTPJob

+ func (job *HTTPJob) Execute(ctx context.Context) (proto.Message, error)

+ func (job *HTTPJob) JobWatchers() JobWatchers

+ func (job *HTTPJob) Name() string

+ type HTTPJobConfig struct

+ Body BodyProvider

+ Client *http.Client

+ ExpectedBody string

+ ExpectedStatus int

+ Method string

+ Name string

+ URL string

+ type Job interface

+ Execute func(ctx context.Context) (proto.Message, error)

+ JobWatchers func() JobWatchers

+ Name func() string

+ type JobBase struct

+ JWS JobWatchers

+ JobName string

+ func (job JobBase) JobWatchers() JobWatchers

+ func (job JobBase) Name() string

+ type JobCallback func(context.Context) (proto.Message, error)

+ type JobConfig struct

+ ExecutionPeriod config.Duration

+ ExecutionTimeout config.Duration

+ InitialDelay config.Duration

+ InitiallyHealthy bool

+ type JobGroup struct

+ func NewJobGroup(statusRegistry status.Registry, maxConcurrentJobs int, ...) (*JobGroup, error)

+ func (jg *JobGroup) DeregisterAll()

+ func (jg *JobGroup) DeregisterJob(name string) error

+ func (jg *JobGroup) GetRegistry() status.Registry

+ func (jg *JobGroup) IsHealthy() bool

+ func (jg *JobGroup) JobInfo(name string) *JobInfo

+ func (jg *JobGroup) RegisterJob(job Job, config JobConfig) error

+ func (jg *JobGroup) Results() (*statusv1.GroupStatus, bool)

+ func (jg *JobGroup) Start() error

+ func (jg *JobGroup) Stop() error

+ func (jg *JobGroup) TriggerJob(name string)

+ type JobGroupConfig struct

+ type JobGroupConstructor struct

+ DefaultConfig JobGroupConfig

+ GW GroupWatchers

+ Key string

+ Name string

+ SchedulerMode SchedulerMode

+ func (jgc JobGroupConstructor) Annotate() fx.Option

+ type JobInfo struct

+ LastRunTime time.Time

+ NextRunTime time.Time

+ RunCount int

+ type JobStats struct

+ Duration time.Duration

+ type JobWatcher interface

+ OnJobCompleted func(status *statusv1.Status, stats JobStats)

+ OnJobScheduled func()

+ type JobWatchers []JobWatcher

+ func (jws JobWatchers) OnJobCompleted(status *statusv1.Status, jobStats JobStats)

+ func (jws JobWatchers) OnJobScheduled()

+ type MultiJob struct

+ func NewMultiJob(name string, alwaysHealthy bool, jws JobWatchers, gws GroupWatchers) *MultiJob

+ func (mj *MultiJob) DeregisterAll()

+ func (mj *MultiJob) DeregisterJob(name string) error

+ func (mj *MultiJob) Execute(ctx context.Context) (proto.Message, error)

+ func (mj *MultiJob) JobWatchers() JobWatchers

+ func (mj *MultiJob) Name() string

+ func (mj *MultiJob) RegisterJob(job Job) error

+ type MultiJobConfig struct

+ AlwaysHealthy bool

+ type MultiJobConstructor struct

+ DefaultConfig MultiJobConfig

+ GWS GroupWatchers

+ JWS JobWatchers

+ JobGroupName string

+ Name string

+ func (mjc MultiJobConstructor) Annotate() fx.Option

+ type SchedulerConfig struct

+ MaxConcurrentJobs int

+ type SchedulerMode int8

+ const RescheduleMode

+ const WaitMode

+ type SelfChecksIn struct

+ Liveness *MultiJob

+ Readiness *MultiJob