mz_
persist_
client
0.139.0-dev.0
In mz_
persist_
client::
rpc
Structs
GrpcPubSubClient
GrpcPubSubSender
MetricsSameProcessPubSubSender
NoopPubSubSender
PersistGrpcPubSubServer
PersistPubSubClientConfig
PubSubClientConnection
PubSubConnection
PubSubState
ShardSubscriptionToken
SubscriptionTrackingSender
Constants
PERSIST_PUBSUB_CALLER_KEY
PUBSUB_CLIENT_ENABLED
PUBSUB_CLIENT_RECEIVER_CHANNEL_SIZE
PUBSUB_CLIENT_SENDER_CHANNEL_SIZE
PUBSUB_CONNECT_ATTEMPT_TIMEOUT
PUBSUB_CONNECT_MAX_BACKOFF
PUBSUB_PUSH_DIFF_ENABLED
PUBSUB_RECONNECT_BACKOFF
PUBSUB_REQUEST_TIMEOUT
PUBSUB_SAME_PROCESS_DELEGATE_ENABLED
PUBSUB_SERVER_CONNECTION_CHANNEL_SIZE
PUBSUB_STATE_CACHE_SHARD_REF_CHANNEL_SIZE
Traits
PersistPubSubClient
PubSubReceiver
PubSubSender
PubSubSenderInternal
Functions
create_request
subscribe_state_cache_to_pubsub
mz_persist_client
::
rpc
Function
create_request
Copy item path
Settings
Help
Summary
Source
fn create_request(message:
Message
) ->
ProtoPubSubMessage