[−][src]Module nakadion::consumer
Kit for creating a consumer for a subscription
Start here if you want to consume a stream. You will need
a BatchHandlerFactory
to consume a stream.
Re-exports
pub use crate::instrumentation::Instrumentation; |
pub use crate::instrumentation::MetricsDetailLevel; |
Structs
AbortConnectOnAuthError | If |
AbortConnectOnSubscriptionNotFound | If |
BatchFlushTimeoutSecs | Maximum time in seconds to wait for the flushing of each chunk (per partition). |
BatchLimit | Maximum number of Events in each chunk (and therefore per partition) of the stream. |
BatchTimespanSecs | Useful for batching events based on their received_at timestamp. |
Builder | Creates a |
CommitAttemptTimeoutMillis | The timeout for a request made to Nakadi to commit cursors. |
CommitRetryDelayMillis | The delay between failed attempts to commit cursors. |
ConnectStreamRetryMaxDelaySecs | The maximum retry delay between failed attempts to connect to a stream. |
ConnectStreamTimeoutSecs | The timeout for a request made to Nakadi to connect to a stream. |
Consumer | Consumes an event stream |
ConsumerError | Always leads to Nakadion shutting down |
ConsumerHandle | A handle for controlling a |
Consuming | A Future that completes once the consumer stopped events consumption |
ConsumptionOutcome | Returned once a |
DevNullLogger | Does no logging at all |
Error | An error for cases where further investigation is not necessary |
InactivityTimeoutSecs | The time after which a stream or partition is considered inactive. |
LogLogger | A logger based on |
MaxConnectAttempts | The maximum number of attempts to be made to connect to a stream. |
MaxUncommittedEvents | The maximum number of uncommitted events that Nakadi will stream before pausing the stream. |
Metrix | Instrumentation with Metrix |
MetrixConfig | |
SlogLogger | A logger based on |
StdErrLogger | Logs to stderr |
StdOutLogger | Logs to stdout |
StreamLimit | Maximum number of Events in this stream (over all partitions being streamed in this connection). |
StreamParameters | Parameters for starting a new stream on a subscription |
StreamTimeoutSecs | Maximum time in seconds a stream will live before connection is closed by the server. |
SubscriptionId | Id of a subscription |
TickIntervalMillis | The internal tick interval. |
WarnStreamStalledSecs | Emits a warning when no lines were received from Nakadi. |
Enums
CommitStrategy | Defines how to commit cursors |
ConsumerErrorKind | |
DispatchStrategy | Defines how to dispatch batches to handlers. |
StreamDeadPolicy | Specifies when a stream is considered dead and has to be aborted. |
Traits
LoggingAdapter | An adapter for pluggable logging. |