test

Documentation

Index

• 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
  • func (m *TracerFake) AppendLookupResults(results map[flow.RecordKey][]flow.RecordMetrics)
  • func (m *TracerFake) AppendRingBufEvent(flow flow.RawRecord) error
  • func (m *TracerFake) Close() error
  • func (m *TracerFake) LookupAndDeleteMap() map[flow.RecordKey][]flow.RecordMetrics
  • func (m *TracerFake) ReadRingBuf() (ringbuf.Record, error)
  • func (m *TracerFake) Register(iface ifaces.Interface) error

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 (SliceInformerFake) Subscribe

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[flow.RecordKey][]flow.RecordMetrics)

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[flow.RecordKey][]flow.RecordMetrics

func (*TracerFake) ReadRingBuf

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

func (*TracerFake) Register

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