Skip to main content

IndexedEventStore

hivemind::storage::event_store

Struct IndexedEventStore 

Source 
pub struct IndexedEventStore { /* private fields */ }
Expand description

Event store that maintains per-project and per-flow append-only logs plus an index.

Reads and streams are currently served from the global events.jsonl file to preserve backwards compatibility and keep read ordering identical to the legacy store.

Implementations§

Source§

impl IndexedEventStore

Source

pub fn open(base_dir: &Path) -> Result<Self>

Opens (or creates) an indexed store rooted at base_dir.

This will create:

  • base_dir/index.json
  • base_dir/projects/<project_id>/events.jsonl
  • base_dir/flows/<flow_id>/events.jsonl
  • base_dir/events.jsonl (global, legacy-compatible)

Trait Implementations§

Source§

impl Debug for IndexedEventStore

Source§

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

Formats the value using the given formatter. Read more
Source§

impl EventStore for IndexedEventStore

Source§

fn append(&self, event: Event) -> Result<EventId>

Appends an event to the store, returning its assigned ID.
Source§

fn read(&self, filter: &EventFilter) -> Result<Vec<Event>>

Reads events matching the filter.
Source§

fn stream(&self, filter: &EventFilter) -> Result<Receiver<Event>>

Streams events matching the filter. Read more
Source§

fn read_all(&self) -> Result<Vec<Event>>

Reads all events in order.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Downcast for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
Source§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
Source§

impl<T> DowncastSync for T
where T: Any + Send + Sync,

Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.