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 any, sender func())
- func TestSourceConnectorCompare(t *testing.T, r api.Source, props map[string]any, expected any, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunBytesSinkCollect ¶
func RunTupleSinkCollect ¶
func TestSourceConnector ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.