scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) CleanupRemainingServices() map[string]service.ServiceStatus
  • func (s *Scheduler) ExecuteService(serv service.ServiceInterface) error
  • func (s *Scheduler) NotifyServiceUpdate() <-chan service.ServiceUpdateInterface
  • func (s *Scheduler) RecvNotifyServiceStatus()
  • func (s *Scheduler) RegisterServices(services map[string]service.ServiceInterface)
  • func (s *Scheduler) Start() error
  • func (s *Scheduler) UpdateServiceStatus(update service.ServiceUpdateInterface)

Types

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) CleanupRemainingServices

func (s *Scheduler) CleanupRemainingServices() map[string]service.ServiceStatus

func (*Scheduler) ExecuteService

func (s *Scheduler) ExecuteService(serv service.ServiceInterface) error

func (*Scheduler) NotifyServiceUpdate

func (s *Scheduler) NotifyServiceUpdate() <-chan service.ServiceUpdateInterface

func (*Scheduler) RecvNotifyServiceStatus

func (s *Scheduler) RecvNotifyServiceStatus()

func (*Scheduler) RegisterServices

func (s *Scheduler) RegisterServices(services map[string]service.ServiceInterface)

func (*Scheduler) Start

func (s *Scheduler) Start() error

func (*Scheduler) UpdateServiceStatus

func (s *Scheduler) UpdateServiceStatus(update service.ServiceUpdateInterface)