[−][src]Module nakadion::components::connector
A connector to directly consume Nakadi Streams
Re-exports
pub use crate::components::IoError; |
pub use crate::api::BytesStream; |
pub use crate::api::SubscriptionApi; |
pub use crate::api::SubscriptionStreamChunks; |
Structs
BatchLine | An analyzed line (frame) from Nakadi |
BatchLineError | |
ConnectError | Error returned on failed connect attempts for a stream |
ConnectStreamTimeoutSecs | The timeout for a request made to Nakadi to connect to a stream. |
Connector | A |
ConnectorParams | Parameters to configure the |
Error | An error for cases where further investigation is not necessary |
FlowId | The flow id of the request, which is written into the logs and passed to called services. Helpful for operational troubleshooting and log analysis. |
NakadiApiError | An error type to get insights on why an HTTP request failed |
NakadiFrame | A frame (line) from Nakadi |
RandomFlowId | Crates a random |
StreamId | Id of a stream |
StreamParameters | Parameters for starting a new stream on a subscription |
StreamedBatchMeta | Metadata on the currently received batch |
Streamer | Wraps a |
SubscriptionCursor | Cursor of a subscription with a |
SubscriptionId | Id of a subscription |
Enums
ConnectErrorKind |
Traits
Connects | Can connect to a Nakadi Stream |
ProvidesConnector | Gives a |
Type Definitions
BatchStream | |
ConnectFuture | |
ConnectResult | |
EventsStream | |
FramesStream |