Help us shape the future of Go! Take the 2026 Go Developer Survey

agents

package
v0.0.58 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 19, 2023 License: MIT Imports: 21 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func AddProcessor added in v0.0.55

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 added in v0.0.55

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

func NewServiceLogger

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

func NewServiceProvider added in v0.0.55

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

func PinToLatestRelease added in v0.0.41

func PinToLatestRelease(agent *configurations.Agent) error

func Register

func Register(agents ...AgentImplementation)

func ValidURL added in v0.0.51

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 added in v0.0.55

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

type ClientLogHandler added in v0.0.55

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

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

func LogHandler added in v0.0.55

func LogHandler() *ClientLogHandler

func NewLogHandler added in v0.0.55

func NewLogHandler() *ClientLogHandler

func (*ClientLogHandler) Write added in v0.0.55

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

type GithubSource added in v0.0.33

type GithubSource struct {
	Owner string
	Repo  string
}

type HCLogMessageIn added in v0.0.55

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

type HCLogMessageOut added in v0.0.55

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
}

Directories

Path Synopsis
helpers
api
go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL