test

package

v0.3.0 Latest Latest Go to latest Published: Feb 17, 2023 License: Apache-2.0 Imports: 9 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 []*flow.Record)
- func (ef *ExporterFake) Get(t *testing.T, timeout time.Duration) []*flow.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 []*flow.Record)

func (*ExporterFake) Get ¶

func (ef *ExporterFake) Get(t *testing.T, timeout time.Duration) []*flow.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][]ebpf.BpfFlowMetrics)

func (*TracerFake) AppendRingBufEvent ¶

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

func (*TracerFake) Close ¶

func (m *TracerFake) Close() error

func (*TracerFake) LookupAndDeleteMap ¶

func (m *TracerFake) LookupAndDeleteMap() map[ebpf.BpfFlowId][]ebpf.BpfFlowMetrics

func (*TracerFake) ReadRingBuf ¶

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

func (*TracerFake) Register ¶

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

Source Files ¶

View all Source files

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