agent

Documentation

Index

• type Flows
  • func FlowsAgent(ctxInfo *global.ContextInfo, cfg *beyla.Config) (*Flows, error)
  • func (f *Flows) Run(ctx context.Context) error
  • func (f *Flows) Status() Status
• type FlowsPipeline
  • func (fp *FlowsPipeline) Connect()
• type Status
  • func (s Status) String() string

Types

type Flows

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

Flows reporting agent

func FlowsAgent

func FlowsAgent(ctxInfo *global.ContextInfo, 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     pipe.Start[[]*ebpf.Record]
	RingBufTracer pipe.Start[[]*ebpf.Record]

	ProtoFilter pipe.Middle[[]*ebpf.Record, []*ebpf.Record]
	Deduper     pipe.Middle[[]*ebpf.Record, []*ebpf.Record]
	Kubernetes  pipe.Middle[[]*ebpf.Record, []*ebpf.Record]
	ReverseDNS  pipe.Middle[[]*ebpf.Record, []*ebpf.Record]
	CIDRs       pipe.Middle[[]*ebpf.Record, []*ebpf.Record]
	Decorator   pipe.Middle[[]*ebpf.Record, []*ebpf.Record]

	OTEL    pipe.Final[[]*ebpf.Record]
	Prom    pipe.Final[[]*ebpf.Record]
	Printer pipe.Final[[]*ebpf.Record]
}

FlowsPipeline defines the different nodes in the Beyla's NetO11y module, as well as how they are interconnected (in its Connect() method)

func (*FlowsPipeline) Connect

func (fp *FlowsPipeline) Connect()

Connect specifies how the pipeline nodes are connected

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