mock

Documentation

Index

• func RunBytesSinkCollect(s api.BytesCollector, data [][]byte, props map[string]any) error
• func RunTupleSinkCollect(s api.TupleCollector, data []any, props map[string]any) error
• func TestSourceConnector(t *testing.T, r api.Source, props map[string]any, expected []api.Tuple, ...)

Functions

func RunBytesSinkCollect

func RunBytesSinkCollect(s api.BytesCollector, data [][]byte, props map[string]any) error

func RunTupleSinkCollect

func RunTupleSinkCollect(s api.TupleCollector, data []any, props map[string]any) error

func TestSourceConnector

func TestSourceConnector(t *testing.T, r api.Source, props map[string]any, expected []api.Tuple, sender func())