[−] List of all items
Structs
- api::ApiClient
- 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::CommitError
- components::committer::Committer
- components::connector::BatchLine
- components::connector::BatchLineError
- components::connector::ConnectError
- components::connector::ConnectStreamTimeoutSecs
- components::connector::Connector
- components::connector::ConnectorParams
- components::connector::Error
- 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::BatchLine
- components::streams::BatchLineError
- components::streams::BatchLineStream
- components::streams::FramedStream
- components::streams::NakadiFrame
- consumer::AbortConnectOnAuthError
- consumer::AbortConnectOnSubscriptionNotFound
- consumer::BatchFlushTimeoutSecs
- consumer::BatchLimit
- consumer::BatchTimespanSecs
- consumer::Builder
- consumer::CommitAttemptTimeoutMillis
- consumer::CommitRetryDelayMillis
- consumer::ConnectStreamRetryMaxDelaySecs
- consumer::ConnectStreamTimeoutSecs
- consumer::Consumer
- consumer::ConsumerError
- consumer::ConsumerHandle
- consumer::Consuming
- consumer::ConsumptionOutcome
- consumer::DevNullLogger
- consumer::Error
- consumer::HandlerInactivityTimeoutSecs
- consumer::LogLogger
- consumer::MaxConnectAttempts
- consumer::MaxUncommittedEvents
- consumer::Metrix
- consumer::MetrixConfig
- consumer::PartitionInactivityTimeoutSecs
- consumer::SlogLogger
- consumer::StdErrLogger
- consumer::StdOutLogger
- consumer::StreamLimit
- consumer::StreamParameters
- consumer::StreamTimeoutSecs
- consumer::SubscriptionId
- consumer::TickIntervalMillis
- consumer::WarnStreamStalledSecs
- handler::BatchMeta
- handler::BatchStats
- handler::Bytes
- handler::Error
- handler::HandlerFn
- instrumentation::DriverBuilder
- instrumentation::Instrumentation
- instrumentation::Metrix
- instrumentation::MetrixConfig
- instrumentation::MetrixTrackingSecs
- instrumentation::ProcessorMount
- instrumentation::TelemetryDriver
- publisher::BatchResponse
- publisher::Bytes
- publisher::Error
- publisher::EventTypeName
- publisher::FlowId
- publisher::NakadiApiError
- publisher::PublishAttemptTimeoutMillis
- publisher::PublishInitialRetryIntervalMillis
- publisher::PublishMaxRetryIntervalMillis
- publisher::PublishRetryIntervalMultiplier
- publisher::PublishRetryOnAuthErrors
- publisher::PublishTimeoutMillis
- publisher::Publisher
- publisher::PublisherConfig
Enums
- api::PublishFailure
- components::committer::CommitErrorKind
- components::connector::ConnectErrorKind
- components::streams::BatchLineErrorKind
- consumer::CommitStrategy
- consumer::ConsumerErrorKind
- consumer::DispatchMode
- consumer::StreamDeadPolicy
- handler::BatchPostAction
- handler::EventsPostAction
- handler::HandlerAssignment
- handler::InactivityAnswer
- handler::SpawnTarget
- instrumentation::MetricsDetailLevel
- publisher::PartialFailureStrategy
Traits
- api::MonitoringApi
- api::PublishApi
- api::SchemaRegistryApi
- api::SubscriptionApi
- api::api_ext::SubscriptionApiExt
- api::dispatch_http_request::DispatchHttpRequest
- auth::ProvidesAccessToken
- components::StreamingEssentials
- components::committer::Commits
- components::committer::ProvidesCommitter
- components::connector::Connects
- components::connector::ConnectsExt
- components::connector::ProvidesConnector
- consumer::LoggingAdapter
- handler::BatchHandler
- handler::BatchHandlerFactory
- handler::EventsHandler
- instrumentation::AggregatesProcessors
- instrumentation::Instruments
- publisher::PublishesEvents
- publisher::PublishesSerializedEvents
Typedefs
- api::ApiFuture
- api::BytesStream
- api::PublishFuture
- api::dispatch_http_request::RemoteCallResult
- api::dispatch_http_request::ResponseFuture
- auth::TokenFuture
- components::committer::CommitFuture
- components::connector::BatchStream
- components::connector::ConnectFuture
- components::connector::ConnectResult
- components::connector::EventsStream
- components::connector::FramesStream
- handler::BatchHandlerFuture
- handler::EventDeserializationResult
- handler::EventsHandlerFuture