agent

Documentation

Index

• type Accounter
• type CapacityLimiter
• type Decorator
• type Flows
  • func FlowsAgent(cfg *beyla.Config) (*Flows, error)
  • func (f *Flows) Run(ctx context.Context) error
  • func (f *Flows) Status() Status
• type FlowsPipeline
• type MapTracer
• type RingBufTracer
• type Status
  • func (s Status) String() string

Types

type Accounter

type Accounter struct{}

type CapacityLimiter

type CapacityLimiter struct{}

type Decorator

type Decorator struct{}

type Flows

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

Flows reporting agent

func FlowsAgent

func FlowsAgent(cfg *beyla.Config) (*Flows, error)

FlowsAgent instantiates a new agent, given a configuration.

func (*Flows) Run

func (f *Flows) Run(ctx context.Context) error

Run a Flows agent. The function will keep running in the same thread until the passed context is canceled

func (*Flows) Status

func (f *Flows) Status() Status

type FlowsPipeline

type FlowsPipeline struct {
	MapTracer       `sendTo:"Deduper"`
	RingBufTracer   `sendTo:"Accounter"`
	Accounter       `sendTo:"Deduper"`
	Deduper         flow.Deduper `forwardTo:"CapacityLimiter"`
	CapacityLimiter `sendTo:"Decorator"`
	Decorator       `sendTo:"Kubernetes"`

	Kubernetes k8s.NetworkTransformConfig `sendTo:"Exporter"`

	Exporter export.MetricsConfig
}

FlowsPipeline defines the different nodes in the Beyla's NetO11y module, as well as how they are interconnected TODO: add flow_printer node

type MapTracer

type MapTracer struct{}

type RingBufTracer

type RingBufTracer struct{}

type Status

type Status int

Status of the agent service. Helps on the health report as well as making some asynchronous tests waiting for the agent to accept flows.

const (
	StatusNotStarted Status = iota
	StatusStarting
	StatusStarted
	StatusStopping
	StatusStopped
)

func (Status) String

func (s Status) String() string