Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.