thy1016/mooncmd/command

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

CommandHandler

type CommandHandler[S, C, E] = (S, C) -> Result[Array[E], CommandError]

命令处理程序类型

Command

source

pub trait Command {
  fn type_name() -> String
}

命令：用户意图，可失败

CommandError

source

pub(all) suberror CommandError {
  InvalidCommand(String)
  UnregisteredCommand(String)
  Unauthorized(String)
  PreconditionFailed(String)
  NotFound(String)
  Conflict(Int, Int)
}

CommandError::to_string

source

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

显式晋升 Show::to_string（[0079] 隐式晋升已弃会；examples 插值面需要——FR-MC-6 错误面 Show 稳定）

CommandMessage

source

pub struct CommandMessage[C] {
  command : C
  command_id : String
  correlation_id : String
  causation_id : String
  user_id : String?
  timestamp : Int64
  metadata : Json
}

带元数据的命令

CommandMessage::new

source

fn[C] CommandMessage::new(command : C) -> CommandMessage[C]

CommandMessage::with_correlation

source

fn[C] CommandMessage::with_correlation(self : CommandMessage[C], correlation_id : String) -> CommandMessage[C]

CommandMessage::with_user

source

fn[C] CommandMessage::with_user(self : CommandMessage[C], user_id : String) -> CommandMessage[C]

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