agents

Documentation

Index

• type Agent
• type AgentReply
• type Manager
  • func New(requests chan *choria.ConnectorMessage, fw *choria.Framework, ...) *Manager
  • func (a *Manager) Choria() *choria.Framework
  • func (a *Manager) DenyAgent(agent string)
  • func (a *Manager) Dispatch(ctx context.Context, wg *sync.WaitGroup, replies chan *AgentReply, ...)
  • func (a *Manager) Get(name string) (Agent, bool)
  • func (a *Manager) KnownAgents() []string
  • func (a *Manager) Logger() *logrus.Entry
  • func (a *Manager) RegisterAgent(ctx context.Context, name string, agent Agent, conn choria.AgentConnector) error
• type Metadata
• type ServerInfoSource
• type ServerStats

Types

type Agent

type Agent interface {
	Metadata() *Metadata
	Name() string
	HandleMessage(context.Context, *choria.Message, protocol.Request, choria.ConnectorInfo, chan *AgentReply)
	SetServerInfo(ServerInfoSource)
	ServerInfo() ServerInfoSource
	ShouldActivate() bool
}

Agent is a generic choria agent

type AgentReply

type AgentReply struct {
	Body    []byte
	Request protocol.Request
	Message *choria.Message
	Error   error
}

type Manager

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

func New

func New(requests chan *choria.ConnectorMessage, fw *choria.Framework, conn choria.ConnectorInfo, srv ServerInfoSource, log *logrus.Entry) *Manager

New creates a new Agent Manager

func (*Manager) Choria

func (a *Manager) Choria() *choria.Framework

func (*Manager) DenyAgent

func (a *Manager) DenyAgent(agent string)

DenyAgent adds an agent to the list of agent names not allowed to start

func (*Manager) Dispatch

func (a *Manager) Dispatch(ctx context.Context, wg *sync.WaitGroup, replies chan *AgentReply, msg *choria.Message, request protocol.Request)

func (*Manager) Get

func (a *Manager) Get(name string) (Agent, bool)

func (*Manager) KnownAgents

func (a *Manager) KnownAgents() []string

KnownAgents retrieves a list of known agents

func (*Manager) Logger

func (a *Manager) Logger() *logrus.Entry

func (*Manager) RegisterAgent

func (a *Manager) RegisterAgent(ctx context.Context, name string, agent Agent, conn choria.AgentConnector) error

RegisterAgent connects a new agent to the server instance, subscribe to all its targets etc

type Metadata

type Metadata struct {
	License     string `json:"license"`
	Author      string `json:"author"`
	Timeout     int    `json:"timeout"`
	Name        string `json:"name"`
	Version     string `json:"version"`
	URL         string `json:"url"`
	Description string `json:"description"`
}

type ServerInfoSource

type ServerInfoSource interface {
	KnownAgents() []string
	AgentMetadata(string) (Metadata, bool)
	ConfigFile() string
	Classes() []string
	Facts() json.RawMessage
	StartTime() time.Time
	Stats() ServerStats
	NewEvent(t lifecycle.Type, opts ...lifecycle.Option) error
	MachinesStatus() ([]aagent.MachineState, error)
	MachineTransition(name string, version string, path string, id string, transition string) error
}

ServerInfoSource provides data about a running server instance

type ServerStats

type ServerStats struct {
	Total      float64 `json:"total"`
	Valid      float64 `json:"valid"`
	Invalid    float64 `json:"invalid"`
	Passed     float64 `json:"passed"`
	Filtered   float64 `json:"filtered"`
	Replies    float64 `json:"replies"`
	TTLExpired float64 `json:"ttlexpired"`
}