flow

type Accounter ¶

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

Accounter accumulates flows metrics in memory and eventually evicts them via an evictor channel. The accounting process is usually done at kernel-space. This type reimplements it at userspace for the edge case where packets are submitted directly via ring-buffer because the kernel-side accounting map is full.

func NewAccounter(
	maxEntries int, evictTimeout time.Duration,
	clock func() time.Time,
	monoClock func() time.Duration,
	m *metrics.Metrics,
	s *ovnobserv.SampleDecoder,
	udnEnabled bool,
) *Accounter

func (c *Accounter) Account(in <-chan *model.RawRecord, out chan<- []*model.Record)

type CapacityLimiter ¶ added in v0.2.1

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

CapacityLimiter forwards the flows between two nodes but checks the status of the destination node's buffered channel. If it is already full, it drops the incoming flow and periodically will log a message about the number of lost flows.

func NewCapacityLimiter(m *metrics.Metrics) *CapacityLimiter

func (c *CapacityLimiter) Limit(in <-chan []*model.Record, out chan<- []*model.Record)

type MapTracer ¶ added in v0.2.1

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

MapTracer accesses a mapped source of flows (the eBPF PerCPU HashMap), deserializes it into a flow model.Record structure, and performs the accumulation of each perCPU-record into a single flow

func NewMapTracer(fetcher mapFetcher, evictionTimeout, staleEntriesEvictTimeout time.Duration, m *metrics.Metrics,
	s *ovnobserv.SampleDecoder, udnEnabled bool) *MapTracer

func (m *MapTracer) Flush()

func (m *MapTracer) TraceLoop(ctx context.Context, forceGC bool) node.StartFunc[[]*model.Record]

type PerfBuffer ¶ added in v0.3.3

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

func NewPerfBuffer(
	maxEntries int, evictTimeout time.Duration,
) *PerfBuffer

func (c *PerfBuffer) PBuffer(in <-chan *model.PacketRecord, out chan<- []*model.PacketRecord)

type PerfTracer ¶ added in v0.3.3

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

RingBufTracer receives single-packet flows via ringbuffer (usually, these that couldn't be added in the eBPF kernel space due to the map being full or busy) and submits them to the userspace Aggregator map

func NewPerfTracer(
	reader perfReader, logTimeout time.Duration,
) *PerfTracer

func (m *PerfTracer) TraceLoop(ctx context.Context) node.StartFunc[*model.PacketRecord]

type RingBufTracer ¶ added in v0.2.1

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

RingBufTracer receives single-packet flows via ringbuffer (usually, these that couldn't be added in the eBPF kernel space due to the map being full or busy) and submits them to the userspace Aggregator map

func NewRingBufTracer(reader ringBufReader, flusher mapFlusher, logTimeout time.Duration, m *metrics.Metrics) *RingBufTracer

func (m *RingBufTracer) TraceLoop(ctx context.Context) node.StartFunc[*model.RawRecord]