evoq_decision behaviour (evoq v1.19.0)

DCB Decision behaviour (Dynamic Consistency Boundary).

A Decision is a write-side construct that sits alongside the aggregate. Where an aggregate locks on its own stream's version, a Decision locks on the absence of new events matching a tag-filter context query. Decisions are for cross-cutting checks that don't fit the per-entity Dossier shape: uniqueness, allocation against shared resources, idempotency keys, rate limits.

Callbacks

Required: context(Command :: map()) -> context_filter() Describe the tag-filter context this decision queries. The runtime reads matching events, then passes them to decide/2.

decide(ContextEvents :: [map()], Command :: map()) -> {ok, [Event :: map()]} | {error, Reason :: term()} Pure decision function. Given the current context and the command, return the events to append OR an error. The runtime appends conditionally via the configured event-store adapter.

Optional: retry_budget() -> non_neg_integer() Maximum retries on context_changed conflicts. Default 3.

v1 limitations

- context_filter() only supports any_of / all_of. Compound and_ / or_ filters are supported by the backend's conditional-append check but the runtime's read path doesn't yet translate them; flat filters only. - The runtime considers only events from the DCB pseudo-stream (the binary "_dcb"). Mixed-mode use cases (aggregate streams + DCB sharing tags) are not supported; use evoq_aggregate if the consistency boundary is per-aggregate, evoq_decision if it's cross-cutting via DCB.

Summary

Types

context_filter/0

Callbacks

context/1

decide/2

retry_budget/0

Types

context_filter/0

-type context_filter() ::
          {any_of, [binary()]} |
          {all_of, [binary()]} |
          {and_, [context_filter()]} |
          {or_, [context_filter()]}.

Callbacks

context/1

-callback context(Command :: map()) -> context_filter().

decide/2

-callback decide(ContextEvents :: [map()], Command :: map()) ->
                    {ok, [Event :: map()]} | {error, Reason :: term()}.

retry_budget/0

(optional)

-callback retry_budget() -> non_neg_integer().