agentpoll

Documentation

Overview

Handling of tricky Agent polling logic. Should eventually be made a lot simpler.

Index

• type PollData
• type PollDataStream
• type PollDataStreamManager
  • func NewManager(agentData core.AgentInformationStorage, commandStorage core.CommandStorage) *PollDataStreamManager
  • func (manager *PollDataStreamManager) Get(agentID core.AgentID) PollDataStream

Types

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

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

func (*PollDataStreamManager) Get

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