IActorType

Creates a command subscription to wait for a specific event from a target actor. Sends the command and asynchronously returns the first matching event received. If no matching event arrives within `akka.fcqrs.command-timeout` (default 30s) — e.g. the aggregate decided UnhandledEvent/IgnoreEvent or the filter never matches — the returned Async raises TimeoutException instead of hanging forever. <param name="factory">Entity factory function for the target actor type.</param> <param name="cid">Correlation ID for tracking.</param> <param name="id">Entity ID of the target actor.</param> <param name="command">The command payload to send.</param> <param name="filter">A predicate function to select the desired event.</param> <param name="metadata">Optional metadata to include with the command.</param> <returns>An async computation yielding the target event.</returns>

Initializes a sharded, persistent aggregate actor. <param name="cfg">Environment configuration (IConfiguration & ILoggerFactory).</param> <param name="initialState">The initial state for new aggregate instances.</param> <param name="name">The shard type name for this aggregate.</param> <param name="handleCommand">The command handler function: `Command -> State -> EventAction`.</param> <param name="apply">The event handler function: `Event -> State -> State`.</param> <param name="snapshotPolicy">Snapshot cadence for this aggregate.</param> <param name="passivationPolicy">Idle passivation for this aggregate; `Default` defers to configuration.</param> <returns>An entity factory (`EntityFac<obj>`) for creating instances of this actor.</returns>

Like InitializeActor, plus a runner for the `RunAsync` effect: it maps a boxed effect description to a boxed command (self-dispatched, re-entering decide). None means the aggregate does not use RunAsync (and using it fail-fasts). The runner must be total (map failure to a command).

Initializes a sharded, persistent saga actor. <param name="initialState">The initial state (`SagaState`) for new saga instances.</param> <param name="handleEvent">The event handler function: `Event -> SagaState -> EventAction`.</param> <param name="applySideEffects">Function determining side effects based on state transitions: `SagaState -> Option<StartingEvent> -> bool -> SagaTransition<NewState> * ExecuteCommand list`. CONTRACT: it must be idempotent for the same state — the framework invokes it on every state entry, on recovery re-drives, and (for this raw API) again when the start handshake acknowledges, so issued commands must be retry-safe. The SagaBuilder facade absorbs the extra invocations by returning Stay; raw sagas must do it themselves.</param> <param name="applyStateChange">Function to apply internal state changes: `SagaState -> SagaState`.</param> <param name="name">The shard type name for this saga.</param> <returns>An entity factory (`EntityFac<obj>`) for creating instances of this saga.</returns>

Simplified saga starter where you just return factories. Uses default PrefixConversion (identity) and passes through the original event.

Initializes the Saga Starter actor, configuring which events trigger which sagas. <param name="eventHandler">A function mapping a received event object to a list of saga definitions to start: `obj -> list<(Factory * Prefix * StartingEvent)>`.</param>

Stops the actor system gracefully.

Subscribes to the result of a command sent to another actor.

Gets the logger factory.

Gets the reference to the distributed pub/sub mediator actor.

Gets the hosting ActorSystem.

Gets the configuration.

Gets the time provider.

Gets the Akka Streams materializer.