(Internal) Contains the implementation for command subscriptions.

Contains types and functions for building and initializing sagas

Contains types and functions related to the Saga Starter actor (internal implementation detail).

Akka's internal log verbosity. FCQRS ships with Akka logging OFF (it is chatty); this enables it without hand-editing HOCON/config.

Represents a command to be processed by an aggregate actor. The specific type of the command payload.

Represents an event generated by an aggregate actor as a result of processing a command. The specific type of the event payload.

Defines the possible actions an aggregate or saga actor can take after processing a command or event. The type of the event payload associated with the action (e.g., for PersistEvent).

Represents a command to be executed, often scheduled or triggered by a saga.

Represents the information needed to locate or create a target actor, typically used within sagas.

Defines the core functionalities and context provided by the FCQRS environment to actors. This interface provides access to essential Akka.NET services and FCQRS initialization methods.

Non-generic access to a Command<_>/Event<_> payload, so a boxed message can be unwrapped to its details without knowing the concrete payload type.

Marker interface for types that can be serialized by Akka.NET.

Stable logical names for journal payload types. Register every command/event/ state type that touches the journal; the serializer then writes manifests like "fcqrs:ev(doc.event)" instead of CLR AssemblyQualifiedNames — so types can be renamed or moved freely (update the mapping, old journal rows keep reading). Unregistered types fall back to the legacy AQN manifest.

Decision returned by a filtered projection handler: whether the event it just handled should be published to subscribers as-is. `Publish` notifies (so a read-your-writes awaiter wakes on it); `Suppress` updates the read model silently — e.g. an intermediate event that a later one supersedes. The middle ground between an always-publish handler and one returning an arbitrary notification list.

Default shard name used if no specific sharding strategy is provided. Represents a potential transformation to apply to an entity ID prefix, used in saga routing. Allows sagas to be co-located or routed differently based on the originator's ID structure.

Represents the state of a saga instance. The type of the custom data held by the saga. The type representing the saga's current state machine state (e.g., an enum or DU).

Represents the next state transition for a saga after processing an event or timeout.

Snapshot cadence for an aggregate or saga, set per entity at registration.

Represents the target of a command execution triggered by a saga.

Represents the name identifying a target actor for a command, typically used within sagas.

FCQRS's ActivitySource names — register them with your tracing pipeline (e.g. OpenTelemetry: tracing.AddSource(Telemetry.AllActivitySources)).