test

package

v1.9.0-community Latest Latest Go to latest Published: Jun 30, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/netobserv/netobserv-ebpf-agent

Links

Open Source Insights

Documentation ¶

Index ¶

func ReceiveTimeout[T any](t *testing.T, ch <-chan T, timeout time.Duration) T
type ExporterFake
- func NewExporterFake() *ExporterFake
- func (ef *ExporterFake) Export(in <-chan []*model.Record)
- func (ef *ExporterFake) Get(t *testing.T, timeout time.Duration) []*model.Record
type SliceInformerFake
- func (sif SliceInformerFake) Subscribe(_ context.Context) (<-chan ifaces.Event, error)
type TracerFake
- func NewTracerFake() *TracerFake

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ReceiveTimeout ¶ added in v0.2.4

func ReceiveTimeout[T any](t *testing.T, ch <-chan T, timeout time.Duration) T

ReceiveTimeout returns the first received element or fails the test if nothing is received before the given timeout

Types ¶

type ExporterFake ¶

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

func NewExporterFake ¶

func NewExporterFake() *ExporterFake

func (*ExporterFake) Export ¶

func (ef *ExporterFake) Export(in <-chan []*model.Record)

func (*ExporterFake) Get ¶

func (ef *ExporterFake) Get(t *testing.T, timeout time.Duration) []*model.Record

type SliceInformerFake ¶

type SliceInformerFake []ifaces.Interface

SliceInformerFake fakes the ifaces.Informer implementation by just notifying all the interfaces in the slice

func (sif SliceInformerFake) Subscribe(_ context.Context) (<-chan ifaces.Event, error)

type TracerFake ¶

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

TracerFake fakes the kernel-side eBPF map structures for testing

func NewTracerFake ¶

func NewTracerFake() *TracerFake

func (*TracerFake) AppendLookupResults ¶

func (m *TracerFake) AppendLookupResults(results map[ebpf.BpfFlowId]model.BpfFlowContent)

func (*TracerFake) AppendRingBufEvent ¶

func (m *TracerFake) AppendRingBufEvent(flow model.RawRecord) error

func (*TracerFake) AttachTCX ¶

func (m *TracerFake) AttachTCX(_ *ifaces.Interface) error

func (*TracerFake) Close ¶

func (m *TracerFake) Close() error

func (*TracerFake) DeleteMapsStaleEntries ¶ added in v0.3.2

func (m *TracerFake) DeleteMapsStaleEntries(_ time.Duration)

func (*TracerFake) DetachTCX ¶

func (m *TracerFake) DetachTCX(_ *ifaces.Interface) error

func (*TracerFake) LookupAndDeleteMap ¶

func (m *TracerFake) LookupAndDeleteMap(_ *metrics.Metrics) map[ebpf.BpfFlowId]model.BpfFlowContent

func (*TracerFake) ReadRingBuf ¶

func (m *TracerFake) ReadRingBuf() (ringbuf.Record, error)

func (*TracerFake) Register ¶

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

func (*TracerFake) UnRegister ¶

func (m *TracerFake) UnRegister(iface *ifaces.Interface) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL