dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher() *Dispatcher
  • func (d *Dispatcher) Add(a *agent.Agent) int
  • func (d *Dispatcher) Remove(id string)

Types

type Dispatcher

type Dispatcher struct {
	Log   chan []byte
	Queue []*agent.Agent
	// contains filtered or unexported fields
}

Dispatcher handles the processing of submitted executor agents

func NewDispatcher

func NewDispatcher() *Dispatcher

NewDispatcher returns a new Dispatcher with defaults

func (*Dispatcher) Add

func (d *Dispatcher) Add(a *agent.Agent) int

Add adds an agent to the dispatcher queue

func (*Dispatcher) Remove

func (d *Dispatcher) Remove(id string)

Remove removes an agent by id from the dispatcher queue