[−] List of all items
Structs
- api::ApiClient
- api::Builder
- api::NakadiApiError
- api::SubscriptionStreamChunks
- api::dispatch_http_request::RemoteCallError
- api::dispatch_http_request::ReqwestDispatchHttpRequest
- auth::AccessToken
- auth::AccessTokenProvider
- auth::FileAccessTokenProvider
- auth::FixedAccessTokenProvider
- auth::NoAuthAccessTokenProvider
- auth::TokenError
- components::IoError
- components::committer::CommitAttemptTimeoutMillis
- components::committer::CommitConfig
- components::committer::CommitError
- components::committer::CommitHandle
- components::committer::CommitInitialRetryIntervalMillis
- components::committer::CommitItem
- components::committer::CommitMaxRetryIntervalMillis
- components::committer::CommitRetryIntervalMultiplier
- components::committer::CommitRetryOnAuthError
- components::committer::CommitTimeoutMillis
- components::committer::Committer
- components::connector::ConnectAbortOnAuthError
- components::connector::ConnectAbortOnSubscriptionNotFound
- components::connector::ConnectAttemptTimeoutSecs
- components::connector::ConnectConfig
- components::connector::ConnectError
- components::connector::ConnectMaxRetryDelaySecs
- components::connector::ConnectTimeoutSecs
- components::connector::Connector
- components::connector::Error
- components::connector::EventStream
- components::connector::EventStreamBatch
- components::connector::EventStreamError
- components::connector::FlowId
- components::connector::NakadiApiError
- components::connector::NakadiFrame
- components::connector::RandomFlowId
- components::connector::StreamId
- components::connector::StreamParameters
- components::connector::StreamedBatchMeta
- components::connector::SubscriptionCursor
- components::connector::SubscriptionId
- components::streams::EventStream
- components::streams::EventStreamBatch
- components::streams::EventStreamError
- components::streams::FramedStream
- components::streams::NakadiFrame
- consumer::Builder
- consumer::CommitAttemptTimeoutMillis
- consumer::CommitConfig
- consumer::CommitInitialRetryIntervalMillis
- consumer::CommitMaxRetryIntervalMillis
- consumer::CommitRetryIntervalMultiplier
- consumer::CommitRetryOnAuthError
- consumer::CommitTimeoutMillis
- consumer::ConnectAbortOnAuthError
- consumer::ConnectAbortOnSubscriptionNotFound
- consumer::ConnectAttemptTimeoutSecs
- consumer::ConnectConfig
- consumer::ConnectMaxRetryDelaySecs
- consumer::ConnectTimeoutSecs
- consumer::Consumer
- consumer::ConsumerError
- consumer::ConsumerHandle
- consumer::Consuming
- consumer::ConsumptionOutcome
- consumer::DebugLoggingEnabled
- consumer::DevNullLoggingAdapter
- consumer::Error
- consumer::HandlerInactivityTimeoutSecs
- consumer::LogConfig
- consumer::LogLoggingAdapter
- consumer::Metrix
- consumer::MetrixConfig
- consumer::PartitionInactivityTimeoutSecs
- consumer::ProcessorMount
- consumer::SlogLoggingAdapter
- consumer::StdErrLoggingAdapter
- consumer::StdOutLoggingAdapter
- consumer::StreamBatchFlushTimeoutSecs
- consumer::StreamBatchLimit
- consumer::StreamBatchTimespanSecs
- consumer::StreamId
- consumer::StreamLimit
- consumer::StreamMaxUncommittedEvents
- consumer::StreamParameters
- consumer::StreamTimeoutSecs
- consumer::SubscriptionId
- consumer::TickIntervalMillis
- consumer::WarnNoEventsSecs
- consumer::WarnNoFramesSecs
- handler::BatchMeta
- handler::BatchStats
- handler::Bytes
- handler::Error
- handler::HandlerFn
- instrumentation::DriverBuilder
- instrumentation::Instrumentation
- instrumentation::Metrix
- instrumentation::MetrixConfig
- instrumentation::MetrixGaugeTrackingSecs
- instrumentation::ProcessorMount
- instrumentation::TelemetryDriver
- publisher::BatchStats
- publisher::Bytes
- publisher::DriverBuilder
- publisher::Error
- publisher::EventTypeName
- publisher::FlowId
- publisher::Instrumentation
- publisher::Metrix
- publisher::NakadiApiError
- publisher::ProcessorMount
- publisher::PublishAttemptTimeoutMillis
- publisher::PublishInitialRetryIntervalMillis
- publisher::PublishMaxRetryIntervalMillis
- publisher::PublishRetryIntervalMultiplier
- publisher::PublishRetryOnAuthError
- publisher::Publisher
- publisher::PublisherConfig
- publisher::TelemetryDriver
- publisher::partitioner::DefaultBuildHasher
- publisher::partitioner::Partitioner
Enums
- api::PublishError
- components::committer::CommitErrorKind
- components::committer::CommitStrategy
- components::committer::CommitTrigger
- components::connector::ConnectErrorKind
- components::connector::ConnectTimeout
- components::streams::EventStreamErrorKind
- consumer::CommitStrategy
- consumer::ConnectTimeout
- consumer::ConsumerAbort
- consumer::ConsumerErrorKind
- consumer::DispatchMode
- consumer::LogDetailLevel
- consumer::LogPartitionEventsMode
- consumer::StreamDeadPolicy
- consumer::complex_types::DispatchMode
- consumer::complex_types::LogPartitionEventsMode
- consumer::complex_types::StreamDeadPolicy
- handler::BatchPostAction
- handler::EventsPostAction
- handler::HandlerAssignment
- handler::InactivityAnswer
- handler::SpawnTarget
- instrumentation::MetricsDetailLevel
- publisher::Metric
- publisher::PublishTimeoutMillis
- publisher::SubmissionFailure
- publisher::SubmissionFailureStrategy
Traits
- api::MonitoringApi
- api::PublishApi
- api::SchemaRegistryApi
- api::SubscriptionApi
- api::SubscriptionCommitApi
- api::SubscriptionStreamApi
- api::api_ext::SubscriptionApiExt
- api::dispatch_http_request::DispatchHttpRequest
- auth::ProvidesAccessToken
- components::StreamingEssentials
- consumer::AggregatesProcessors
- consumer::LifecycleListener
- consumer::LoggingAdapter
- handler::BatchHandler
- handler::BatchHandlerFactory
- handler::EventsHandler
- instrumentation::AggregatesProcessors
- instrumentation::Instruments
- publisher::AggregatesProcessors
- publisher::Instruments
- publisher::PublishesEvents
- publisher::PublishesSerializedEvents
- publisher::partitioner::PartitionAssignable
- publisher::partitioner::PartitionKeyExtractable
Typedefs
- api::ApiFuture
- api::BytesStream
- api::PublishFuture
- api::dispatch_http_request::RemoteCallResult
- api::dispatch_http_request::ResponseFuture
- auth::TokenFuture
- components::connector::BoxedEventStream
- components::connector::BoxedFrameStream
- components::connector::BoxedParsedEventsStream
- handler::BatchHandlerFuture
- handler::EventDeserializationResult
- handler::EventsHandlerFuture