agentpoll

type PollData ¶

type PollData struct {
	Roles          []core.AgentRole
	CommandChannel chan core.Command
}

PollData Gets a chain for the caller to wait on, we return a chan chan string instead of chan string directly to make sure of the following: 1- The redis pop loop will not try to pop jobs out of the queue until there is a caller waiting

for new commands

2- Prevent multiple clients polling on a single gid:nid at the same time.

type PollDataStream ¶

type PollDataStream chan PollData

type PollDataStreamManager ¶

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

A manager of Handler instances

func NewManager(agentData core.AgentInformationStorage, commandStorage core.CommandStorage) *PollDataStreamManager

func (manager *PollDataStreamManager) Get(agentID core.AgentID) PollDataStream