Struct FileStore 

pub struct FileStore { /* private fields */ }

Per-shard append-log remember-entities store.

Each shard is stored as <dir>/<hex(type_name)>/<hex(shard_id)>.log. Starts append one record. Stops/passivation rewrite the shard log with the remaining live entity ids, which compacts tombstones immediately. With FileStoreFsyncPolicy::Always, each append and compaction is fsynced before the store method returns to the write-behind worker; because writes are still write-behind, a delivered message is acknowledged before the store record is necessarily durable.

Implementations

impl FileStore

pub fn new(dir: impl Into<PathBuf>) -> Self

Create a file store rooted at dir.

pub const fn with_fsync_policy(self, policy: FileStoreFsyncPolicy) -> Self

Set the fsync policy.

Trait Implementations

impl Clone for FileStore

fn clone(&self) -> FileStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileStore

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

Formats the value using the given formatter.

impl RememberEntitiesStore for FileStore

fn record_entity_started<'a>( &'a self, type_name: &'a str, shard_id: &'a str, entity_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Record that entity_id has started in type_name/shard_id.

fn record_entity_stopped<'a>( &'a self, type_name: &'a str, shard_id: &'a str, entity_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Record that entity_id has stopped/passivated in type_name/shard_id.

fn list_entities_for_shard<'a>( &'a self, type_name: &'a str, shard_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<Vec<String>>>

Return remembered entity ids for one shard.

fn list_shards<'a>( &'a self, type_name: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<Vec<String>>>

Return shards known to the store for one entity type.

fn flush<'a>( &'a self, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Synchronise outstanding writes so a resolved RememberEntitiesRuntime::flush makes prior starts/stops visible to a reader that opens the store after the flush resolves (e.g., a node restart).