agents

Documentation

Index

• Variables
• func AddProcessor(processor wool.LogProcessorWithSource)
• func Cleanup(unique string)
• func ClearAgents()
• func Download(ctx context.Context, p *configurations.Agent) error
• func DownloadURL(p *configurations.Agent) string
• func Load[P AgentContext, Instance any](ctx context.Context, p *configurations.Agent, unique string) (*Instance, error)
• func NewAgentLogger(agent *configurations.Agent) wool.LogProcessor
• func NewAgentProvider(ctx context.Context, agent *configurations.Agent) *wool.Provider
• func NewServiceLogger(service *configurations.ServiceIdentity) wool.LogProcessor
• func NewServiceProvider(ctx context.Context, service *configurations.ServiceIdentity) *wool.Provider
• func PinToLatestRelease(agent *configurations.Agent) error
• func Register(agents ...AgentImplementation)
• func ValidURL(s string) bool
• type Agent
• type AgentContext
• 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 GithubSource
• type HCLogMessageIn
• type HCLogMessageOut
• type Pluggable

Variables

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

Functions

func AddProcessor

func AddProcessor(processor wool.LogProcessorWithSource)

func Cleanup

func Cleanup(unique string)

func ClearAgents

func ClearAgents()

func Download

func Download(ctx context.Context, p *configurations.Agent) error

func DownloadURL

func DownloadURL(p *configurations.Agent) string

func Load

func Load[P AgentContext, Instance any](ctx context.Context, p *configurations.Agent, unique string) (*Instance, error)

func NewAgentLogger

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

func NewAgentProvider

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

func NewServiceLogger

func NewServiceLogger(service *configurations.ServiceIdentity) wool.LogProcessor

func NewServiceProvider

func NewServiceProvider(ctx context.Context, service *configurations.ServiceIdentity) *wool.Provider

func PinToLatestRelease

func PinToLatestRelease(agent *configurations.Agent) error

func Register

func Register(agents ...AgentImplementation)

func ValidURL

func ValidURL(s string) bool

Types

type Agent

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

type AgentContext

type AgentContext interface {
	Key(p *configurations.Agent, unique string) string
	Default() plugin.Plugin
}

type AgentImplementation

type AgentImplementation struct {
	Agent         plugin.Plugin
	Configuration *configurations.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 {
	// 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 GithubSource

type GithubSource struct {
	Owner string
	Repo  string
}

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"`
}

type Pluggable

type Pluggable interface {
	ImplementationKind() string
	Path() (string, error)
	Name() string
	Unique() string
}