agents

Documentation

Index

• Variables
• func AddProcessor(processor wool.LogProcessorWithSource)
• func LogToConsole()
• func NewAgentLogger(agent *resources.Agent) wool.LogProcessor
• func NewAgentProvider(ctx context.Context, agent *resources.Agent) *wool.Provider
• func NewAgentServiceLogger(identity *resources.ServiceIdentity) wool.LogProcessor
• func NewServiceAgentProvider(ctx context.Context, identity *resources.ServiceIdentity) *wool.Provider
• func NewServiceLogger(identity *resources.ServiceIdentity) wool.LogProcessor
• func NewServiceProvider(ctx context.Context, identity *resources.ServiceIdentity) *wool.Provider
• func Register(agents ...AgentImplementation)
• type Agent
• type AgentImplementation
• type AgentLogger
  • func (w *AgentLogger) Process(log *wool.Log)
• type ClientLogHandler
  • func LogHandler() *ClientLogHandler
  • func NewLogHandler() *ClientLogHandler
  • func (h *ClientLogHandler) Write(p []byte) (n int, err error)
• type HCLogMessageIn
• type HCLogMessageOut

Variables

var HandshakeConfig = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "codefly::agents",
	MagicCookieValue: "0.0.0",
}

Functions

func AddProcessor

func AddProcessor(processor wool.LogProcessorWithSource)

func LogToConsole

func LogToConsole()

func NewAgentLogger

func NewAgentLogger(agent *resources.Agent) wool.LogProcessor

func NewAgentProvider

func NewAgentProvider(ctx context.Context, agent *resources.Agent) *wool.Provider

func NewAgentServiceLogger

func NewAgentServiceLogger(identity *resources.ServiceIdentity) wool.LogProcessor

func NewServiceAgentProvider

func NewServiceAgentProvider(ctx context.Context, identity *resources.ServiceIdentity) *wool.Provider

func NewServiceLogger

func NewServiceLogger(identity *resources.ServiceIdentity) wool.LogProcessor

func NewServiceProvider

func NewServiceProvider(ctx context.Context, identity *resources.ServiceIdentity) *wool.Provider

func Register

func Register(agents ...AgentImplementation)

Types

type Agent

type Agent struct {
	Configuration  *resources.Agent
	Type           string
	Implementation plugin.Plugin
}

type AgentImplementation

type AgentImplementation struct {
	Agent         plugin.Plugin
	Configuration *resources.Agent
}

type AgentLogger

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

func (*AgentLogger) Process

func (w *AgentLogger) Process(log *wool.Log)

type ClientLogHandler

type ClientLogHandler struct {
	Receiver hclog.Logger
	// contains filtered or unexported fields
}

A ClientLogHandler handles logs from the Agents and converts them back to wool.Log

func LogHandler

func LogHandler() *ClientLogHandler

func NewLogHandler

func NewLogHandler() *ClientLogHandler

func (*ClientLogHandler) Write

func (h *ClientLogHandler) Write(p []byte) (n int, err error)

type HCLogMessageIn

type HCLogMessageIn struct {
	Level     string    `json:"@level"`
	Timestamp time.Time `json:"@timestamp"`
	Message   string    `json:"@message"`
	Module    string    `json:"@module"`
}

type HCLogMessageOut

type HCLogMessageOut struct {
	Log    *wool.Log        `json:"log"`
	Source *wool.Identifier `json:"identifier"`
}