HiveEventStore class final
Hive-backed implementation of EventStore.
Stores events in a Hive box for local persistence. Events survive app restarts and device reboots.
The store uses a composite key structure to efficiently query events by stream ID while maintaining per-stream ordering.
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
appendEventsAsync(
StreamId streamId, ExpectedVersion expectedVersion, List< StoredEvent> events) → Future<void> - Appends events to a stream with optimistic concurrency control.
-
appendEventsToStreamsAsync(
Map< StreamId, StreamAppendBatch> batches) → Future<void> - Appends events to multiple streams atomically.
-
closeAsync(
) → Future< void> - Closes the Hive boxes.
-
loadStreamAsync(
StreamId streamId) → Future< List< StoredEvent> > - Loads all events for a stream, ordered by version.
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited
Static Methods
-
openAsync(
{required String boxName}) → Future< HiveEventStore> - Opens a Hive event store with the given box names.