struct PersistTableWriteWorkerInner<T: Timestamp + Lattice + Codec64 + TimestampManipulation> {
tx: UnboundedSender<(Span, PersistTableWriteCmd<T>)>,
}
Expand description
Contains the components necessary for sending commands to a PersistTableWriteWorker
.
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, PersistTableWriteCmd<T>)>
Sending side of a channel that we can use to send commands.
Implementations§
source§impl<T> PersistTableWriteWorkerInner<T>where
T: Timestamp + Lattice + Codec64 + TimestampManipulation,
impl<T> PersistTableWriteWorkerInner<T>where T: Timestamp + Lattice + Codec64 + TimestampManipulation,
fn new(tx: UnboundedSender<(Span, PersistTableWriteCmd<T>)>) -> Self
fn send(&self, cmd: PersistTableWriteCmd<T>)
Trait Implementations§
source§impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation> Debug for PersistTableWriteWorkerInner<T>
impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation> Debug for PersistTableWriteWorkerInner<T>
Auto Trait Implementations§
impl<T> !RefUnwindSafe for PersistTableWriteWorkerInner<T>
impl<T> Send for PersistTableWriteWorkerInner<T>
impl<T> Sync for PersistTableWriteWorkerInner<T>
impl<T> Unpin for PersistTableWriteWorkerInner<T>
impl<T> !UnwindSafe for PersistTableWriteWorkerInner<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
.