pub struct NoopReplicator;Expand description
A no-op replicator for testing. Accepts all control events and returns Ok. Replicate requests are assigned sequential LSNs and immediately acknowledged.
Note: The replicator does NOT set read/write access status — that is the runtime’s responsibility. The replicator only updates LSN progress values on PartitionState.
Implementations§
Source§impl NoopReplicator
impl NoopReplicator
Sourcepub async fn run(
control_rx: Receiver<ReplicatorControlEvent>,
data_rx: Receiver<ReplicateRequest>,
state: Arc<PartitionState>,
)
pub async fn run( control_rx: Receiver<ReplicatorControlEvent>, data_rx: Receiver<ReplicateRequest>, state: Arc<PartitionState>, )
Run the noop replicator actor. Processes control and data channels until both are closed or an Abort/Close event is received.
Auto Trait Implementations§
impl Freeze for NoopReplicator
impl RefUnwindSafe for NoopReplicator
impl Send for NoopReplicator
impl Sync for NoopReplicator
impl Unpin for NoopReplicator
impl UnsafeUnpin for NoopReplicator
impl UnwindSafe for NoopReplicator
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> 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