Struct RedisLocalSnapshot 

pub struct RedisLocalSnapshot {
    pub redis_addr: SocketAddr,
    pub aof_path: PathBuf,
    pub timeout: Duration,
    pub bgrewrite_retries: u32,
    pub bgrewrite_retry_pause: Duration,
}

Default snapshot source: pulls a Redis snapshot from a local Redis instance.

The reference engine pipes the on-disk AOF file produced by BGREWRITEAOF over the entropy channel. The Rust default follows that contract: it issues a BGREWRITEAOF over the configured Redis TCP endpoint, waits for the command to be acknowledged, then reads the AOF file from disk. Embedders that need a different snapshot strategy plug in their own SnapshotSource through the Stage 13 API.

Examples

use dynomite::entropy::RedisLocalSnapshot;
let source = RedisLocalSnapshot::default();
drop(source);

Fields

redis_addr: SocketAddr

Address of the local Redis instance.

aof_path: PathBuf

Path to the AOF file on disk.

timeout: Duration

Connect/read timeout.

bgrewrite_retries: u32

Number of BGREWRITEAOF retries before giving up. The reference engine retries once after a 10 second sleep; we expose the count and pause as parameters.

bgrewrite_retry_pause: Duration

Pause between BGREWRITEAOF retries.

Implementations

impl RedisLocalSnapshot

pub fn with_redis_addr(self, addr: SocketAddr) -> Self

Override the Redis address.

pub fn with_aof_path(self, path: PathBuf) -> Self

Override the AOF on-disk path.

Trait Implementations

impl Default for RedisLocalSnapshot

fn default() -> Self

Returns the “default value” for a type.

impl SnapshotSource for RedisLocalSnapshot

fn snapshot(&self) -> EntropyResult<Vec<u8>>

Produce one snapshot of the local state as a contiguous byte buffer. The sender treats the bytes as opaque; the receiver replays them through its SnapshotSink.