Expand description
Source — entry point for data into a streaming pipeline.
Structs§
- Source
- A streaming data source. Cloneable for multi-producer use.
Traits§
- Record
- Trait for types that can be streamed through a Source.
Functions§
- create
- Creates a new Source/Sink pair with the given buffer size.
- create_
with_ config - Creates a new Source/Sink pair with custom configuration.