scheduler

Documentation

Index

• func NewServiceWorkerPool(limit int) *serviceWorkerPool
• type Scheduler
  • func NewScheduler(optWorkersCount int) *Scheduler
  • func (s *Scheduler) CleanupRemainingServices() map[string]service.ServiceStatus
  • func (s *Scheduler) GetAvailableWorkerChannel() chan *service.Service
  • func (s *Scheduler) GetAvailableWorkerChannelList() []chan *service.Service
  • func (s *Scheduler) GetWorkersCount() int
  • func (s *Scheduler) NotifyServiceUpdate() <-chan *service.UpdateService
  • func (s *Scheduler) PushService(reqCh chan *service.Service, serv *service.Service)
  • func (s *Scheduler) PushServices(reqChs []chan *service.Service, servs []*service.Service)
  • func (s *Scheduler) RecvNotifyServiceStatus()
  • func (s *Scheduler) Start() error
  • func (s *Scheduler) UpdateServiceStatus(update *service.UpdateService)

Functions

func NewServiceWorkerPool

func NewServiceWorkerPool(limit int) *serviceWorkerPool

Types

type Scheduler

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

func NewScheduler

func NewScheduler(optWorkersCount int) *Scheduler

func (*Scheduler) CleanupRemainingServices

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

func (*Scheduler) GetAvailableWorkerChannel

func (s *Scheduler) GetAvailableWorkerChannel() chan *service.Service

func (*Scheduler) GetAvailableWorkerChannelList

func (s *Scheduler) GetAvailableWorkerChannelList() []chan *service.Service

func (*Scheduler) GetWorkersCount

func (s *Scheduler) GetWorkersCount() int

func (*Scheduler) NotifyServiceUpdate

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

func (*Scheduler) PushService

func (s *Scheduler) PushService(reqCh chan *service.Service, serv *service.Service)

func (*Scheduler) PushServices

func (s *Scheduler) PushServices(reqChs []chan *service.Service, servs []*service.Service)

func (*Scheduler) RecvNotifyServiceStatus

func (s *Scheduler) RecvNotifyServiceStatus()

func (*Scheduler) Start

func (s *Scheduler) Start() error

func (*Scheduler) UpdateServiceStatus

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