test

package

v0.1.0-rc5 Latest Latest Go to latest Published: Aug 21, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func NewMockBatch() spec.Batch

NewMockBatch creates a new mock batch for testing

func NewMockComponentContext() spec.ComponentContext

NewMockComponentContext creates a mock ComponentContext for testing

func NewMockMessage(data []byte) spec.Message

NewMockMessage creates a new mock message for testing

func NewMockTriggerBatch() spec.TriggerBatch

NewMockTriggerBatch creates a new mock trigger batch for testing

func RandomPort() (int, error)

RandomPort returns an unused random port on this machine.

func TestEnvironment() spec.Environment

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

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

Legacy methods