struct PersistMonotonicWriteWorkerInner<T: Timestamp + Lattice + Codec64 + TimestampManipulation> {
tx: UnboundedSender<(Span, PersistMonotonicWriteCmd<T>)>,
}
Expand description
Contains the components necessary for sending commands to a PersistMonotonicWriteWorker
.
When Drop
-ed sends a shutdown command, as such this should never implement Clone
because
if one clone is dropped, the other clones will be unable to send commands. If you need this
to be Clone
-able, wrap it in an Arc
or Rc
first.
#[derive(Clone)] <– do not do this.
Fields§
§tx: UnboundedSender<(Span, PersistMonotonicWriteCmd<T>)>
Sending side of a channel that we can use to send commands.
Implementations§
source§impl<T> PersistMonotonicWriteWorkerInner<T>where
T: Timestamp + Lattice + Codec64 + TimestampManipulation,
impl<T> PersistMonotonicWriteWorkerInner<T>where T: Timestamp + Lattice + Codec64 + TimestampManipulation,
fn new(tx: UnboundedSender<(Span, PersistMonotonicWriteCmd<T>)>) -> Self
fn send(&self, cmd: PersistMonotonicWriteCmd<T>)
Trait Implementations§
source§impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation> Debug for PersistMonotonicWriteWorkerInner<T>
impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation> Debug for PersistMonotonicWriteWorkerInner<T>
Auto Trait Implementations§
impl<T> !RefUnwindSafe for PersistMonotonicWriteWorkerInner<T>
impl<T> Send for PersistMonotonicWriteWorkerInner<T>
impl<T> Sync for PersistMonotonicWriteWorkerInner<T>
impl<T> Unpin for PersistMonotonicWriteWorkerInner<T>
impl<T> !UnwindSafe for PersistMonotonicWriteWorkerInner<T>
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> 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
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
.