[][src]Module nakadion::streaming_client

Connect to a stream and consume lines

Structs

Config

Settings for establishing a connection to Nakadi.

ConfigBuilder

A builder for a Config.

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 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