Struct RedisAdapter 

pub struct RedisAdapter<C> { /* private fields */ }

Remote over a caller-owned redis crate connection handle.

See the module documentation for the caller’s responsibilities.

Implementations

impl<C: RedisConnection> RedisAdapter<C>

pub fn new(connection: C) -> Self

Borrow connection. The adapter never connects or closes it.

pub fn connection(&self) -> &C

The borrowed connection handle.

pub fn invalidate_decimal<'a>( &'a self, watermark_key: &'a str, future_buffer_ms: &'a str, invalidated_at_ms: &'a str, ) -> BoxFuture<'a, Result<(), BoxError>>

The script’s raw decimal boundary for out-of-band tooling and conformance replay. Validation inside Lua precedes every mutation.

EVALSHA runs first; any failure is retried exactly once as EVAL with identical arguments, and a failed retry surfaces unmodified. The transition is idempotent (the watermark only advances and its retention only widens), so a duplicate run after an ambiguous failure is harmless. A successful reply must be the integer 1.

Trait Implementations

impl<C: Clone> Clone for RedisAdapter<C>

fn clone(&self) -> RedisAdapter<C>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C> Debug for RedisAdapter<C>

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

Formats the value using the given formatter.

impl<C: RedisConnection> Remote for RedisAdapter<C>

fn write(&self, request: WriteRequest) -> BoxFuture<'_, Result<(), BoxError>>

Exactly one native SET of the complete frame. It neither reads nor modifies the entity watermark; the frame’s stamp is stored exactly.

fn invalidate( &self, request: InvalidateRequest, ) -> BoxFuture<'_, Result<(), BoxError>>

The caller’s clock sample stays stable through the EVAL retry, so one logical invalidation proposes one watermark.

fn read( &self, request: ReadRequest, context: ReadContext, ) -> BoxFuture<'_, Result<ReadResult, BoxError>>

Read one value, and for tracked requests its watermark atomically from a primary, then classify the result. An Err counts as a cache_read error and the call falls through to the source.