Documentation
¶
Overview ¶
Package durabletest checks the execution store's atomicity and lease contract.
Index ¶
- func QueryGuardCloseFixture(f QueryGuardFixture, r durable.QueryRemovalRevalidationReceipt) durable.QueryRemovalGuardCloseRequest
- func QueryGuardCommitFixture(f QueryGuardFixture, r durable.QueryRemovalRevalidationReceipt) durable.QueryRemovalCommitRequest
- func QueryIdentityFixture() durable.BuildQueryIdentity
- func QueryProofFixture(identity durable.QueryRuntimeIdentity, id string) durable.QueryRuntimeVerification
- func QuerySettlementFixture(t *testing.T, f durable.QueryRemovalFence) durable.QueryRemovalSettlement
- func Run(t *testing.T, s durable.Store)
- func RunBuildRetirement(t *testing.T, s durable.Store)
- func RunOutbox(t *testing.T, s AuditStore)
- func RunOutboxConflict(t *testing.T, s AuditStore)
- func RunQueryEmptyRetiredLastBinding(t *testing.T, s durable.Store)
- func RunQueryIntentRollback(t *testing.T, s durable.Store, ...)
- func RunQueryReceiptRecovery(t *testing.T, s durable.Store, ...)
- func RunQueryRemovalGuard(t *testing.T, s durable.Store)
- func RunQueryRemovalGuardExpiry(t *testing.T, s durable.Store)
- func RunQueryRemovalGuardPositiveEffect(t *testing.T, s durable.Store)
- func RunQueryRemovalGuardRaces(t *testing.T, s durable.Store)
- func RunQueryRemovalGuardRowBounds(t *testing.T, s durable.Store)
- func RunQueryRuntimeRetention(t *testing.T, s durable.Store)
- func RunReads(t *testing.T, s ReadBackend, tie func([]durable.Key))
- func RunRetirementCancellationAcknowledgment(t *testing.T, s durable.Store)
- func RunRetirementEnrollment(t *testing.T, s durable.Store)
- func RunRetirementLateChildBlocker(t *testing.T, s durable.Store)
- func RunRetiringContinuationLineage(t *testing.T, s durable.Store)
- func RunRunChainHistoryBoundary(t *testing.T, s durable.Store)
- func RunWorkerDrainIntentRollback(t *testing.T, s durable.Store, ...)
- func RunWorkerDrainReceipt(t *testing.T, s durable.Store)
- func RunWorkflowRetryCapacity(t *testing.T, s durable.Store)
- func RunWorkflowRetryChains(t *testing.T, initial durable.Store, reopen func() durable.Store)
- func RunWorkflowTaskDeferral(t *testing.T, s durable.Store)
- func RunWorkflowTaskDeferralIntentRollback(t *testing.T, s durable.Store, inject func() func())
- type AuditStore
- type QueryGuardFixture
- func NewQueryGuardExpiringFixture(t *testing.T, s durable.Store) QueryGuardFixture
- func NewQueryGuardFixture(t *testing.T, s durable.Store) QueryGuardFixture
- func NewQueryGuardMaximumFixture(t *testing.T, s durable.Store) QueryGuardFixture
- func RunQueryRemovalGuardMaximum(t *testing.T, s durable.Store) QueryGuardFixture
- type ReadBackend
- type RegisteredAuditStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func QueryGuardCloseFixture ¶
func QueryGuardCloseFixture(f QueryGuardFixture, r durable.QueryRemovalRevalidationReceipt) durable.QueryRemovalGuardCloseRequest
QueryGuardCloseFixture supplies affirmative permanent full-set closure.
func QueryGuardCommitFixture ¶
func QueryGuardCommitFixture(f QueryGuardFixture, r durable.QueryRemovalRevalidationReceipt) durable.QueryRemovalCommitRequest
QueryGuardCommitFixture creates synthetic accepted-permission evidence.
func QueryIdentityFixture ¶
func QueryIdentityFixture() durable.BuildQueryIdentity
QueryIdentityFixture is synthetic store conformance data, not artifact proof.
func QueryProofFixture ¶
func QueryProofFixture(identity durable.QueryRuntimeIdentity, id string) durable.QueryRuntimeVerification
func QuerySettlementFixture ¶
func QuerySettlementFixture(t *testing.T, f durable.QueryRemovalFence) durable.QueryRemovalSettlement
QuerySettlementFixture is synthetic store conformance evidence, not a host or provider settlement claim. Native qualification uses its owned controller.
func RunOutbox ¶
func RunOutbox(t *testing.T, s AuditStore)
RunOutbox exercises the public ownership, acceptance and delivery contract.
func RunOutboxConflict ¶
func RunOutboxConflict(t *testing.T, s AuditStore)
RunOutboxConflict checks the persisted conflict fence on each backend.
func RunQueryIntentRollback ¶
func RunQueryIntentRollback(t *testing.T, s durable.Store, snapshot func(*testing.T, durable.NamespaceTarget) any, inject func(*testing.T, string) func())
RunQueryIntentRollback checks complete stored evidence around failed audit writes.
func RunQueryReceiptRecovery ¶
func RunQueryReceiptRecovery(t *testing.T, s durable.Store, replace func(*testing.T, durable.LifecycleReceipt))
RunQueryReceiptRecovery corrupts only dedicated fixture receipt payloads. Replace must retain the immutable lookup columns so both recovery paths run.
func RunQueryRemovalGuard ¶
RunQueryRemovalGuard proves native protection, immutable replay and terminal closure.
func RunQueryRemovalGuardExpiry ¶
RunQueryRemovalGuardExpiry exercises original expiry, first bind and saved replay.
func RunQueryRemovalGuardPositiveEffect ¶
RunQueryRemovalGuardPositiveEffect requires positive retained evidence after process expiry.
func RunQueryRemovalGuardRaces ¶
RunQueryRemovalGuardRaces checks namespace coordination at competing boundaries.
func RunQueryRemovalGuardRowBounds ¶
RunQueryRemovalGuardRowBounds qualifies the other records with joint maximum identities.
func RunReads ¶
func RunReads(t *testing.T, s ReadBackend, tie func([]durable.Key))
RunReads qualifies namespace predicates and immutable keyset order on real stores.
func RunRetirementCancellationAcknowledgment ¶
RunRetirementCancellationAcknowledgment covers future acknowledgments even after the original parent and current child have both closed.
func RunRetirementEnrollment ¶
RunRetirementEnrollment checks exact responses and historical admission accounting.
func RunRunChainHistoryBoundary ¶
RunRunChainHistoryBoundary proves accepted closing batches remain replayable.
func RunWorkerDrainIntentRollback ¶
func RunWorkerDrainIntentRollback(t *testing.T, s durable.Store, snapshot func(*testing.T, durable.NamespaceTarget) any, reject func(*testing.T) func())
RunWorkerDrainIntentRollback checks acceptance and its required intent together.
func RunWorkflowRetryCapacity ¶
RunWorkflowRetryCapacity checks capacity finality for failures and expired children.
func RunWorkflowRetryChains ¶
RunWorkflowRetryChains checks replay and child delivery across worker/store replacement. Reopen must return the same durable data through a fresh client.
Types ¶
type AuditStore ¶
type AuditStore interface {
durable.Store
durable.NamespaceStore
durable.OutboxStore
}
type QueryGuardFixture ¶
type QueryGuardFixture struct {
Request durable.QueryRemovalRevalidationRequest
Begin durable.LifecycleReceipt
Candidate durable.QueryRuntimeBinding
Survivor durable.QueryRuntimeBinding
}
QueryGuardFixture holds synthetic storage evidence, never production attestations.
func NewQueryGuardExpiringFixture ¶
func NewQueryGuardExpiringFixture(t *testing.T, s durable.Store) QueryGuardFixture
NewQueryGuardExpiringFixture gives the original reservation a short real lifetime.
func NewQueryGuardFixture ¶
func NewQueryGuardFixture(t *testing.T, s durable.Store) QueryGuardFixture
NewQueryGuardFixture enrolls real native rows for the guard conformance campaign.
func NewQueryGuardMaximumFixture ¶
func NewQueryGuardMaximumFixture(t *testing.T, s durable.Store) QueryGuardFixture
NewQueryGuardMaximumFixture populates all supported identity and evidence widths.
func RunQueryRemovalGuardMaximum ¶
func RunQueryRemovalGuardMaximum(t *testing.T, s durable.Store) QueryGuardFixture
RunQueryRemovalGuardMaximum persists and recovers the actual joint maximum material.
type ReadBackend ¶
type ReadBackend interface {
durable.Store
durable.ReadStore
durable.NamespaceStore
durable.OutboxStore
}
type RegisteredAuditStore ¶
type RegisteredAuditStore struct{ AuditStore }
RegisteredAuditStore runs existing conformance paths with both destinations required. Database constraint guards prove each accepted event and receipt has an intent, including paths that create children or carry continuation history.
func (RegisteredAuditStore) SignalWithStart ¶
func (s RegisteredAuditStore) SignalWithStart(ctx context.Context, r durable.SignalWithStartRequest) (durable.SignalReceipt, error)
func (RegisteredAuditStore) StartExecution ¶
func (s RegisteredAuditStore) StartExecution(ctx context.Context, r durable.StartRequest) (durable.Receipt, error)
Source Files
¶
- async.go
- build_lifecycle.go
- child_delivery.go
- children.go
- continuation.go
- execution_cancellation.go
- execution_deadline.go
- execution_target.go
- execution_timeout.go
- heartbeat.go
- lifecycle.go
- lifecycle_delivery.go
- outbox.go
- outbox_conflict.go
- query_intent_rollback.go
- query_receipt_recovery.go
- query_removal_revalidation.go
- query_retention.go
- reads.go
- receipt.go
- retirement_ack.go
- run_chain.go
- run_chain_capacity.go
- signals.go
- suite.go
- task_control.go
- task_deferral.go
- timeout.go
- worker_drain.go
- workflow_retry.go
- workflow_retry_runtime.go