cadrumo.application.operations.persistence package

Operation persistence-contract namespace.

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
  • OperationPhaseEvent
    • OperationPhaseEvent.kind
    • OperationPhaseEvent.phase_code
  • OperationProgressEvent
    • OperationProgressEvent.kind
    • OperationProgressEvent.completed
    • OperationProgressEvent.total
    • OperationProgressEvent.unit_code
  • OperationLogRecord
    • OperationLogRecord.kind
    • OperationLogRecord.severity
    • OperationLogRecord.diagnostic_ref
  • OperationEffectEvent
    • OperationEffectEvent.kind
    • OperationEffectEvent.effect
  • OperationNoticeEvent
    • OperationNoticeEvent.kind
    • OperationNoticeEvent.notice_code
  • OperationReconciliationEvent
    • OperationReconciliationEvent.kind
    • OperationReconciliationEvent.outcome
    • OperationReconciliationEvent.lease_evidence_ref
  • OperationDiagnosticEvent
    • OperationDiagnosticEvent.kind
    • OperationDiagnosticEvent.diagnostic_ref
  • OperationInteractionEvent
    • OperationInteractionEvent.kind
    • OperationInteractionEvent.interaction_id
  • OperationTerminalEvent
    • OperationTerminalEvent.kind
    • OperationTerminalEvent.receipt
• cadrumo.application.operations.persistence.financial_operand_custody module
  • OperationFinancialOperandCustodyConflictError
    • OperationFinancialOperandCustodyConflictError.code
  • OperationFinancialOperandCustodyRepository
    • OperationFinancialOperandCustodyRepository.read()
    • OperationFinancialOperandCustodyRepository.open()
    • OperationFinancialOperandCustodyRepository.advance()
    • OperationFinancialOperandCustodyRepository.unsettled()
• cadrumo.application.operations.persistence.idempotency module
  • OperationIdempotencyClaim
    • OperationIdempotencyClaim.definition_id
    • OperationIdempotencyClaim.subject_ref
    • OperationIdempotencyClaim.key_digest
    • OperationIdempotencyClaim.operation_id
    • OperationIdempotencyClaim.request_reference
    • OperationIdempotencyClaim.bind()
• cadrumo.application.operations.persistence.journal module
  • OperationPersistedSnapshot
    • OperationPersistedSnapshot.schema_version
    • OperationPersistedSnapshot.identity
    • OperationPersistedSnapshot.definition_contract_digest
    • OperationPersistedSnapshot.request_storage
    • OperationPersistedSnapshot.request_reference
    • OperationPersistedSnapshot.credential_free_request_json
    • OperationPersistedSnapshot.secret_requirement
    • OperationPersistedSnapshot.executor_entered_at
    • OperationPersistedSnapshot.revision
    • OperationPersistedSnapshot.lifecycle
    • OperationPersistedSnapshot.terminal_condition
    • OperationPersistedSnapshot.effect
    • OperationPersistedSnapshot.phase_code
    • OperationPersistedSnapshot.started_at
    • OperationPersistedSnapshot.updated_at
    • OperationPersistedSnapshot.execution_deadline
    • OperationPersistedSnapshot.cleanup_deadline
    • OperationPersistedSnapshot.cancellation_requested_at
    • OperationPersistedSnapshot.cancellation_acknowledged_at
    • OperationPersistedSnapshot.cancellation_deferred
    • OperationPersistedSnapshot.event_cursor
    • OperationPersistedSnapshot.terminal_receipt
    • OperationPersistedSnapshot.events
    • OperationPersistedSnapshot.idempotency_claim
    • OperationPersistedSnapshot.pending_interaction
    • OperationPersistedSnapshot.consumed_interactions
    • OperationPersistedSnapshot.operation_id
  • OperationProgressFoldCheckpoint
    • OperationProgressFoldCheckpoint.identity
    • OperationProgressFoldCheckpoint.through_cursor
    • OperationProgressFoldCheckpoint.phase_code
    • OperationProgressFoldCheckpoint.progress_event
  • OperationProgressFoldInput
    • OperationProgressFoldInput.checkpoint
    • OperationProgressFoldInput.events
  • OperationObservationMaterialization
    • OperationObservationMaterialization.snapshot
    • OperationObservationMaterialization.anchor_cursor
    • OperationObservationMaterialization.replay
    • OperationObservationMaterialization.progress_fold
  • OperationObservationUnknownOperationError
    • OperationObservationUnknownOperationError.code
  • OperationObservationCursorAheadError
    • OperationObservationCursorAheadError.code
  • OperationJournal
    • OperationJournal.load()
    • OperationJournal.resolve_idempotency()
    • OperationJournal.create()
    • OperationJournal.commit()
  • OperationEventStream
    • OperationEventStream.read_after()
  • OperationObservationReader
    • OperationObservationReader.read_observation()
  • OperationLeaseRepository
    • OperationLeaseRepository.inspect()
    • OperationLeaseRepository.acquire()
    • OperationLeaseRepository.compare_and_swap()
    • OperationLeaseRepository.release()
  • OperationSecureReferenceStore
    • OperationSecureReferenceStore.put()
    • OperationSecureReferenceStore.resolve()
• cadrumo.application.operations.persistence.leases module
  • operation_conflict_scope_reference()
  • OperationLeaseObservationDisposition
    • OperationLeaseObservationDisposition.ABSENT
    • OperationLeaseObservationDisposition.ACTIVE
    • OperationLeaseObservationDisposition.EXPIRED
  • OperationLeaseDisposition
    • OperationLeaseDisposition.ACQUIRED
    • OperationLeaseDisposition.RENEWED
    • OperationLeaseDisposition.RELEASED
    • OperationLeaseDisposition.CONFLICT
    • OperationLeaseDisposition.EXPIRED
    • OperationLeaseDisposition.TAKEN_OVER
    • OperationLeaseDisposition.OWNER_LOST
  • OperationOwnerLease
    • OperationOwnerLease.operation_id
    • OperationOwnerLease.scope_ref
    • OperationOwnerLease.owner_id
    • OperationOwnerLease.token
    • OperationOwnerLease.acquired_at
    • OperationOwnerLease.expires_at
  • OperationLeaseObservation
    • OperationLeaseObservation.schema_version
    • OperationLeaseObservation.scope_ref
    • OperationLeaseObservation.operation_id
    • OperationLeaseObservation.disposition
    • OperationLeaseObservation.observed_at
    • OperationLeaseObservation.current
    • OperationLeaseObservation.evidence_ref
  • OperationLeaseResult
    • OperationLeaseResult.schema_version
    • OperationLeaseResult.scope_ref
    • OperationLeaseResult.operation_id
    • OperationLeaseResult.disposition
    • OperationLeaseResult.observed_at
    • OperationLeaseResult.predecessor
    • OperationLeaseResult.current
    • OperationLeaseResult.evidence_ref
• cadrumo.application.operations.persistence.replay module
  • OperationReplayStatus
    • OperationReplayStatus.PAGE
    • OperationReplayStatus.CAUGHT_UP
    • OperationReplayStatus.EXPIRED
    • OperationReplayStatus.COMPACTED
    • OperationReplayStatus.UNKNOWN_OPERATION
  • RESYNCHRONIZING_REPLAY_STATUSES
  • OperationReplayPage
    • OperationReplayPage.status
    • OperationReplayPage.requested_cursor
    • OperationReplayPage.events
    • OperationReplayPage.next_cursor
    • OperationReplayPage.restart_cursor