[−] List of all items
Structs
- api::ApiClient
- api::IoError
- api::NakadiApiError
- api::SubscriptionStream
- api::dispatch_http_request::RemoteCallError
- api::dispatch_http_request::ReqwestDispatchHttpRequest
- auth::AccessToken
- auth::AccessTokenProvider
- auth::FileAccessTokenProvider
- auth::FixedAccessTokenProvider
- auth::NoAuthAccessTokenProvider
- auth::TokenError
- 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::InactivityTimeoutSecs
- consumer::LogLogger
- consumer::MaxConnectAttempts
- consumer::MaxUncommittedEvents
- consumer::Metrix
- consumer::MetrixConfig
- 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
- instrumentation::Instrumentation
- instrumentation::Metrix
- instrumentation::MetrixConfig
- instrumentation::MetrixTrackingSecs
Enums
- api::PublishFailure
- consumer::CommitStrategy
- consumer::ConsumerErrorKind
- consumer::DispatchStrategy
- consumer::StreamDeadPolicy
- handler::BatchPostAction
- handler::EventsPostAction
- handler::HandlerAssignment
- handler::InactivityAnswer
- handler::SpawnTarget
- instrumentation::MetricsDetailLevel
Traits
- api::MonitoringApi
- api::NakadionEssentials
- api::PublishApi
- api::SchemaRegistryApi
- api::SubscriptionApi
- api::SubscriptionCommitApi
- api::SubscriptionStreamApi
- api::dispatch_http_request::DispatchHttpRequest
- auth::ProvidesAccessToken
- consumer::LoggingAdapter
- handler::BatchHandler
- handler::BatchHandlerFactory
- handler::EventsHandler
- instrumentation::Instruments