ringbuffer

Documentation

Overview

Package ringbuffer holds ringbuffer related files

Index

• type RingBuffer
  • func New(handler func(int, []byte)) *RingBuffer
  • func (rb *RingBuffer) Init(mgr *manager.Manager, config *config.Config) error
  • func (rb *RingBuffer) Pause() error
  • func (rb *RingBuffer) Resume() error
  • func (rb *RingBuffer) SetMonitor(_ eventstream.LostEventCounter)
  • func (rb *RingBuffer) Start(_ *sync.WaitGroup) error

Types

type RingBuffer

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

RingBuffer implements the EventStream interface using an eBPF map of type BPF_MAP_TYPE_RINGBUF

func New

func New(handler func(int, []byte)) *RingBuffer

New returns a new ring buffer based event stream.

func (*RingBuffer) Init

func (rb *RingBuffer) Init(mgr *manager.Manager, config *config.Config) error

Init the ring buffer

func (*RingBuffer) Pause

func (rb *RingBuffer) Pause() error

Pause the event stream. Do nothing when using ring buffer

func (*RingBuffer) Resume

func (rb *RingBuffer) Resume() error

Resume the event stream. Do nothing when using ring buffer

func (*RingBuffer) SetMonitor

func (rb *RingBuffer) SetMonitor(_ eventstream.LostEventCounter)

SetMonitor set the monitor

func (*RingBuffer) Start

func (rb *RingBuffer) Start(_ *sync.WaitGroup) error

Start the event stream.