List of all items

Structs

• admin_proto::ActivateBrokerRequest
• admin_proto::ActivateBrokerResponse
• admin_proto::AddNodeRequest
• admin_proto::AddNodeResponse
• admin_proto::BindingDefinition
• admin_proto::BrokerInfo
• admin_proto::BrokerListResponse
• admin_proto::BrokerLoadInfo
• admin_proto::BrokerRequest
• admin_proto::BrokerResponse
• admin_proto::ClusterBalanceRequest
• admin_proto::ClusterBalanceResponse
• admin_proto::ClusterStatusResponse
• admin_proto::CreateBindingRequest
• admin_proto::CreateBindingResponse
• admin_proto::CreateRoleRequest
• admin_proto::CreateRoleResponse
• admin_proto::DeleteBindingRequest
• admin_proto::DeleteBindingResponse
• admin_proto::DeleteRoleRequest
• admin_proto::DeleteRoleResponse
• admin_proto::DescribeTopicRequest
• admin_proto::DescribeTopicResponse
• admin_proto::Empty
• admin_proto::GetBindingRequest
• admin_proto::GetBindingResponse
• admin_proto::GetRoleRequest
• admin_proto::GetRoleResponse
• admin_proto::GetSubscriptionFailurePolicyRequest
• admin_proto::GetSubscriptionFailurePolicyResponse
• admin_proto::ListBindingsRequest
• admin_proto::ListBindingsResponse
• admin_proto::ListRolesResponse
• admin_proto::NamespaceListResponse
• admin_proto::NamespaceRequest
• admin_proto::NamespaceResponse
• admin_proto::NewTopicRequest
• admin_proto::PartitionedTopicRequest
• admin_proto::PolicyResponse
• admin_proto::PromoteNodeRequest
• admin_proto::PromoteNodeResponse
• admin_proto::ProposedMove
• admin_proto::RebalanceRequest
• admin_proto::RebalanceResponse
• admin_proto::RemoveNodeRequest
• admin_proto::RemoveNodeResponse
• admin_proto::RoleDefinition
• admin_proto::SetSubscriptionFailurePolicyRequest
• admin_proto::SubscriptionFailurePolicy
• 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::cluster_admin_client::ClusterAdminClient
• admin_proto::cluster_admin_server::ClusterAdminServer
• admin_proto::namespace_admin_client::NamespaceAdminClient
• admin_proto::namespace_admin_server::NamespaceAdminServer
• admin_proto::security_admin_client::SecurityAdminClient
• admin_proto::security_admin_server::SecurityAdminServer
• admin_proto::topic_admin_client::TopicAdminClient
• admin_proto::topic_admin_server::TopicAdminServer
• jwt::Claims
• message::MessageID
• message::StreamMessage
• metadata::KeyValueVersion
• metadata::MemoryStore
• metadata::WatchStream
• proto::AckRequest
• proto::AckResponse
• proto::ConsumerRequest
• proto::ConsumerResponse
• proto::HealthCheckRequest
• proto::HealthCheckResponse
• proto::MessageResponse
• proto::MsgId
• proto::NackRequest
• proto::NackResponse
• proto::ProducerRequest
• proto::ProducerResponse
• proto::ReceiveRequest
• proto::SchemaReference
• proto::StreamMessage
• proto::TopicLookupRequest
• proto::TopicLookupResponse
• proto::TopicPartitionsResponse
• 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::edge::EdgeChange
• proto::edge::EdgeHeartbeatRequest
• proto::edge::EdgeHeartbeatResponse
• proto::edge::EdgeTopicDeclaration
• proto::edge::RegisterEdgeRequest
• proto::edge::RegisterEdgeResponse
• proto::edge::ReplicateAck
• proto::edge::ReplicateBatch
• proto::edge::ResolvedSchema
• proto::edge::TopicRegistrationResult
• proto::edge::edge_replicator_service_client::EdgeReplicatorServiceClient
• proto::edge::edge_replicator_service_server::EdgeReplicatorServiceServer
• proto::health_check_client::HealthCheckClient
• proto::health_check_server::HealthCheckServer
• proto::producer_service_client::ProducerServiceClient
• proto::producer_service_server::ProducerServiceServer
• raft_proto::ClientWriteReply
• raft_proto::ClientWriteRequest
• raft_proto::Empty
• raft_proto::NodeInfoReply
• raft_proto::RaftReply
• raft_proto::RaftRequest
• raft_proto::raft_transport_client::RaftTransportClient
• raft_proto::raft_transport_server::RaftTransportServer

Enums

• admin_proto::DispatchStrategy
• admin_proto::SubscriptionBackoffStrategy
• admin_proto::SubscriptionPoisonPolicy
• dispatch_strategy::ConfigDispatchStrategy
• metadata::MetaOptions
• metadata::MetadataError
• metadata::WatchEvent
• proto::DispatchStrategy
• proto::ProducerAccessMode
• proto::consumer_request::SubscriptionType
• proto::edge::EdgeChangeType
• 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::cluster_admin_server::ClusterAdmin
• admin_proto::namespace_admin_server::NamespaceAdmin
• admin_proto::security_admin_server::SecurityAdmin
• admin_proto::topic_admin_server::TopicAdmin
• metadata::MetadataStore
• proto::consumer_service_server::ConsumerService
• proto::danube_schema::schema_registry_server::SchemaRegistry
• proto::discovery_server::Discovery
• proto::edge::edge_replicator_service_server::EdgeReplicatorService
• proto::health_check_server::HealthCheck
• proto::producer_service_server::ProducerService
• raft_proto::raft_transport_server::RaftTransport
• storage::PersistentStorage

Functions

• jwt::create_token
• jwt::parse_bearer_token
• jwt::validate_token

Type Aliases

• metadata::Result
• storage::TopicStream

Constants

• admin_proto::broker_admin_server::SERVICE_NAME
• admin_proto::cluster_admin_server::SERVICE_NAME
• admin_proto::namespace_admin_server::SERVICE_NAME
• admin_proto::security_admin_server::SERVICE_NAME
• admin_proto::topic_admin_server::SERVICE_NAME
• proto::consumer_service_server::SERVICE_NAME
• proto::danube_schema::schema_registry_server::SERVICE_NAME
• proto::discovery_server::SERVICE_NAME
• proto::edge::edge_replicator_service_server::SERVICE_NAME
• proto::health_check_server::SERVICE_NAME
• proto::producer_service_server::SERVICE_NAME
• raft_proto::raft_transport_server::SERVICE_NAME