Struct mz_persist_client::rpc::GrpcPubSubClient
source · pub struct GrpcPubSubClient;
Expand description
A PersistPubSubClient implementation backed by gRPC.
Returns a PubSubClientConnection backed by channels that submit and receive messages to and from a long-lived bidirectional gRPC stream. The gRPC stream will be transparently reestablished if the connection is lost.
Trait Implementations§
source§impl Debug for GrpcPubSubClient
impl Debug for GrpcPubSubClient
source§impl PersistPubSubClient for GrpcPubSubClient
impl PersistPubSubClient for GrpcPubSubClient
source§fn connect(
config: PersistPubSubClientConfig,
metrics: Arc<Metrics>
) -> PubSubClientConnection
fn connect( config: PersistPubSubClientConfig, metrics: Arc<Metrics> ) -> PubSubClientConnection
Receive handles with which to push and subscribe to diffs.
Auto Trait Implementations§
impl RefUnwindSafe for GrpcPubSubClient
impl Send for GrpcPubSubClient
impl Sync for GrpcPubSubClient
impl Unpin for GrpcPubSubClient
impl UnwindSafe for GrpcPubSubClient
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.