[−][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::SubscriptionStreamApi; |
pub use crate::api::SubscriptionStreamChunks; |
Structs
ConnectAbortOnAuthError | If |
ConnectAbortOnSubscriptionNotFound | If |
ConnectAttemptTimeoutSecs | The timeout for a single request made to Nakadi to connect to a stream. |
ConnectConfig | Parameters to configure the |
ConnectError | Error returned on failed connect attempts for a stream |
ConnectMaxRetryDelaySecs | The maximum retry delay between failed attempts to connect to a stream. |
ConnectTimeoutSecs | The maximum time for connecting to a stream. |
Connector | A |
Error | An error for cases where further investigation is not necessary. |
EventStream | A stream of analyzed Nakadi Frames |
EventStreamBatch | An analyzed line (frame) from Nakadi |
EventStreamError | |
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 | The id of this stream generated by Nakadi. |
StreamParameters | Parameters for starting a new stream on a subscription |
StreamedBatchMeta | Metadata on the currently received batch |
SubscriptionCursor | Cursor of a subscription with a |
SubscriptionId | Id of subscription that was created. |
Enums
ConnectErrorKind | |
ConnectTimeout | The timeout for a request made to Nakadi to connect to a stream including retries |
Type Definitions
BoxedEventStream | |
BoxedFrameStream | |
BoxedParsedEventsStream |