Struct ReplicationReplica 

pub struct ReplicationReplica { /* private fields */ }

Implementations

impl ReplicationReplica

pub fn new(shard_count: usize) -> Self

pub fn with_route_mode( shard_count: usize, route_mode: EmbeddedRouteMode, ) -> Self

pub fn get(&self, key: &[u8]) -> Option<Bytes>

pub fn watermarks(&self) -> &ShardWatermarks

pub fn metrics_snapshot(&self) -> ReplicationMetricsSnapshot

pub fn apply_frame_bytes(&mut self, frame: &[u8]) -> Result<()>

pub fn apply_frame(&mut self, frame: Bytes) -> Result<()>

pub fn apply_frames(&mut self, frames: &[Bytes]) -> Result<()>

pub fn apply_decoded_frame(&mut self, frame: ReplicationFrame) -> Result<()>

pub fn apply_frame_payload( &mut self, frame: ReplicationFramePayload<'_>, ) -> Result<()>

pub fn apply_frame_bytes_payload( &mut self, frame: ReplicationFrameBytesPayload, ) -> Result<()>

pub fn apply_mutation(&mut self, mutation: ReplicationMutation)

pub fn replace_with_snapshot(&mut self, snapshot: ReplicationSnapshot)

pub fn inner(&self) -> &EmbeddedStore

Trait Implementations

impl Debug for ReplicationReplica

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.