ActorWiringType

C#-friendly CreateCommandSubscription that returns FSharpAsync (for use with Handler delegate)

InitActor with explicit per-aggregate snapshot and idle-passivation policies.

InitActor with an explicit per-aggregate snapshot policy.

C#-friendly InitializeActor that accepts Func delegates instead of F# functions

InitActorWithRunner with an explicit idle-passivation policy. RunAsync work is ephemeral, so an aggregate that dispatches long effects is a candidate for a longer idle timeout: passivation drops work still in flight.

InitActor whose decide can return `EventActions.Dispatch(...)` (the RunAsync effect). `runner` maps a boxed effect description to a Task of the boxed command self-dispatched back to the aggregate. It MUST be total catch every failure into a command (try/catch in the Task); an escaping exception fail-fasts the process, like a throwing fold. The in-flight work is NOT journaled (ephemeral). See EventAction.RunAsync.

InitAggregate with explicit per-aggregate snapshot and idle-passivation policies.

InitAggregate with an explicit per-aggregate snapshot policy.

One-call aggregate wiring: registers the aggregate (sharding region) and returns its Factory + Handler. Collapses the Init/Factory/Handler trio an aggregate would otherwise hand-roll. Call it for EVERY aggregate you want live. Registration is the act of calling this, not a side effect.

InitAggregateWithEffects with an explicit idle-passivation policy.

InitAggregate whose decide can return `EventActions.Dispatch(...)`. See InitActorWithRunner. Returns Factory + Handler like InitAggregate.

C#-friendly InitializeSagaStarter that accepts Func returning IList of SagaDefinition. A null list means "no sagas". Null Factory/StartingEvent members fail with a named error: this handler runs inside the SagaStarter during the saga-start handshake, where a bare NRE used to surface 30s later as a misleading handshake-timeout FailFast.

Static helper for C# where extension may not resolve

C#-friendly simplified InitializeSagaStarter where you just return factories. A null list means "no sagas"; a null factory fails with a named error.

Initialize saga starter with no sagas (for simple scenarios)

Send a command and wait for the event (C# friendly)

Send a conditional command with cancellation of the caller's wait. An already-canceled token prevents starting the request. Once started, cancellation does not undo processing. A mismatch faults with AggregateVersionConflictException independently of the event filter.

Send only when the aggregate's persisted version equals expectedVersion (initially zero). A mismatch faults with AggregateVersionConflictException before the handler or filter runs. The check and handler run in one actor turn. Deferred replies do not advance the version; persisted batches advance it per event. Stash and RunAsync continuations recheck the version. This does not deduplicate commands or wait for a projection. A timeout does not undo a write. A caller-built PublishEvent reply must retain the incoming command's Id and CorrelationId.

Register a deterministic, one-to-one historical event conversion for this actor system. Register every conversion before initializing any aggregate, saga, or projection. Chains follow the envelope's declared payload type; duplicate sources and cycles are rejected. Applies during FCQRS journal recovery and projection reads. Envelope metadata and stored bytes are preserved; live messages and application-owned snapshot state are not converted. Keep historical payload types readable. A converter must not return null. Converters may run concurrently across consumers and must be thread-safe.