Struct MemoryProjectionCheckpointStore 

pub struct MemoryProjectionCheckpointStore { /* private fields */ }

In-memory monotonically advancing projection checkpoints.

Implementations

impl MemoryProjectionCheckpointStore

pub fn new() -> Self

Creates an empty checkpoint store.

Trait Implementations

impl Debug for MemoryProjectionCheckpointStore

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

Formats the value using the given formatter.

impl Default for MemoryProjectionCheckpointStore

fn default() -> MemoryProjectionCheckpointStore

Returns the “default value” for a type.

impl ProjectionCheckpointStore for MemoryProjectionCheckpointStore

fn load<'a>( &'a self, projection: &'a ProjectionId, ) -> BoxFuture<'a, SoapResult<Option<GlobalPosition>>>

Loads the last completed position, or None for a new projection.

fn store<'a>( &'a self, projection: &'a ProjectionId, position: GlobalPosition, ) -> BoxFuture<'a, SoapResult<()>>

Stores a monotonically advancing completed position.