thy1016/mooncmd/store - mooncakes.io

README
Tr
Logger
E
EventSourcingErr
- ::newCommandConfig::new
- ::with_consistencyCommandConfig::with_consistency
- ::with_retriesCommandConfig::with_retries
- ::with_timeoutCommandConfig::with_timeout
T
Consistency
- ::infoConsoleLogger::info
- ::infoMuteLogger::info
- ::newRouteEnv::new
- ::dispatchRouter::dispatch
- ::dispatch_batchRouter::dispatch_batch
- ::dispatch_defaultRouter::dispatch_default
- ::dispatch_nowRouter::dispatch_now
- ::dispatch_with_configRouter::dispatch_with_config
- ::newRouter::new
- ::add_handlerRouterBuilder::add_handler
- ::add_handlersRouterBuilder::add_handlers
- ::buildRouterBuilder::build
- ::handler_countRouterBuilder::handler_count
- ::newRouterBuilder::new
- ::with_consistencyRouterBuilder::with_consistency
- ::with_default_retriesRouterBuilder::with_default_retries
- ::with_default_timeoutRouterBuilder::with_default_timeout
V
dispatch
V
dispatch_ask
V
dispatch_asks
V
dispatch_reader_bind
V
dispatch_reader_map
V
dispatch_reader_new
V
dispatch_reader_run
V
effect_kind_of_sourcing_err
V
log_warn
V
make_console_logger
V
make_mute_logger

thy1016/mooncmd/store does not have a README file

EventStoreError

pub(all) suberror EventStoreError {
  DuplicateVersion(Int)
  StorageError(String)
  SerializationError(String)
}

EventStoreError::to_string

source

fn EventStoreError::to_string(self : EventStoreError) -> String

SnapshotError

source

pub(all) suberror SnapshotError {
  StorageError(String)
  SerializationError(String)
}

EventStore

source

pub(all) struct EventStore[AggregateId, E] {
  append : (EventStore[AggregateId, E], AggregateId, Array[@thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]]) -> Unit raise EventStoreError
  load : (EventStore[AggregateId, E], AggregateId, Int) -> Array[@thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]] raise EventStoreError
  current_version : (EventStore[AggregateId, E], AggregateId) -> Int raise EventStoreError
}

事件存储抽象

SQLiteEventStore

source

pub struct SQLiteEventStore[E] {
  conn : @moonbit-community/sqlite3.Connection
Connection
  serialize : (E) -> Bytes
  deserialize : (Bytes) -> E raise
  get_type_name : (E) -> String
}

SQLite 实现

SQLiteEventStore::append

source

fn[E] SQLiteEventStore::append(self : SQLiteEventStore[E], aggregate_id : String, events : Array[@thy1016/mooncmd/event.EventMessage
EventMessage[String, E]]) -> Unit raise

SQLiteEventStore::current_version

source

fn[E] SQLiteEventStore::current_version(self : SQLiteEventStore[E], aggregate_id : String) -> Int raise

SQLiteEventStore::init_schema

source

fn[E] SQLiteEventStore::init_schema(self : SQLiteEventStore[E]) -> Unit raise

SQLiteEventStore::load

source

fn[E] SQLiteEventStore::load(self : SQLiteEventStore[E], aggregate_id : String, after_version : Int) -> Array[@thy1016/mooncmd/event.EventMessage
EventMessage[String, E]] raise

SQLiteEventStore::new

source

fn[E] SQLiteEventStore::new(db_path : String, serialize : (E) -> Bytes, deserialize : (Bytes) -> E raise, get_type_name : (E) -> String) -> SQLiteEventStore[E] raise

SQLiteEventStore::to_event_store

source

fn[E] SQLiteEventStore::to_event_store(self : SQLiteEventStore[E]) -> EventStore[String, E]

EventStore 记录面适配器：SQLite 实现接入记录型函数面—— 错误穿透不抹平（EventStoreError 变体原样上浮，DuplicateVersion 可分辨）。聚合 id 域 = String（event_stream.aggregate_id 列 TEXT）。

Snapshot

source

pub struct Snapshot[AggregateId, S] {
  aggregate_id : AggregateId
  state : S
  version : Int
  timestamp : Int64
}

快照

Snapshot::new

source

fn[AggregateId, S] Snapshot::new(aggregate_id : AggregateId, state : S, version : Int) -> Snapshot[AggregateId, S]

SnapshotStore

source

pub(all) struct SnapshotStore[AggregateId, S] {
  save : (AggregateId, S, Int, Int64) -> Unit raise SnapshotError
  load : (AggregateId) -> (S, Int)? raise SnapshotError
}

快照存储 Trait

Source Files

Install

Download zip

Command-side event sourcing kernel for MoonBit: pure command handlers, auto-wrapped EventMessage metadata (correlation/causation), optimistic concurrency with duplicate-version rejection, SQLite event store, projections and snapshots.

event-sourcingcqrsevent-storeaggregatesnapshotsqlite