List of all items

Structs

• Dsh
• ManagementApiTokenFetcher
• ManagementApiTokenFetcherBuilder
• certificates::Cert
• datastream::Datastream
• datastream::Stream
• dsh::Dsh
• management_api::AccessToken
• management_api::ManagementApiTokenFetcher
• management_api::ManagementApiTokenFetcherBuilder
• protocol_adapters::http_protocol::client::HttpClient
• protocol_adapters::http_protocol::client::HttpClientBuilder
• protocol_adapters::http_protocol::client::MultiGetItem
• protocol_adapters::http_protocol::client::Stream
• protocol_adapters::http_protocol::client::Topic
• protocol_adapters::kafka_protocol::config::KafkaConfig
• protocol_adapters::token::Claims
• protocol_adapters::token::DataAccessToken
• protocol_adapters::token::DatastreamsMqttTokenClaim
• protocol_adapters::token::RequestDataAccessToken
• protocol_adapters::token::RequestRestToken
• protocol_adapters::token::RestToken
• protocol_adapters::token::TopicPermission
• protocol_adapters::token::api_client_token_fetcher::ApiClientTokenFetcher
• protocol_adapters::token::data_access_token::DataAccessToken
• protocol_adapters::token::data_access_token::Ports
• protocol_adapters::token::data_access_token::RequestDataAccessToken
• protocol_adapters::token::data_access_token::TopicPermission
• protocol_adapters::token::rest_token::Claims
• protocol_adapters::token::rest_token::DatastreamsMqttTokenClaim
• protocol_adapters::token::rest_token::RequestRestToken
• protocol_adapters::token::rest_token::RestToken
• schema_store::SchemaStoreClient
• schema_store::types::CompatibilityCheck
• schema_store::types::ConfigGet
• schema_store::types::ConfigPut
• schema_store::types::RawSchemaWithType
• schema_store::types::SchemaId
• schema_store::types::Subject
• schema_store::types::SubjectVersionInfo
• utils::dlq::Dlq
• utils::dlq::SendToDlq
• utils::graceful_shutdown::Shutdown

Enums

• DshError
• Platform
• certificates::CertificatesError
• datastream::DatastreamError
• datastream::GroupType
• datastream::ReadWriteAccess
• management_api::ManagementApiTokenError
• protocol_adapters::http_protocol::client::Accept
• protocol_adapters::http_protocol::client::ContentType
• protocol_adapters::http_protocol::client::HttpError
• protocol_adapters::http_protocol::client::ResponseBody
• protocol_adapters::token::Action
• protocol_adapters::token::ProtocolTokenError
• protocol_adapters::token::data_access_token::Action
• schema_store::SchemaStoreError
• schema_store::types::Compatibility
• schema_store::types::SchemaType
• schema_store::types::SubjectName
• schema_store::types::SubjectVersion
• utils::Platform
• utils::UtilsError
• utils::dlq::DlqErrror
• utils::dlq::Retryable
• utils::metrics::MetricsError

Traits

• DshKafkaConfig
• protocol_adapters::kafka_protocol::DshKafkaConfig
• utils::dlq::ErrorToDlq

Functions

• protocol_adapters::token::data_access_token::validate_client_id
• utils::get_configured_topics
• utils::metrics::start_http_server
• utils::tenant_name

Type Aliases

• utils::dlq::DlqChannel