struct GrpcPubSubSender {
metrics: Arc<Metrics>,
requests: Sender<ProtoPubSubMessage>,
}Expand description
An internal, gRPC-backed implementation of PubSubSender.
Fields§
§metrics: Arc<Metrics>§requests: Sender<ProtoPubSubMessage>Implementations§
Source§impl GrpcPubSubSender
impl GrpcPubSubSender
fn send(&self, message: Message, metrics: &PubSubClientCallMetrics)
Trait Implementations§
Source§impl Debug for GrpcPubSubSender
impl Debug for GrpcPubSubSender
Source§impl PubSubSenderInternal for GrpcPubSubSender
impl PubSubSenderInternal for GrpcPubSubSender
Source§fn push_diff(&self, shard_id: &ShardId, diff: &VersionedData)
fn push_diff(&self, shard_id: &ShardId, diff: &VersionedData)
Push a diff to subscribers.
Source§fn subscribe(&self, shard_id: &ShardId)
fn subscribe(&self, shard_id: &ShardId)
Subscribe the corresponding PubSubReceiver to diffs for the given shard. Read more
Source§fn unsubscribe(&self, shard_id: &ShardId)
fn unsubscribe(&self, shard_id: &ShardId)
Unsubscribe the corresponding PubSubReceiver from diffs for the given shard. Read more
Auto Trait Implementations§
impl Freeze for GrpcPubSubSender
impl !RefUnwindSafe for GrpcPubSubSender
impl Send for GrpcPubSubSender
impl Sync for GrpcPubSubSender
impl Unpin for GrpcPubSubSender
impl !UnwindSafe for GrpcPubSubSender
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<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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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::RequestCreates 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.Source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
Source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign, for types that do not implement AddAssign.