thy1016/mooncmd/projection

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/projection does not have a README file

LiveProjection

pub(all) struct LiveProjection[AggregateId, E] {
  view : Json
  last_version : Int
  projection : Projection[AggregateId, E]
  event_store : @thy1016/mooncmd/store.EventStore
EventStore[AggregateId, E]
  aggregate_id : AggregateId
}

实时投影（内存视图 + 检查点;拉取刷新形——FR-MC-3 参考实现）。

LiveProjection::checkpoint

source

fn[AggregateId, E] LiveProjection::checkpoint(self : LiveProjection[AggregateId, E]) -> Int

读检查点

LiveProjection::get_view

source

fn[AggregateId, E] LiveProjection::get_view(self : LiveProjection[AggregateId, E]) -> Json

读视图

LiveProjection::new

source

fn[AggregateId, E] LiveProjection::new(aggregate_id : AggregateId, event_store : @thy1016/mooncmd/store.EventStore
EventStore[AggregateId, E], projection : Projection[AggregateId, E], position : SubscriptionPosition) -> LiveProjection[AggregateId, E] raise @thy1016/mooncmd/store.EventStoreError
EventStoreError

构造:按订阅位置装载——拉取起始版本之后的事件,批量折入初始视图, 检查点 = 已折末事件版本（流空 = 起始版本）。

LiveProjection::refresh

source

fn[AggregateId, E] LiveProjection::refresh(self : LiveProjection[AggregateId, E]) -> Unit raise @thy1016/mooncmd/store.EventStoreError
EventStoreError

刷新:拉取检查点之后的事件,折入视图,推进检查点;流空 = no-op。

PersistedProjection

source

pub(all) struct PersistedProjection {
  conn : @moonbit-community/sqlite3.Connection
Connection
  table_name : String
}

SQLite 持久化投影落点（视图 + checkpoint;save 即 ack,load 即恢复—— 与 LiveProjection 组合 = 重启续跑）。

PersistedProjection::load

source

fn PersistedProjection::load(self : PersistedProjection, id : String) -> (Json, Int)? raise

PersistedProjection::new

source

fn PersistedProjection::new(conn : @moonbit-community/sqlite3.Connection
Connection, table_name : String) -> PersistedProjection raise

PersistedProjection::save

source

fn PersistedProjection::save(self : PersistedProjection, id : String, view : Json, version : Int) -> Unit raise

Projection

source

pub(all) struct Projection[AggregateId, E] {
  init : () -> Json
  apply : (Json, @thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]) -> Json
  apply_batch : (Json, Array[@thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]]) -> Json
}

投影器（记录型函数面,ADR-MC-003 同族）：init 出初始视图, apply 单事件演化,apply_batch 批量折叠（缺省 = 逐事件 apply）。

Projection::new

source

fn[AggregateId, E] Projection::new(init : () -> Json, apply : (Json, @thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]) -> Json, apply_batch : (Json, Array[@thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]]) -> Json) -> Projection[AggregateId, E]

SubscriptionPosition

source

pub(all) enum SubscriptionPosition {
  Origin
  Current
  FromVersion(Int)
}

订阅位置（刷新起点语义）

default_batch

source

fn[AggregateId, E] default_batch(apply : (Json, @thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]) -> Json) -> ((Json, Array[@thy1016/mooncmd/event.EventMessage
EventMessage[AggregateId, E]]) -> Json)

缺省批量折叠（逐事件 apply——多数投影够用;性能敏感可自定义）。

Source Files

projection.mbt

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