test

Sep 8, 2023

Changes in this version

type TracerFake

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

Jan 23, 2023

Changes in this version

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

Dec 6, 2022

Changes in this version

+ type ExporterFake struct

+ 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 []ifaces.Interface

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

+ type TracerFake struct

+ 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