cadrumo.application.operations._projection_authority module

Runtime-only response authority mechanics for operation projections.

response_authority_binding_matches(authority, request, pending)

Match request and checkpoint coordinates to the bound bearer exactly.

Return type:

bool

Parameters:

• authority (_BoundAuthorityHost)

• request (OperationResponseControlRequestV1)

• pending (OperationPendingInteraction)

class OperationResponseAuthorityBrokerMixin

Bases: _AuthorityHost

Implementation of process-local REVIEW bearer custody.

reserve(operation_id, actor_ref)

Issue an actor-bound opaque handle before operation execution starts.

Return type:

OperationResponseCapability

Parameters:

• operation_id (OperationId)

• actor_ref (OperationActorReference)

issue(pending, response_token)

Retain one mutable bearer only after its digest-bound checkpoint exists.

Return type:

None

Parameters:

• pending (OperationPendingInteraction)

• response_token (OperationResponseToken)

bind(request, pending, capability, *, clock)

Transfer one exact live bearer into an actor-bound response service.

Return type:

Any

Parameters:

• request (OperationResponseControlRequestV1)

• pending (OperationPendingInteraction)

• capability (OperationResponseCapability)

• clock (Callable[[], datetime])

close()

Wipe every unbound bearer during application shutdown.

Return type:

None