Module nakadion::streaming_client
[−]
[src]
Connect to a stream and consume lines
Structs
Config |
Settings for establishing a connection to |
ConfigBuilder |
A builder for a |
NakadiLineIterator |
An iterator over lines received from Nakadi. |
NakadiStreamingClient |
Connects to Nakadi via HTTP and creates an iterator of lines from the data received from Nakadi over the network |
RawLine |
A line as received from Nakadi plus a timestamp. |
XFlowId | |
XNakadiStreamId |
Enums
ConnectError |
Errors that can happen when connectiong to Nakadi for extablishing a streaming connection. |
Traits
StreamingClient |
A client for connecting to a subscription on the Nakadi Event Broker |
Type Definitions
LineResult |