agent

Documentation

Index

• Constants
• type Agent
  • func New(cfg *config.AgentConfig) (*Agent, error)
  • func (a *Agent) Run() error
  • func (a *Agent) Start() error
  • func (a *Agent) Stop()

Constants

const (
	// Uploader constants
	UploaderBatchSize    = 1000
	UploaderMaxQueueSize = 10000

	// Goroutine counts
	NumBackgroundGoroutines = 2

	// Timing constants
	MetricsShutdownTimeout = 3 * time.Second

	// Tracer constants
	PeriodicTraceHopLimit = 3

	// Signal constants
	ShutdownSignals = "SIGINT, SIGTERM"
)

Constants

const (
	LogLevelTrace = "trace"
	LogLevelDebug = "debug"
	LogLevelInfo  = "info"
	LogLevelWarn  = "warn"
	LogLevelError = "error"
)

Log levels

Types

type Agent

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

Agent represents the RPingMesh agent

func New

func New(cfg *config.AgentConfig) (*Agent, error)

New creates a new agent instance

func (*Agent) Run

func (a *Agent) Run() error

Run runs the agent with signal handling for graceful shutdown

func (*Agent) Start

func (a *Agent) Start() error

Start starts the agent

func (*Agent) Stop

func (a *Agent) Stop()

Stop stops the agent