scheduler

Documentation

Index

• type PlatformStorageManager
• type Scheduler
  • func New(p PlatformStorageManager) (*Scheduler, error)
  • func (s *Scheduler) DeleteFunction(funcName string) error
  • func (s *Scheduler) GetWorker(funcName string, resCh chan *worker.Worker)
  • func (s *Scheduler) GetWorkerMust(funcName string, resCh chan *worker.Worker)
  • func (s *Scheduler) RegisterWorker(workerID string, workerAddr string)
  • func (s *Scheduler) Work()

Types

type PlatformStorageManager

type PlatformStorageManager interface {
	GetCodeURI(funcName string) (string, error)
	GetImage(funcName string) (string, error)
}

type Scheduler

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

Scheduler has serveral roles: dispatch tasks to workers maintain metrics alloc and release workers

func New

func New(p PlatformStorageManager) (*Scheduler, error)

New returns a scheduler

func (*Scheduler) DeleteFunction

func (s *Scheduler) DeleteFunction(funcName string) error

DeleteFunction is invoked when the user deletes a function

func (*Scheduler) GetWorker

func (s *Scheduler) GetWorker(funcName string, resCh chan *worker.Worker)

func (*Scheduler) GetWorkerMust

func (s *Scheduler) GetWorkerMust(funcName string, resCh chan *worker.Worker)

func (*Scheduler) RegisterWorker

func (s *Scheduler) RegisterWorker(workerID string, workerAddr string)

RegisterWorker

func (*Scheduler) Work

func (s *Scheduler) Work()