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