storetest

Documentation

Index

• func AttachAttemptContract(t *testing.T, harness AttachAttemptHarness)
• func AttachmentContract(t *testing.T, harness AttachmentHarness)
• func AttentionSummaryContract(t *testing.T)
• func ConnectionContract(t *testing.T, harness ConnectionHarness)
• func Contract(t *testing.T, newStore Harness)
• func FileReferenceCommandContract(t *testing.T, ledger store.FileReferenceCommandStore, ...)
• func HistoryContract(t *testing.T, harness HistoryHarness)
• func PendingCommandContract(t *testing.T, harness PendingCommandHarness)
• func ProposalContract(t *testing.T, harness ProposalHarness)
• func RunControlContract(t *testing.T, ledger store.RunControlStore, harness SettingsCommandHarness)
• func SettingsCommandContract(t *testing.T, harness SettingsCommandHarness)
• func WarmAttachContract(t *testing.T, harness WarmAttachHarness)
• func WorkspaceLeaseContract(t *testing.T, harness WorkspaceLeaseHarness)
• type AttachAttemptHarness
• type AttachmentHarness
• type CommandAuthorityFailure
• type ConnectionHarness
• type Harness
• type HistoryHarness
• type PendingCommandHarness
• type ProposalHarness
• type SettingsCommandHarness
• type WarmAttachFailure
• type WarmAttachHarness
• type WorkspaceLeaseAuthorityFailure
• type WorkspaceLeaseHarness

Functions

func AttachAttemptContract

func AttachAttemptContract(t *testing.T, harness AttachAttemptHarness)

func AttachmentContract

func AttachmentContract(t *testing.T, harness AttachmentHarness)

func AttentionSummaryContract

func AttentionSummaryContract(t *testing.T)

AttentionSummaryContract fixes the v2 projection's provider-neutral surface. Backend transaction, rebuild, and delivery behavior is deliberately exercised by T36 and T37 once those stores implement the contract.

func ConnectionContract

func ConnectionContract(t *testing.T, harness ConnectionHarness)

func Contract

func Contract(t *testing.T, newStore Harness)

func FileReferenceCommandContract

func FileReferenceCommandContract(t *testing.T, ledger store.FileReferenceCommandStore, harness SettingsCommandHarness)

func HistoryContract

func HistoryContract(t *testing.T, harness HistoryHarness)

func PendingCommandContract

func PendingCommandContract(t *testing.T, harness PendingCommandHarness)

func ProposalContract

func ProposalContract(t *testing.T, harness ProposalHarness)

func RunControlContract

func RunControlContract(t *testing.T, ledger store.RunControlStore, harness SettingsCommandHarness)

RunControlContract fixes the v2 durable run-control state machine. It uses the existing backend harness solely to reopen the same durable Store; no Settings behavior is asserted here.

func SettingsCommandContract

func SettingsCommandContract(t *testing.T, harness SettingsCommandHarness)

SettingsCommandContract fixes the durable reservation state machine shared by SQLite and PostgreSQL. Callers use only opaque IDs, fingerprints and writer routing metadata; the contract deliberately has no Provider, credential or content fixtures.

func WarmAttachContract

func WarmAttachContract(t *testing.T, harness WarmAttachHarness)

WarmAttachContract proves that admission and the initial reference-only delivery and target credential activation are indivisible Store truth. Post-commit credential delivery remains outside this contract.

func WorkspaceLeaseContract

func WorkspaceLeaseContract(t *testing.T, harness WorkspaceLeaseHarness)

WorkspaceLeaseContract proves that a backend preserves only trusted, non-secret writer ownership. It deliberately models no Provider spawn: a rejected start receipt is the proof that spawning remains impossible.

Types

type AttachAttemptHarness

type AttachAttemptHarness struct {
	Open   func(t *testing.T) store.AttachAttemptStore
	Reopen func(t *testing.T, current store.AttachAttemptStore) store.AttachAttemptStore
}

type AttachmentHarness

type AttachmentHarness struct {
	Open   func(t *testing.T) store.AttachmentStore
	Reopen func(t *testing.T, current store.AttachmentStore) store.AttachmentStore
}

type CommandAuthorityFailure

type CommandAuthorityFailure string

