jobs

Documentation

Index

• Constants
• type JobsManager
  • func (s *JobsManager) DelayOrSkipJob(ctx context.Context, namespace string, objectType string, job v1alpha2.JobData) error
  • func (s *JobsManager) Enabled() bool
  • func (s *JobsManager) HandleHeartBeatEvent(ctx context.Context, event v1alpha2.Event) error
  • func (s *JobsManager) HandleJobEvent(ctx context.Context, event v1alpha2.Event) error
  • func (s *JobsManager) HandleScheduleEvent(ctx context.Context, event v1alpha2.Event) error
  • func (s *JobsManager) Init(vContext *contexts.VendorContext, config managers.ManagerConfig, ...) error
  • func (s *JobsManager) Poll() []error
  • func (s *JobsManager) Reconcil() []error
• type LastSuccessTime

Constants

const Scheduled = "Scheduled"

Types

type JobsManager

type JobsManager struct {
	managers.Manager
	PersistentStateProvider states.IStateProvider
	VolatileStateProvider   states.IStateProvider
	// contains filtered or unexported fields
}

func (*JobsManager) DelayOrSkipJob

func (s *JobsManager) DelayOrSkipJob(ctx context.Context, namespace string, objectType string, job v1alpha2.JobData) error

func (*JobsManager) Enabled

func (s *JobsManager) Enabled() bool

func (*JobsManager) HandleHeartBeatEvent

func (s *JobsManager) HandleHeartBeatEvent(ctx context.Context, event v1alpha2.Event) error

func (*JobsManager) HandleJobEvent

func (s *JobsManager) HandleJobEvent(ctx context.Context, event v1alpha2.Event) error

func (*JobsManager) HandleScheduleEvent

func (s *JobsManager) HandleScheduleEvent(ctx context.Context, event v1alpha2.Event) error

func (*JobsManager) Init

func (s *JobsManager) Init(vContext *contexts.VendorContext, config managers.ManagerConfig, providers map[string]providers.IProvider) error

func (*JobsManager) Poll

func (s *JobsManager) Poll() []error

func (*JobsManager) Reconcil

func (s *JobsManager) Reconcil() []error

type LastSuccessTime

type LastSuccessTime struct {
	Time time.Time `json:"time"`
}