cadrumo.application.operations package¶
Generic operation-platform namespace.
Subpackages¶
- cadrumo.application.operations.persistence package
- Submodules
- cadrumo.application.operations.persistence._journal_snapshot_validation module
validate_request_storage()validate_secret_state()validate_executor_entry()validate_secret_requirement()validate_deadline_and_cancellation_state()validate_deferred_cancellation()validate_safety_timestamps()validate_execution_deadline()validate_unrequested_cancellation()validate_requested_cancellation()validate_cancellation_acknowledgement()validate_checkpoint_state()validate_idempotency_claim()validate_pending_interaction()validate_consumed_interactions()
- cadrumo.application.operations.persistence.events module
- cadrumo.application.operations.persistence.financial_operand_custody module
- cadrumo.application.operations.persistence.idempotency module
- cadrumo.application.operations.persistence.journal module
OperationPersistedSnapshotOperationProgressFoldCheckpointOperationProgressFoldInputOperationObservationMaterializationOperationObservationUnknownOperationErrorOperationObservationCursorAheadErrorOperationJournalOperationEventStreamOperationObservationReaderOperationLeaseRepositoryOperationSecureReferenceStore
- cadrumo.application.operations.persistence.leases module
- cadrumo.application.operations.persistence.replay module
- cadrumo.application.operations.persistence._journal_snapshot_validation module
- Submodules
Submodules¶
- cadrumo.application.operations._execution_context module
- cadrumo.application.operations._model_contract module
- cadrumo.application.operations._projection_authority module
- cadrumo.application.operations._projection_control module
authorize_cancellation()cancellation_request_or_refusal()detach_refusal()execute_cancellation()inspect_response_authority()load_cancellation_snapshot()load_detach_context()load_response_control_context()response_control_contract_is_current()response_control_request_or_refusal()response_for_mutation()response_refusal()
- cadrumo.application.operations._projection_read module
load_refresh_context()load_result_context()load_review_context()lookup_refresh_registration()lookup_result_registration()lookup_review_registration()refresh_request_or_refusal()resolve_refresh_target()resolve_result_projection()resolve_review_projection()result_digest_or_refusal()result_request_or_refusal()review_request_or_refusal()
- cadrumo.application.operations._registry_contracts module
schema_identity_key()public_schema_bindings()declared_public_schema_identities()validate_public_schema_manifest()validate_public_request_binding()validate_public_result_registration()validate_resultless_public_registration()validate_resultful_public_registration()validate_public_review_registration()validate_public_review_declarations()validate_public_review_implementations()validate_public_refresh_registration()validate_public_result_projector_signature()validate_public_registration()validate_public_contract_fixed_point()definition_contract_digest()contract_set_digest()definition_contract_value()definition_contract_identity_value()definition_contract_schema_value()definition_contract_policy_value()build_public_contract()require_positional_callable_signature()
- cadrumo.application.operations._supervisor_execution module
- cadrumo.application.operations._supervisor_host module
- cadrumo.application.operations._supervisor_lease module
- cadrumo.application.operations._supervisor_reconciliation module
- cadrumo.application.operations._supervisor_settlement module
- cadrumo.application.operations.capabilities module
OperationReplayPolicyOperationBaselinePolicyOperationSensitiveInputPolicyOperationRequestStoragePolicyOperationConflictScopeOperationOwnedResourceOperationCapabilitiesOperationCapabilities.durabilityOperationCapabilities.cancellationOperationCapabilities.deadlineOperationCapabilities.replayOperationCapabilities.baselineOperationCapabilities.request_storageOperationCapabilities.sensitive_inputOperationCapabilities.conflict_scopeOperationCapabilities.owned_resourcesOperationCapabilities.permitted_effectsOperationCapabilities.close_policy
- cadrumo.application.operations.composition module
OperationSubmissionOperationSubmissionServiceOperationComposedServicesOperationComposedServices.public_contractsOperationComposedServices.submissionOperationComposedServices.observationOperationComposedServices.reviewOperationComposedServices.resultOperationComposedServices.refreshOperationComposedServices.cancellationOperationComposedServices.detachOperationComposedServices.shutdown()OperationComposedServices.response()
compose_operation_services()
- cadrumo.application.operations.errors module
- cadrumo.application.operations.event_replay module
- cadrumo.application.operations.events module
- cadrumo.application.operations.financial_operand module
OperationFinancialOperandRefusalReasonOperationFinancialOperandRefusalReason.EXPIREDOperationFinancialOperandRefusalReason.CANCELLEDOperationFinancialOperandRefusalReason.OUT_OF_DECLARED_RANGEOperationFinancialOperandRefusalReason.SCALE_NOT_REPRESENTABLEOperationFinancialOperandRefusalReason.UNKNOWN_REQUIREMENTOperationFinancialOperandRefusalReason.ALREADY_SETTLED
OperationTransientFinancialOperandDeclarationOperationTransientFinancialOperandDeclaration.operand_kindOperationTransientFinancialOperandDeclaration.currencyOperationTransientFinancialOperandDeclaration.scaleOperationTransientFinancialOperandDeclaration.minimumOperationTransientFinancialOperandDeclaration.maximumOperationTransientFinancialOperandDeclaration.lifetimeOperationTransientFinancialOperandDeclaration.admits()
OperationTransientFinancialOperandRequirementOperationTransientFinancialOperandAcknowledgementOperationTransientFinancialOperandRefusalOperationTransientFinancialOperandExpiryOperationTransientFinancialOperandReleaseOperationTransientFinancialOperandAccess
- cadrumo.application.operations.financial_operand_custody module
OperationFinancialOperandCustodyStateOperationFinancialOperandCustodyState.AWAITING_SUBMISSIONOperationFinancialOperandCustodyState.BOUNDOperationFinancialOperandCustodyState.DELIVERY_STARTEDOperationFinancialOperandCustodyState.DELIVERY_ACKNOWLEDGEDOperationFinancialOperandCustodyState.RELEASEDOperationFinancialOperandCustodyState.EXPIREDOperationFinancialOperandCustodyState.CANCELLED
OperationFinancialOperandCrashClassificationOperationFinancialOperandCustodyErrorOperationFinancialOperandCustodyCheckpointOperationFinancialOperandCustodyCheckpoint.operand_kindOperationFinancialOperandCustodyCheckpoint.interaction_idOperationFinancialOperandCustodyCheckpoint.sequenceOperationFinancialOperandCustodyCheckpoint.stateOperationFinancialOperandCustodyCheckpoint.recorded_atOperationFinancialOperandCustodyCheckpoint.refusal_reasonOperationFinancialOperandCustodyCheckpoint.crash_classificationOperationFinancialOperandCustodyCheckpoint.is_terminal
open_custody()advance_custody()classify_interrupted_custody()reconcile_on_restart()
- cadrumo.application.operations.financial_operand_submission module
financial_operand_interaction_id()OperationFinancialOperandContextAccessGrantedTransientFinancialOperandAccessBoundTransientFinancialOperandAccessOperationTransientFinancialOperandBrokerOperationTransientFinancialOperandBroker.declare_requirement()OperationTransientFinancialOperandBroker.deliver()OperationTransientFinancialOperandBroker.grant_access()OperationTransientFinancialOperandBroker.read_operand()OperationTransientFinancialOperandBroker.release()OperationTransientFinancialOperandBroker.expire_lapsed()OperationTransientFinancialOperandBroker.settle()OperationTransientFinancialOperandBroker.settle_operation()OperationTransientFinancialOperandBroker.reconcile_owner_restart()OperationTransientFinancialOperandBroker.close()
- cadrumo.application.operations.frontend_contracts module
- cadrumo.application.operations.frontend_projection module
OperationPublicProgressV1OperationNoPendingInteractionV1OperationReviewProjectionReferenceV1OperationReviewProjectionReferenceV1.operation_idOperationReviewProjectionReferenceV1.interaction_idOperationReviewProjectionReferenceV1.revisionOperationReviewProjectionReferenceV1.review_projection_schemaOperationReviewProjectionReferenceV1.definition_contract_digestOperationReviewProjectionReferenceV1.expires_at
OperationReviewAvailableInteractionV1OperationReviewAvailableInteractionV1.dispositionOperationReviewAvailableInteractionV1.operation_idOperationReviewAvailableInteractionV1.interaction_idOperationReviewAvailableInteractionV1.revisionOperationReviewAvailableInteractionV1.presentation_codeOperationReviewAvailableInteractionV1.response_schemaOperationReviewAvailableInteractionV1.expires_atOperationReviewAvailableInteractionV1.review_reference
OperationUnsupportedInteractionV1OperationUnsupportedInteractionV1.dispositionOperationUnsupportedInteractionV1.interaction_kindOperationUnsupportedInteractionV1.interaction_idOperationUnsupportedInteractionV1.revisionOperationUnsupportedInteractionV1.presentation_codeOperationUnsupportedInteractionV1.unsupported_codeOperationUnsupportedInteractionV1.expires_at
OperationPublicProjectionV1OperationPublicProjectionV1.observation_versionOperationPublicProjectionV1.operation_idOperationPublicProjectionV1.definition_idOperationPublicProjectionV1.subject_refOperationPublicProjectionV1.revisionOperationPublicProjectionV1.anchor_cursorOperationPublicProjectionV1.definition_contractOperationPublicProjectionV1.contract_set_digestOperationPublicProjectionV1.lifecycleOperationPublicProjectionV1.terminal_conditionOperationPublicProjectionV1.effectOperationPublicProjectionV1.phase_codeOperationPublicProjectionV1.started_atOperationPublicProjectionV1.updated_atOperationPublicProjectionV1.progressOperationPublicProjectionV1.close_policyOperationPublicProjectionV1.cancellationOperationPublicProjectionV1.cancellable_nowOperationPublicProjectionV1.cancellation_requestedOperationPublicProjectionV1.cancellation_acknowledgedOperationPublicProjectionV1.execution_deadline_atOperationPublicProjectionV1.cleanup_deadline_atOperationPublicProjectionV1.pending_interactionOperationPublicProjectionV1.result_refOperationPublicProjectionV1.refusal_refOperationPublicProjectionV1.failure_error_codeOperationPublicProjectionV1.diagnostic_ref
- cadrumo.application.operations.frontend_requests module
OperationObservationRefusalCodeOperationObservationRefusalCode.UNSUPPORTED_VERSIONOperationObservationRefusalCode.UNKNOWN_OPERATIONOperationObservationRefusalCode.CURSOR_AHEADOperationObservationRefusalCode.INVALID_CURSOROperationObservationRefusalCode.DEFINITION_CONTRACT_MISMATCHOperationObservationRefusalCode.OBSERVATION_UNAVAILABLE
OperationReviewProjectionRefusalCodeOperationReviewProjectionRefusalCode.UNSUPPORTED_VERSIONOperationReviewProjectionRefusalCode.UNKNOWN_OPERATIONOperationReviewProjectionRefusalCode.REVIEW_NOT_PENDINGOperationReviewProjectionRefusalCode.STALE_REVIEW_REFERENCEOperationReviewProjectionRefusalCode.REVIEW_EXPIREDOperationReviewProjectionRefusalCode.DEFINITION_CONTRACT_MISMATCHOperationReviewProjectionRefusalCode.REVIEW_SCHEMA_MISMATCHOperationReviewProjectionRefusalCode.REVIEW_PROJECTION_UNAVAILABLE
OperationResultProjectionRefusalCodeOperationResultProjectionRefusalCode.UNSUPPORTED_VERSIONOperationResultProjectionRefusalCode.UNKNOWN_OPERATIONOperationResultProjectionRefusalCode.OPERATION_NOT_TERMINALOperationResultProjectionRefusalCode.OPERATION_NOT_SUCCESSFULOperationResultProjectionRefusalCode.STALE_OPERATION_REVISIONOperationResultProjectionRefusalCode.DEFINITION_CONTRACT_MISMATCHOperationResultProjectionRefusalCode.RESULT_SCHEMA_MISMATCHOperationResultProjectionRefusalCode.RESULT_PROJECTION_UNAVAILABLE
OperationWorkspaceRefreshTargetRefusalCodeOperationWorkspaceRefreshTargetRefusalCode.UNSUPPORTED_VERSIONOperationWorkspaceRefreshTargetRefusalCode.UNKNOWN_OPERATIONOperationWorkspaceRefreshTargetRefusalCode.OPERATION_NOT_TERMINALOperationWorkspaceRefreshTargetRefusalCode.OPERATION_NOT_SUCCESSFULOperationWorkspaceRefreshTargetRefusalCode.REFRESH_ADAPTER_UNAVAILABLEOperationWorkspaceRefreshTargetRefusalCode.DEFINITION_CONTRACT_MISMATCHOperationWorkspaceRefreshTargetRefusalCode.REFRESH_SCHEMA_MISMATCHOperationWorkspaceRefreshTargetRefusalCode.UNSAFE_REFRESH_TARGET
OperationResponseControlRefusalCodeOperationCancellationRefusalCodeOperationCancellationRefusalCode.UNSUPPORTED_VERSIONOperationCancellationRefusalCode.UNKNOWN_OPERATIONOperationCancellationRefusalCode.STALE_OPERATION_REVISIONOperationCancellationRefusalCode.OPERATION_TERMINALOperationCancellationRefusalCode.CANCELLATION_UNSUPPORTEDOperationCancellationRefusalCode.CANCELLATION_UNAVAILABLE
OperationDetachRefusalCodeOperationObservationVersionHeaderOperationReviewProjectionVersionHeaderOperationResponseControlVersionHeaderOperationCancellationVersionHeaderOperationDetachVersionHeaderOperationWorkspaceRefreshTargetVersionHeaderOperationResultProjectionVersionHeaderOperationObservationRequestV1OperationReviewProjectionRequestV1OperationReviewProjectionSuccessV1OperationReviewProjectionRefusalV1OperationResponseControlRequestV1OperationResponseControlSuccessV1OperationResponseControlSuccessV1.outcomeOperationResponseControlSuccessV1.response_control_versionOperationResponseControlSuccessV1.operation_idOperationResponseControlSuccessV1.interaction_idOperationResponseControlSuccessV1.revisionOperationResponseControlSuccessV1.availableOperationResponseControlSuccessV1.permitted_intents
OperationResponseControlRefusalV1OperationResponseApplyRequestV1OperationResponseRejectRequestV1OperationResponseMutationSuccessV1OperationSubmissionReceiptV1OperationCancellationRequestV1OperationCancellationSuccessV1OperationCancellationRefusalV1OperationDetachRequestV1OperationDetachSuccessV1OperationDetachRefusalV1OperationWorkspaceRefreshTargetRequestV1OperationWorkspaceRefreshTargetSuccessV1OperationWorkspaceRefreshTargetRefusalV1OperationWorkspaceRefreshTargetRefusalV1.outcomeOperationWorkspaceRefreshTargetRefusalV1.refresh_target_versionOperationWorkspaceRefreshTargetRefusalV1.codeOperationWorkspaceRefreshTargetRefusalV1.requested_versionOperationWorkspaceRefreshTargetRefusalV1.supported_versionOperationWorkspaceRefreshTargetRefusalV1.diagnostic_ref
OperationResultProjectionRequestV1OperationResultProjectionSuccessV1OperationResultProjectionRefusalV1OperationPublicPhaseEventV1OperationPublicProgressEventV1OperationPublicLogEventV1OperationPublicEffectEventV1OperationPublicNoticeEventV1OperationPublicReconciliationEventV1OperationPublicDiagnosticEventV1OperationPublicInteractionEventV1OperationPublicTerminalEventV1OperationPublicEventPageV1OperationPublicEventPageV1.observation_versionOperationPublicEventPageV1.operation_idOperationPublicEventPageV1.anchor_cursorOperationPublicEventPageV1.requested_cursorOperationPublicEventPageV1.statusOperationPublicEventPageV1.eventsOperationPublicEventPageV1.next_cursorOperationPublicEventPageV1.restart_cursor
OperationObservationSuccessV1OperationObservationRefusalV1
- cadrumo.application.operations.interactions module
OperationInteractionRequestOperationInteractionRequest.interaction_idOperationInteractionRequest.identityOperationInteractionRequest.revisionOperationInteractionRequest.kindOperationInteractionRequest.presentation_codeOperationInteractionRequest.response_schema_refOperationInteractionRequest.continuation_digestOperationInteractionRequest.expires_at
OperationResponseIntentOperationResponseIntentValueOperationApplyResponseOperationRejectResponseOperationPendingInteractionOperationPendingInteraction.requestOperationPendingInteraction.response_token_digestOperationPendingInteraction.reviewed_proposal_digestOperationPendingInteraction.baseline_digestOperationPendingInteraction.proposed_effect_digestOperationPendingInteraction.consumedOperationPendingInteraction.response_actionOperationPendingInteraction.bind()OperationPendingInteraction.consume()
OperationConsumedInteractionOperationConsumedInteraction.interaction_idOperationConsumedInteraction.intentOperationConsumedInteraction.response_digestOperationConsumedInteraction.consumed_atOperationConsumedInteraction.checkpointOperationConsumedInteraction.continuation_proof_digestOperationConsumedInteraction.consumedOperationConsumedInteraction.reviewed_proposal_digestOperationConsumedInteraction.response_action
- cadrumo.application.operations.models module
OperationReconciliationOutcomeOperationIdentityCredentialFreeOperationRequestOperationRequestOperationTerminalReceiptOperationTerminalReceipt.identityOperationTerminalReceipt.revisionOperationTerminalReceipt.conditionOperationTerminalReceipt.effectOperationTerminalReceipt.settled_atOperationTerminalReceipt.result_refOperationTerminalReceipt.refusal_refOperationTerminalReceipt.failure_error_codeOperationTerminalReceipt.diagnostic_ref
validate_terminal_reference_meaning()OperationSnapshotnew_operation_id()
- cadrumo.application.operations.observation module
- cadrumo.application.operations.owner module
OperationCancellationScopeOperationDeadlineAccessOperationEventEmitterOperationSecureOperandLookupOperationCleanupOwnerOperationInteractionAccessOperationResumeCheckpointOperationExecutorContextOperationExecutorContext.identityOperationExecutorContext.revisionOperationExecutorContext.authority_operationOperationExecutorContext.cancellationOperationExecutorContext.deadlinesOperationExecutorContext.eventsOperationExecutorContext.operandsOperationExecutorContext.ephemeral_secretOperationExecutorContext.financial_operandOperationExecutorContext.cleanupOperationExecutorContext.interactions
OperationExecutorOperationResumableExecutor
- cadrumo.application.operations.projection_services module
OperationControlSupervisorOperationSecureResponseAuthorityOperationResponseAuthorityIssuerBoundOperationSecureResponseAuthorityBoundOperationSecureResponseAuthority.operation_idBoundOperationSecureResponseAuthority.interaction_idBoundOperationSecureResponseAuthority.revisionBoundOperationSecureResponseAuthority.reviewed_proposal_digestBoundOperationSecureResponseAuthority.actor_refBoundOperationSecureResponseAuthority.expires_atBoundOperationSecureResponseAuthority.intentsBoundOperationSecureResponseAuthority.clockBoundOperationSecureResponseAuthority.bind()BoundOperationSecureResponseAuthority.permitted_intents()BoundOperationSecureResponseAuthority.response_token()BoundOperationSecureResponseAuthority.close()
UnavailableOperationSecureResponseAuthorityOperationResponseCapabilityOperationResponseAuthorityBrokerOperationReviewProjectionServiceOperationWorkspaceRefreshTargetServiceOperationResultProjectionServiceOperationResponseControlServiceOperationCancellationServiceOperationDetachServiceUnavailableSnapshotread_snapshot()
- cadrumo.application.operations.registry module
OperationSchemaIdentityV1OperationPublicDefinitionContractV1OperationPublicDefinitionContractV1.manifest_versionOperationPublicDefinitionContractV1.definition_idOperationPublicDefinitionContractV1.action_referenceOperationPublicDefinitionContractV1.request_schemaOperationPublicDefinitionContractV1.result_schemaOperationPublicDefinitionContractV1.review_projection_schemaOperationPublicDefinitionContractV1.interaction_response_schemaOperationPublicDefinitionContractV1.workspace_refresh_target_schemaOperationPublicDefinitionContractV1.interaction_kindsOperationPublicDefinitionContractV1.request_storageOperationPublicDefinitionContractV1.durabilityOperationPublicDefinitionContractV1.cancellationOperationPublicDefinitionContractV1.deadlineOperationPublicDefinitionContractV1.replayOperationPublicDefinitionContractV1.baselineOperationPublicDefinitionContractV1.sensitive_inputOperationPublicDefinitionContractV1.conflict_scopeOperationPublicDefinitionContractV1.owned_resourcesOperationPublicDefinitionContractV1.permitted_effectsOperationPublicDefinitionContractV1.close_policyOperationPublicDefinitionContractV1.reconciliation_policyOperationPublicDefinitionContractV1.permitted_frontendsOperationPublicDefinitionContractV1.ephemeral_secret_requiredOperationPublicDefinitionContractV1.definition_contract_digest
OperationPublicContractSetV1OperationReconciliationPolicyOperationFrontendProjectionOperationExecutorFactoryOperationDefinitionOperationDefinition.definition_idOperationDefinition.request_typeOperationDefinition.result_typeOperationDefinition.executor_factoryOperationDefinition.phase_codesOperationDefinition.interaction_kindsOperationDefinition.capabilitiesOperationDefinition.reconciliation_policyOperationDefinition.permitted_frontendsOperationDefinition.action_referenceOperationDefinition.ephemeral_secretOperationDefinition.transient_financial_operands
OperationEffectReceiptOperationSchemaBindingV1OperationReviewProjectorOperationWorkspaceRefreshAdapterOperationResultProjectorOperationPublicDefinitionRegistrationV1OperationPublicDefinitionRegistrationV1.contractOperationPublicDefinitionRegistrationV1.schema_bindingsOperationPublicDefinitionRegistrationV1.reviewed_operand_typeOperationPublicDefinitionRegistrationV1.review_projectorOperationPublicDefinitionRegistrationV1.workspace_refresh_adapterOperationPublicDefinitionRegistrationV1.result_projectorOperationPublicDefinitionRegistrationV1.compose_request_only()OperationPublicDefinitionRegistrationV1.compose()
OperationRegistryOperationRegistry.definitionsOperationRegistry.public_registrationsOperationRegistry.public_contract_setOperationRegistry.lookup()OperationRegistry.lookup_public_contract()OperationRegistry.lookup_public_registration()OperationRegistry.lookup_public_schema_binding()OperationRegistry.lookup_action()OperationRegistry.resolve_credential_free_payload()
operation_public_schema_reference()
- cadrumo.application.operations.registry_schema_validation module
FORBIDDEN_CREDENTIAL_FREE_FIELD_PARTSis_hex64_shaped_schema()is_hex64_string_schema()is_hex64_any_of_schema()is_hex64_items_schema()validate_credential_free_schema()validate_credential_free_schema_items()validate_credential_free_schema_format()validate_credential_free_schema_properties()strict_model_json_schema()validate_closed_json_schema()reject_secret_capable_schema_branch()validate_schema_definitions()validate_schema_combinator()validate_closed_object_schema()validate_closed_array_schema()validate_closed_tuple_schema()
- cadrumo.application.operations.secret_submission module
- cadrumo.application.operations.supervisor module
- cadrumo.application.operations.supervisor_context module