const (
	CommandAuthoritySuperseded CommandAuthorityFailure = "superseded"
	CommandAuthorityRevoked    CommandAuthorityFailure = "revoked"
	CommandAuthorityExpired    CommandAuthorityFailure = "expired"
	CommandAuthorityTerminal   CommandAuthorityFailure = "terminal"
)

type ConnectionHarness

type ConnectionHarness struct {
	Open       func(t *testing.T) store.AdapterConnectionStore
	Invalidate func(t *testing.T, connections store.AdapterConnectionStore, terminal bool)
}

type Harness

type Harness func(t *testing.T) store.EventStore

type HistoryHarness

type HistoryHarness struct {
	Open        func(t *testing.T) store.HistoryStore
	Reopen      func(t *testing.T, current store.HistoryStore) store.HistoryStore
	PruneBefore func(t *testing.T, current store.HistoryStore, sessionID string, beforeSeq int64)
}

type PendingCommandHarness

type PendingCommandHarness struct {
	Open       func(t *testing.T) store.CommandLedgerStore
	Reopen     func(t *testing.T, current store.CommandLedgerStore) store.CommandLedgerStore
	Authority  func(t *testing.T, ledger store.CommandLedgerStore) store.CommandAuthority
	Invalidate func(t *testing.T, ledger store.CommandLedgerStore, kind CommandAuthorityFailure)
}

type ProposalHarness

type ProposalHarness struct {
	Open       func(t *testing.T) store.ProposedEventStore
	Reopen     func(t *testing.T, current store.ProposedEventStore) store.ProposedEventStore
	Authority  func(t *testing.T, proposals store.ProposedEventStore) store.CommandAuthority
	Invalidate func(t *testing.T, proposals store.ProposedEventStore, kind CommandAuthorityFailure)
}

type SettingsCommandHarness

type SettingsCommandHarness struct {
	Open                                func(t *testing.T) store.SettingsCommandStore
	Reopen                              func(t *testing.T, current store.SettingsCommandStore) store.SettingsCommandStore
	ExpireOperationDeadline             func(t *testing.T, ledger store.SettingsCommandStore, sessionID, commandID string)
	ExpireFileReferenceDeliveryDeadline func(t *testing.T, ledger store.SettingsCommandStore, sessionID, commandID string)
	RevokeWriter                        func(t *testing.T, ledger store.SettingsCommandStore, sessionID string)
}

type WarmAttachFailure

type WarmAttachFailure string

const (
	WarmAttachFailureAttempt    WarmAttachFailure = "attempt"
	WarmAttachFailureAttachment WarmAttachFailure = "attachment"
	WarmAttachFailureOutbox     WarmAttachFailure = "outbox"
	WarmAttachFailureSummary    WarmAttachFailure = "summary"
)

type WarmAttachHarness

type WarmAttachHarness struct {
	Open   func(t *testing.T) store.WarmAttachStore
	Fail   func(t *testing.T, warm store.WarmAttachStore, failure WarmAttachFailure)
	Expire func(t *testing.T, warm store.WarmAttachStore)
	Absent func(t *testing.T, warm store.WarmAttachStore, request store.WarmAttachRequest)
}

type WorkspaceLeaseAuthorityFailure

type WorkspaceLeaseAuthorityFailure string

const (
	WorkspaceLeaseAuthoritySuperseded WorkspaceLeaseAuthorityFailure = "superseded"
	WorkspaceLeaseAuthorityRevoked    WorkspaceLeaseAuthorityFailure = "revoked"
	WorkspaceLeaseAuthorityExpired    WorkspaceLeaseAuthorityFailure = "expired"
	WorkspaceLeaseAuthorityTerminal   WorkspaceLeaseAuthorityFailure = "terminal"
	WorkspaceLeaseAttachmentExpired   WorkspaceLeaseAuthorityFailure = "attachment_expired"
	WorkspaceLeaseAttachmentCanceled  WorkspaceLeaseAuthorityFailure = "attachment_canceled"
)

type WorkspaceLeaseHarness

type WorkspaceLeaseHarness struct {
	Open       func(t *testing.T) store.WorkspaceLeaseStore
	Reopen     func(t *testing.T, current store.WorkspaceLeaseStore) store.WorkspaceLeaseStore
	Invalidate func(t *testing.T, leases store.WorkspaceLeaseStore, key store.WorkspaceLeaseKey, owner store.WorkspaceLeaseOwner, kind WorkspaceLeaseAuthorityFailure)
}