scheduler

Documentation

Index

• type Option
• type Scheduler
  • func New(queues *queue.Manager, cache *cache.Cache, cl client.Client, ...) *Scheduler
  • func (s *Scheduler) NeedLeaderElection() bool
  • func (s *Scheduler) Start(ctx context.Context) error

Types

type Option

type Option func(*options)

Option configures the reconciler.

type Scheduler

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

func New

func New(queues *queue.Manager, cache *cache.Cache, cl client.Client, recorder record.EventRecorder, opts ...Option) *Scheduler

func (*Scheduler) NeedLeaderElection

func (s *Scheduler) NeedLeaderElection() bool

NeedLeaderElection Implements LeaderElectionRunnable interface to make scheduler run in leader election mode

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context) error

Start implements the Runnable interface to run scheduler as a controller.