List of all items

Structs

• BidiStreamHandle
• BidiStreamReceiver
• BidiStreamSender
• CompactorClient
• ComputeClient
• GrpcCompactorProxyClient
• MetaClient
• RpcClientPool
• StreamClient
• UnboundedBidiStreamHandle
• compactor_client::CompactorClient
• compactor_client::GrpcCompactorProxyClient
• compactor_client::GrpcCompactorProxyClientCore
• compute_client::ComputeClient
• error::TonicStatusWrapper
• frontend_client::FrontendClient
• frontend_client::FrontendRetryClient
• meta_client::GrpcMetaClient
• meta_client::GrpcMetaClientCore
• meta_client::MetaClient
• meta_client::MetaMemberGroup
• meta_client::MetaMemberManagement
• stream_client::StreamClient
• tracing::TracingInjectChannel

Enums

• error::RpcError

Traits

• HummockMetaClient
• RpcClient
• error::ToTonicStatus
• hummock_meta_client::HummockMetaClient
• tracing::TracingInjectedChannelExt

Macros

• error::impl_from_status
• meta_client::for_all_meta_rpc
• meta_rpc_client_method_impl
• retry_rpc
• stream_client::for_all_stream_rpc
• stream_rpc_client_method_impl

Type Aliases

• CompactionEventItem
• ComputeClientPool
• ComputeClientPoolRef
• CoordinatorStreamHandle
• FrontendClientPool
• FrontendClientPoolRef
• SinkCoordinationRpcClient
• SinkCoordinatorStreamHandle
• SinkWriterStreamHandle
• StreamClientPool
• StreamClientPoolRef
• StreamingControlHandle
• compute_client::ComputeClientPool
• compute_client::ComputeClientPoolRef
• connector_client::SinkCoordinatorStreamHandle
• connector_client::SinkWriterRequestSender
• connector_client::SinkWriterResponseReceiver
• connector_client::SinkWriterStreamHandle
• error::Result
• frontend_client::FrontendClientPool
• frontend_client::FrontendClientPoolRef
• hummock_meta_client::CompactionEventItem
• meta_client::ConnectionId
• meta_client::DatabaseId
• meta_client::MetaMemberClient
• meta_client::SchemaId
• meta_client::SinkCoordinationRpcClient
• sink_coordinate_client::CoordinatorStreamHandle
• stream_client::StreamClientPool
• stream_client::StreamClientPoolRef
• stream_client::StreamingControlHandle
• tracing::Channel

Constants

• DEFAULT_BUFFER_SIZE
• compactor_client::DEFAULT_RETRY_INTERVAL
• compactor_client::DEFAULT_RETRY_MAX_ATTEMPTS
• compactor_client::DEFAULT_RETRY_MAX_DELAY
• compactor_client::ENDPOINT_KEEP_ALIVE_INTERVAL_SEC
• compactor_client::ENDPOINT_KEEP_ALIVE_TIMEOUT_SEC
• frontend_client::DEFAULT_RETRY_INTERVAL
• frontend_client::DEFAULT_RETRY_MAX_ATTEMPTS
• frontend_client::DEFAULT_RETRY_MAX_DELAY