List of all items

Structs

• admin_proto::ActivateBrokerRequest
• admin_proto::ActivateBrokerResponse
• admin_proto::BrokerInfo
• admin_proto::BrokerListResponse
• admin_proto::BrokerRequest
• admin_proto::BrokerResponse
• admin_proto::DescribeTopicRequest
• admin_proto::DescribeTopicResponse
• admin_proto::Empty
• admin_proto::NamespaceListResponse
• admin_proto::NamespaceRequest
• admin_proto::NamespaceResponse
• admin_proto::NewTopicRequest
• admin_proto::PartitionedTopicRequest
• admin_proto::PolicyResponse
• admin_proto::SubscriptionListResponse
• admin_proto::SubscriptionRequest
• admin_proto::SubscriptionResponse
• admin_proto::TopicInfo
• admin_proto::TopicInfoListResponse
• admin_proto::TopicListResponse
• admin_proto::TopicRequest
• admin_proto::TopicResponse
• admin_proto::UnloadBrokerRequest
• admin_proto::UnloadBrokerResponse
• admin_proto::broker_admin_client::BrokerAdminClient
• admin_proto::broker_admin_server::BrokerAdminServer
• admin_proto::namespace_admin_client::NamespaceAdminClient
• admin_proto::namespace_admin_server::NamespaceAdminServer
• admin_proto::topic_admin_client::TopicAdminClient
• admin_proto::topic_admin_server::TopicAdminServer
• message::MessageID
• message::StreamMessage
• proto::AckRequest
• proto::AckResponse
• proto::AuthRequest
• proto::AuthResponse
• proto::ConsumerRequest
• proto::ConsumerResponse
• proto::ErrorMessage
• proto::HealthCheckRequest
• proto::HealthCheckResponse
• proto::MessageResponse
• proto::MsgId
• proto::ProducerRequest
• proto::ProducerResponse
• proto::ReceiveRequest
• proto::SchemaReference
• proto::StreamMessage
• proto::TopicLookupRequest
• proto::TopicLookupResponse
• proto::TopicPartitionsResponse
• proto::auth_service_client::AuthServiceClient
• proto::auth_service_server::AuthServiceServer
• proto::consumer_service_client::ConsumerServiceClient
• proto::consumer_service_server::ConsumerServiceServer
• proto::danube_schema::CheckCompatibilityRequest
• proto::danube_schema::CheckCompatibilityResponse
• proto::danube_schema::ConfigureTopicSchemaRequest
• proto::danube_schema::ConfigureTopicSchemaResponse
• proto::danube_schema::DeleteSchemaVersionRequest
• proto::danube_schema::DeleteSchemaVersionResponse
• proto::danube_schema::GetLatestSchemaRequest
• proto::danube_schema::GetSchemaRequest
• proto::danube_schema::GetSchemaResponse
• proto::danube_schema::GetTopicSchemaConfigRequest
• proto::danube_schema::GetTopicSchemaConfigResponse
• proto::danube_schema::ListVersionsRequest
• proto::danube_schema::ListVersionsResponse
• proto::danube_schema::RegisterSchemaRequest
• proto::danube_schema::RegisterSchemaResponse
• proto::danube_schema::SchemaVersionInfo
• proto::danube_schema::SetCompatibilityModeRequest
• proto::danube_schema::SetCompatibilityModeResponse
• proto::danube_schema::UpdateTopicValidationPolicyRequest
• proto::danube_schema::UpdateTopicValidationPolicyResponse
• proto::danube_schema::schema_registry_client::SchemaRegistryClient
• proto::danube_schema::schema_registry_server::SchemaRegistryServer
• proto::discovery_client::DiscoveryClient
• proto::discovery_server::DiscoveryServer
• proto::health_check_client::HealthCheckClient
• proto::health_check_server::HealthCheckServer
• proto::producer_service_client::ProducerServiceClient
• proto::producer_service_server::ProducerServiceServer

Enums

• admin_proto::DispatchStrategy
• dispatch_strategy::ConfigDispatchStrategy
• proto::DispatchStrategy
• proto::ErrorType
• proto::ProducerAccessMode
• proto::consumer_request::SubscriptionType
• proto::health_check_request::ClientType
• proto::health_check_response::ClientStatus
• proto::schema_reference::VersionRef
• proto::topic_lookup_response::LookupType
• storage::PersistentStorageError
• storage::StartPosition

Traits

• admin_proto::broker_admin_server::BrokerAdmin
• admin_proto::namespace_admin_server::NamespaceAdmin
• admin_proto::topic_admin_server::TopicAdmin
• proto::auth_service_server::AuthService
• proto::consumer_service_server::ConsumerService
• proto::danube_schema::schema_registry_server::SchemaRegistry
• proto::discovery_server::Discovery
• proto::health_check_server::HealthCheck
• proto::producer_service_server::ProducerService
• storage::PersistentStorage

Type Aliases

• storage::TopicStream

Constants

• admin_proto::broker_admin_server::SERVICE_NAME
• admin_proto::namespace_admin_server::SERVICE_NAME
• admin_proto::topic_admin_server::SERVICE_NAME
• proto::auth_service_server::SERVICE_NAME
• proto::consumer_service_server::SERVICE_NAME
• proto::danube_schema::schema_registry_server::SERVICE_NAME
• proto::discovery_server::SERVICE_NAME
• proto::health_check_server::SERVICE_NAME
• proto::producer_service_server::SERVICE_NAME