jobs

type BodyProvider func() io.Reader

type GroupWatcher interface {
	OnJobRegistered(name string)
	OnJobDeregistered(name string)
	OnJobScheduled(name string)
	OnJobCompleted(name string, status *statusv1.Status, jobStats JobStats)
}

type GroupWatchers []GroupWatcher

type HTTPJob struct {
	// contains filtered or unexported fields
}

type HTTPJobConfig struct {
	Client         *http.Client
	Body           BodyProvider
	URL            string
	Method         string
	ExpectedBody   string
	Name           string
	ExpectedStatus int
}

type Job interface {
	// Returns the name
	Name() string
	// Executes the job
	Execute(ctx context.Context) (proto.Message, error)
	// JobWatchers
	JobWatchers() JobWatchers
}

type JobBase struct {
	JobName string
	JWS     JobWatchers
}

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

type JobConfig = jobsconfig.JobConfig

type JobGroup struct {
	// contains filtered or unexported fields
}

type JobGroupConfig = jobsconfig.JobGroupConfig

type JobGroupConstructor struct {
	// Name of the job group - config key is <name> and statuses are updated under <name>.<job>
	Name string
	// Config key --  if it is empty then it is <name>.scheduler
	Key           string
	GW            GroupWatchers
	DefaultConfig jobsconfig.JobGroupConfig
}

type JobInfo struct {
	LastExecuteTime time.Time
	ExecuteCount    int
}

type JobStats struct {
	Duration time.Duration
}

type JobWatcher interface {
	OnJobScheduled()
	OnJobCompleted(status *statusv1.Status, stats JobStats)
}

type JobWatchers []JobWatcher

type MultiJob struct {
	JobBase
	// contains filtered or unexported fields
}

type MultiJobConfig struct {
	jobsconfig.JobConfig
}

type MultiJobConstructor struct {
	DefaultConfig MultiJobConfig
	Name          string
	JobGroupName  string
	JWS           JobWatchers
	GWS           GroupWatchers
}

type SelfChecksIn struct {
	fx.In

	Liveness  *MultiJob `name:"liveness.service"`
	Readiness *MultiJob `name:"readiness.service"`
}