ebpf

Documentation

Index

• type FlowTracer
  • func NewFlowTracer(sampling, cacheMaxSize, buffersLength int, evictionTimeout time.Duration, ...) (*FlowTracer, error)
  • func (m *FlowTracer) Register(iface ifaces.Interface) error
  • func (m *FlowTracer) Trace(ctx context.Context, forwardFlows chan<- []*flow.Record)

Types

type FlowTracer

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

FlowTracer reads and forwards the Flows from the Transmission Control, for a given interface.

func NewFlowTracer

func NewFlowTracer(
	sampling, cacheMaxSize, buffersLength int,
	evictionTimeout time.Duration,
	namer flow.InterfaceNamer,
) (*FlowTracer, error)

TODO: decouple flowtracer logic from eBPF maps access so we can inject mocks for testing

func (*FlowTracer) Register

func (m *FlowTracer) Register(iface ifaces.Interface) error

Register and links the eBPF tracer into the system. The program should invoke Unregister before exiting.

func (*FlowTracer) Trace

func (m *FlowTracer) Trace(ctx context.Context, forwardFlows chan<- []*flow.Record)

Trace and forward the read flows until the passed context is Done