Struct krill::commons::eventsourcing::DiskKeyStore

pub struct DiskKeyStore { /* fields omitted */ }

This type can store and retrieve values to/from disk, using json serialization.

Implementations

impl DiskKeyStore

pub fn new(work_dir: &PathBuf, name_space: &str) -> Self

pub fn under_work_dir(
    work_dir: &PathBuf,
    name_space: &str
) -> Result<Self, Error>

Creates a directory for the name_space under the work_dir.

pub fn update_aggregate<A: Aggregate>(
    &self,
    id: &Handle,
    aggregate: &mut A
) -> Result<(), KeyStoreError>

Trait Implementations

impl KeyStore for DiskKeyStore

type Key = PathBuf

fn get_version(&self) -> Result<KeyStoreVersion, KeyStoreError>

fn set_version(&self, version: &KeyStoreVersion) -> Result<(), KeyStoreError>

fn key_for_info() -> Self::Key

fn key_for_snapshot() -> Self::Key

fn key_for_event(version: u64) -> Self::Key

fn key_for_command<S: WithStorableDetails>(
    command: &StoredCommand<S>
) -> CommandKey

fn keys(&self, id: &Handle, matching: &str) -> Vec<Self::Key>

Returns all keys for a Handle in the store, matching a &str

fn keys_ascending(&self, id: &Handle, matching: &str) -> Vec<Self::Key>

Returns all keys for a Handle in the store, matching a &str, sorted ascending

fn command_keys_ascending(
    &self,
    id: &Handle,
    crit: &CommandHistoryCriteria
) -> Vec<CommandKey>

fn has_key(&self, id: &Handle, key: &Self::Key) -> bool

Returns whether a key already exists.

fn has_aggregate(&self, id: &Handle) -> bool

fn aggregates(&self) -> Vec<Handle>

fn store<V: Any + Serialize>(
    &self,
    id: &Handle,
    key: &Self::Key,
    value: &V
) -> Result<(), KeyStoreError>

Write or overwrite the value for an existing. Must not throw an error if the key already exists.

fn get<V: Any + Storable>(
    &self,
    id: &Handle,
    key: &Self::Key
) -> Result<Option<V>, KeyStoreError>

Get the value for this key, if any exists.

fn drop(&self, id: &Handle, key: &Self::Key) -> Result<(), KeyStoreError>

Drop the value for this key

fn get_event<V: Event>(
    &self,
    id: &Handle,
    version: u64
) -> Result<Option<V>, KeyStoreError>

Get the value for this key, if any exists.

fn store_event<V: Event>(&self, event: &V) -> Result<(), KeyStoreError>

MUST check if the event already exists and return an error if it does.

fn store_command<S: WithStorableDetails>(
    &self,
    command: StoredCommand<S>
) -> Result<(), KeyStoreError>

fn get_aggregate<V: Aggregate>(
    &self,
    id: &Handle
) -> Result<Option<V>, KeyStoreError>

Get the latest aggregate

fn store_snapshot<V: Aggregate>(
    &self,
    id: &Handle,
    aggregate: &V
) -> Result<(), KeyStoreError>

Saves the latest snapshot - overwrites any previous snapshot.

fn get_info(&self, id: &Handle) -> Result<StoredValueInfo, KeyStoreError>

fn save_info(
    &self,
    id: &Handle,
    info: &StoredValueInfo
) -> Result<(), KeyStoreError>

fn command_history<A: Aggregate>(
    &self,
    id: &Handle,
    crit: CommandHistoryCriteria
) -> Result<CommandHistory, KeyStoreError>

Find all commands that fit the criteria and return history