net-mesh 0.21.0

High-performance, schema-agnostic, backend-agnostic event bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Memories — a second CortEX model built on the adapter, exercising
//! the pattern on a non-CRUD shape.
//!
//! Where [tasks](super::tasks) are a mutate-by-id CRUD store,
//! memories are a content-addressed log with set-valued tag metadata
//! and a pin toggle. That difference is what the module is for:
//! validating that the adapter pattern accommodates domains beyond
//! per-id status transitions.
//!
//! Structure mirrors the tasks module:
//!
//! - `MemoriesState` — `HashMap<MemoryId, Memory>`.
//! - `MemoriesFold` — decodes `EventMeta` + payload, routes on dispatch.
//! - `MemoriesAdapter` — typed wrapper over `CortexAdapter<MemoriesState>`.
//! - `MemoriesQuery` — fluent query with single-tag / any-tag /
//!   all-tags predicates and a pin filter.
//!
//! All events ride a single RedEX file at `cortex/memories` (see
//! [`MEMORIES_CHANNEL`]). Dispatches use the CortEX-internal range
//! `0x10..=0x14` (stored / retagged / pinned / unpinned / deleted).

mod adapter;
mod dispatch;
mod filter;
mod fold;
mod query;
mod state;
mod types;
mod watch;

pub use adapter::MemoriesAdapter;
pub use dispatch::{
    DISPATCH_MEMORY_DELETED, DISPATCH_MEMORY_PINNED, DISPATCH_MEMORY_RETAGGED,
    DISPATCH_MEMORY_STORED, DISPATCH_MEMORY_UNPINNED, MEMORIES_CHANNEL,
};
pub use filter::MemoriesFilter;
pub use fold::MemoriesFold;
pub use query::{MemoriesQuery, OrderBy};
pub use state::MemoriesState;
pub use types::{Memory, MemoryId};
pub use watch::MemoriesWatcher;