[−][src]Module nakadion::streaming_client
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. |
Enums
ConnectError | Errors that can happen when connections to Nakadi for establishing a streaming connection. |
Traits
StreamingClient | A client for connecting to a subscription on the Nakadi Event Broker |
Type Definitions
LineResult |