core

Documentation

Index

• type ScheduleManager
  • func New(store store.Store) (*ScheduleManager, error)
  • func (s *ScheduleManager) NeedStop() bool
  • func (s *ScheduleManager) Scheduler() definition.Scheduler
  • func (s *ScheduleManager) Shutdown()
  • func (s *ScheduleManager) Start()
  • func (s *ScheduleManager) Store() store.Store

Types

type ScheduleManager

type ScheduleManager struct {
	sync.Mutex

	Started           bool
	StallAfterStartup int64 // in millis
	// Interval of heartbeat
	HeartbeatInterval time.Duration
	// Timeout to be death
	DeathTimeout time.Duration
	// Schedule interval
	ScheduleInterval time.Duration
	// Timeout when trying to shutdown
	ShutdownTimeout time.Duration
	// contains filtered or unexported fields
}

func New

func New(store store.Store) (*ScheduleManager, error)

func (*ScheduleManager) NeedStop

func (s *ScheduleManager) NeedStop() bool

func (*ScheduleManager) Scheduler

func (s *ScheduleManager) Scheduler() definition.Scheduler

func (*ScheduleManager) Shutdown

func (s *ScheduleManager) Shutdown()

func (*ScheduleManager) Start

func (s *ScheduleManager) Start()

func (*ScheduleManager) Store

func (s *ScheduleManager) Store() store.Store