coordinator

Documentation

Overview

Package coordinator coordinates the running of Labors within the system.

Index

• type Coordinator
  • func New(store work.Storage, cogInfo *work.CogInfo, maxReloads int) (*Coordinator, error)
  • func (c *Coordinator) Add(l *work.Labor) error
  • func (c *Coordinator) Labor(id string) (*work.Labor, error)
  • func (c *Coordinator) Signal(id string, signal work.Signal) error
  • func (c *Coordinator) Start(id string) error

Types

type Coordinator

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

Coordinator handles coordination of executing Labors.

func New

func New(store work.Storage, cogInfo *work.CogInfo, maxReloads int) (*Coordinator, error)

New is the constructor for Coordinator.

func (*Coordinator) Add

func (c *Coordinator) Add(l *work.Labor) error

Add adds a Labor for processsing. Processing begins immediately if the state is set to NotStarted. If set to AdminNotStarted, Start() must be called to begin execution.

func (*Coordinator) Labor

func (c *Coordinator) Labor(id string) (*work.Labor, error)

Labor returns a running Labor.

func (*Coordinator) Signal

func (c *Coordinator) Signal(id string, signal work.Signal) error

Signal signals a Labor (Pause/Stop/Unpause/...).

func (*Coordinator) Start

func (c *Coordinator) Start(id string) error

Start begins processing of a Labor in the AdminNotStarted state.