agent

Documentation

Index

• 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 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:"Deduper"`

	Deduper    flow.Deduper          `forwardTo:"Kubernetes"`
	Kubernetes k8s.MetadataDecorator `forwardTo:"ReverseDNS"`
	ReverseDNS flow.ReverseDNS       `forwardTo:"CIDRs"`
	CIDRs      cidr.Definitions      `forwardTo:"Decorator"`
	Decorator  `sendTo:"Exporter,Printer"`

	Exporter export.MetricsConfig
	Printer  export.FlowPrinterEnabled
}

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