Struct AegMemoryEngine 

pub struct AegMemoryEngine {
    pub store: HashMap<String, String>,
    pub collection_name: String,
}

IN-MEMORY KEY-VALUE STORE ENGINE

Fields

store: HashMap<String, String>

collection_name: String

Implementations

impl AegMemoryEngine

pub fn new(collection_name: &str) -> Self

pub fn insert(&mut self, key: impl Into<String>, value: impl Into<String>)

Insert into current engine and update global in-memory cache (fast).

pub fn get(&self, key: &str) -> Option<String>

pub fn delete(&mut self, key: &str)

pub fn list(&self) -> Vec<(String, String)>

pub fn clear(&mut self)

pub fn save_to_disk(engine: &AegMemoryEngine) -> Result<(), String>

Persist single engine to disk (synchronous) — same encryption as before.

pub fn save_all()

Save ALL collections currently in memory to disk. This function clones the cache under the mutex and performs expensive work outside the lock.

pub fn load() -> Self

Load engine from memory cache; otherwise load from disk; otherwise fresh engine.

pub fn start_background_saver(interval_seconds: u64)

Start a background thread to periodically save memory to disk. If already started, this is a no-op.

pub fn stop_background_saver()

Signal the background saver to stop. Thread is detached so we can’t join; this just signals termination.

Trait Implementations

impl Clone for AegMemoryEngine

fn clone(&self) -> AegMemoryEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AegMemoryEngine

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AegMemoryEngine

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AegMemoryEngine

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.