test

Sep 11, 2025

Changes in this version

+ func NewMockBatch() spec.Batch

+ func NewMockComponentContext() spec.ComponentContext

+ func NewMockMessage(data []byte) spec.Message

+ func NewMockTriggerBatch() spec.TriggerBatch

+ func RandomPort() (int, error)

+ func TestEnvironment() spec.Environment

+ type ListCollector struct

+ func NewListCollector() *ListCollector

+ func (l *ListCollector) Collect(message spec.Message) error

+ func (l *ListCollector) Disconnect() error

+ func (l *ListCollector) DisconnectOld(ctx context.Context) error

+ func (l *ListCollector) Flush() (spec.Batch, error)

+ func (l *ListCollector) Messages() []spec.Message

+ func (l *ListCollector) Reset()

+ func (l *ListCollector) Wait()

+ func (l *ListCollector) WaitWithTimeout(timeout time.Duration) bool

+ func (l *ListCollector) Write(message spec.Message) error

+ func (l *ListCollector) WriteOld(ctx context.Context, message spec.Message) error