Module nakadion::components::connector [−][src]
Expand description
A connector to directly consume Nakadi Streams
Re-exports
pub use crate::components::IoError;pub use crate::api::BytesStream;pub use crate::api::SubscriptionStreamApi;pub use crate::api::SubscriptionStreamChunks;Structs
If true abort the consumer when an auth error occurs while connecting to a stream.
If true abort the consumer when a conflict (409) occurs while connecting to a stream.
If true abort the consumer when a subscription does not exist when connection to a stream.
The timeout for a single request made to Nakadi to connect to a stream.
Parameters to configure the Connector
Error returned on failed connect attempts for a stream
The maximum retry delay between failed attempts to connect to a stream.
The maximum time for connecting to a stream.
A Connector to connect to a Nakadi Stream
An error for cases where further investigation is not necessary.
A stream of analyzed Nakadi Frames
An analyzed line (frame) from Nakadi
The flow id of the request, which is written into the logs and passed to called services. Helpful for operational troubleshooting and log analysis.
An error type to get insights on why an HTTP request failed
A frame (line) from Nakadi
Crates a random FlowId when converted into a FlowId
The id of this stream generated by Nakadi.
Parameters for starting a new stream on a subscription
Metadata on the currently received batch
Cursor of a subscription with a CursorToken which is usually found within a
SubscriptionEventStreamBatch.
Id of subscription that was created.
Enums
The retry delay between failed attempts when the previous one was a conflict.
The timeout for a request made to Nakadi to connect to a stream including retries