scheduler

Documentation

Index

• type Elector
• type Periodic
  • func NewScheduler(elector Elector) *Periodic
  • func (s *Periodic) Close() error
  • func (s *Periodic) Open(ctx context.Context) error
  • func (s *Periodic) ScheduleEvery(interval time.Duration, name string, fn func(ctx context.Context) error)

Types

type Elector

type Elector interface {
	IsLeader() bool
}

type Periodic

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

func NewScheduler

func NewScheduler(elector Elector) *Periodic

func (*Periodic) Close

func (s *Periodic) Close() error

func (*Periodic) Open

func (s *Periodic) Open(ctx context.Context) error

func (*Periodic) ScheduleEvery

func (s *Periodic) ScheduleEvery(interval time.Duration, name string, fn func(ctx context.Context) error)