agent

Documentation

Index

• Constants
• Variables
• func LoadConfig() ([]byte, error)
• type Agent
  • func NewAgent(config *pc.Agent, logger *pct.Logger, client pct.WebsocketClient, addr string, ...) *Agent
  • func (agent *Agent) AllStatus() map[string]string
  • func (agent *Agent) GetAllConfigs() (interface{}, []error)
  • func (agent *Agent) GetConfig() ([]proto.AgentConfig, []error)
  • func (agent *Agent) GetDefaults(cmd *proto.Cmd) (interface{}, []error)
  • func (agent *Agent) Handle(cmd *proto.Cmd) *proto.Reply
  • func (agent *Agent) Run() error
  • func (agent *Agent) Status() map[string]string
• type CollectInfoData

Constants

const (
	DEFAULT_KEEPALIVE = 76
	DEFAULT_LISTEN    = "127.0.0.1:9000"
)

const (
	CMD_QUEUE_SIZE    = 10
	STATUS_QUEUE_SIZE = 10
	MAX_ERRORS        = 3
)

Variables

var (
	ErrStop = errors.New("received Stop command")
)

Functions

func LoadConfig

func LoadConfig() ([]byte, error)

Types

type Agent

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

func NewAgent

func NewAgent(config *pc.Agent, logger *pct.Logger, client pct.WebsocketClient, addr string, services map[string]pct.ServiceManager) *Agent

func (*Agent) AllStatus

func (agent *Agent) AllStatus() map[string]string

func (*Agent) GetAllConfigs

func (agent *Agent) GetAllConfigs() (interface{}, []error)

func (*Agent) GetConfig

func (agent *Agent) GetConfig() ([]proto.AgentConfig, []error)

func (*Agent) GetDefaults

func (agent *Agent) GetDefaults(cmd *proto.Cmd) (interface{}, []error)

func (*Agent) Handle

func (agent *Agent) Handle(cmd *proto.Cmd) *proto.Reply

func (*Agent) Run

func (agent *Agent) Run() error

func (*Agent) Status

func (agent *Agent) Status() map[string]string

type CollectInfoData

type CollectInfoData struct {
	Filename string
	Data     []byte
}