Documentation
¶
Overview ¶
Package storetest runs the same optimization storage checks against each backend.
Index ¶
- func ActivationRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ActiveTeamRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ControllerAdoption(t *testing.T, factory Factory)
- func ControllerAdoptionArtifactDenial(t *testing.T, factory Factory)
- func ControllerAdoptionRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ControllerComparisonFixture(t *testing.T, factory Factory, ...) (optimization.Experiment, optimization.ValidationAllocation, ...)
- func ControllerDecisionArtifacts(t *testing.T, factory Factory)
- func ControllerDecisionRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ControllerDecisionWorker(t *testing.T, factory Factory)
- func ControllerDecisions(t *testing.T, factory Factory)
- func CreationCommandRecovery(t *testing.T, factory func(*testing.T, func() time.Time) store.Store)
- func DiscoveryInheritance(t *testing.T, factory Factory)
- func DiscoveryInheritanceRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func DiscoveryLearning(t *testing.T, factory Factory)
- func DiscoveryLearningRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func DiscoveryReflection(t *testing.T, factory Factory)
- func DiscoveryReflectionRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func Fixture(t *testing.T, project string) optimization.ExperimentBundle
- func ImprovementRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ImprovementValidationRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ImprovementWorker(t *testing.T, factory Factory)
- func ImprovementWorkerLoop(t *testing.T, factory Factory)
- func ImprovementWorkerRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func IndependentScopes(t *testing.T, s store.Store)
- func LeaseTakeoverAcrossProcesses(t *testing.T, database func(*testing.T) string, factory ProcessFactory)
- func LessonCommandRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func OperatorActivationRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func OperatorCommandRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func OrchestrationFixture(t *testing.T, model llm.Client) (optimization.ExperimentBundle, *engine.Engine, *rootsqlite.Store, ...)
- func ParallelRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func PublicationRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func PublishedLesson(t *testing.T, factory Factory) (store.Store, context.Context, optimization.PublicationRequest)
- func PublishedLessonFixture(t *testing.T, factory Factory) (store.Store, context.Context, optimization.PublicationRequest)
- func RetainControllerBaseline(t *testing.T, factory Factory)
- func RetainRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
- func ReviewedActivationFixture(t *testing.T, factory Factory) (store.Store, context.Context, optimization.ActivationChange)
- func Run(t *testing.T, factory Factory)
- type Factory
- type ProcessFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ActivationRecovery ¶
ActivationRecovery executes a stored activation after reopening its database, then verifies that a disabled generation and its idempotency survive another reopen.
func ActiveTeamRecovery ¶
ActiveTeamRecovery checks reviewed execution after both stores are reopened.
func ControllerAdoption ¶
ControllerAdoption checks explicit review and separation from execution routes.
func ControllerAdoptionArtifactDenial ¶
ControllerAdoptionArtifactDenial requires live child artifacts at the service boundary.
func ControllerAdoptionRecovery ¶
ControllerAdoptionRecovery preserves controller routes and retry keys across reopen.
func ControllerComparisonFixture ¶
func ControllerComparisonFixture(t *testing.T, factory Factory, configure func(*optimization.ExperimentBundle, []optimization.ExperimentBundle), evaluate func(context.Context, optimization.EvaluationRequest) (optimization.Evaluation, error)) (optimization.Experiment, optimization.ValidationAllocation, []optimization.ControllerEvidence)
ControllerComparisonFixture records a paired stream using the supplied frozen plans and evaluator, so adapter tests exercise the same transactional fixtures.
func ControllerDecisionArtifacts ¶
ControllerDecisionArtifacts checks child retention before decision and review.
func ControllerDecisionRecovery ¶
ControllerDecisionRecovery keeps the exact comparison through parent takeover.
func ControllerDecisionWorker ¶
ControllerDecisionWorker verifies comparison isolation and authority at commit preparation.
func ControllerDecisions ¶
ControllerDecisions preserves child execution provenance in parent decisions.
func CreationCommandRecovery ¶
CreationCommandRecovery verifies receipt recovery on a reopened native store.
func DiscoveryInheritance ¶
DiscoveryInheritance checks arm isolation and frozen earlier-task learning.
func DiscoveryInheritanceRecovery ¶
func DiscoveryInheritanceRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
DiscoveryInheritanceRecovery retains the exact earlier-task references across reopen.
func DiscoveryLearning ¶
DiscoveryLearning checks provisional reflection persistence before holdout exposure.
func DiscoveryLearningRecovery ¶
DiscoveryLearningRecovery verifies that reflection acknowledgement survives restart and lease takeover without rewriting content or duplicating its audit.
func DiscoveryReflection ¶
DiscoveryReflection checks metered early reflection and ambiguous-answer recovery.
func DiscoveryReflectionRecovery ¶
DiscoveryReflectionRecovery preserves outcomes and unknown calls across restart.
func Fixture ¶
func Fixture(t *testing.T, project string) optimization.ExperimentBundle
Fixture creates a populated draft bundle for shared backend checks.
func ImprovementRecovery ¶
ImprovementRecovery verifies family accounting after closing and reopening storage.
func ImprovementValidationRecovery ¶
func ImprovementValidationRecovery(t *testing.T, open func(*testing.T, func() time.Time) store.Store)
ImprovementValidationRecovery resumes the exact paired stream after reopening storage.
func ImprovementWorker ¶
ImprovementWorker checks ordered child creation and restartable parent scheduling.
func ImprovementWorkerLoop ¶
ImprovementWorkerLoop exercises both arms through real controller and trial handlers.
func ImprovementWorkerRecovery ¶
ImprovementWorkerRecovery closes storage during discovery and after holdout allocation.
func IndependentScopes ¶
IndependentScopes checks that one store instance allows another scope to commit while a transaction is held. Use it for database backends that support independent writers; SQLite deliberately has a database-wide write lock.
func LeaseTakeoverAcrossProcesses ¶
func LeaseTakeoverAcrossProcesses(t *testing.T, database func(*testing.T) string, factory ProcessFactory)
LeaseTakeoverAcrossProcesses checks fencing through a fresh test process. database runs only in the parent; factory opens the supplied database in either process.
func LessonCommandRecovery ¶
LessonCommandRecovery checks durable operator receipts after closing the store.
func OperatorActivationRecovery ¶
OperatorActivationRecovery retries transport commands after reopening each committed generation. Old receipts cannot overwrite the current route.
func OperatorCommandRecovery ¶
OperatorCommandRecovery proves that a lost command response can be retried after reopening storage without a second transition or audit event.
func OrchestrationFixture ¶
func OrchestrationFixture(t *testing.T, model llm.Client) (optimization.ExperimentBundle, *engine.Engine, *rootsqlite.Store, func() *rootsqlite.Store)
OrchestrationFixture prepares a real parallel team in a disposable runtime store. It is shared test infrastructure, not a qualified isolation provider.
func ParallelRecovery ¶
ParallelRecovery reopens a database after a mixed batch result, takes over its lease, and inspects the remote attempt without repeating either dispatch.
func PublicationRecovery ¶
PublicationRecovery checks persisted claim takeover and acknowledgement after closing and reopening a database. Open must return the same durable database.
func PublishedLesson ¶
func PublishedLesson(t *testing.T, factory Factory) (store.Store, context.Context, optimization.PublicationRequest)
PublishedLesson creates an accepted reflection with durable decision evidence and a pending outbox record. Adapters can reuse the storage conformance fixture.
func PublishedLessonFixture ¶
func PublishedLessonFixture(t *testing.T, factory Factory) (store.Store, context.Context, optimization.PublicationRequest)
PublishedLessonFixture creates local lesson evidence and its pending outbox. It does not contact or qualify a remote knowledge provider.
func RetainControllerBaseline ¶
RetainControllerBaseline reviews the parent without retaining its execution baseline.
func RetainRecovery ¶
RetainRecovery verifies that the review and its retry identity survive reopening.
func ReviewedActivationFixture ¶
func ReviewedActivationFixture(t *testing.T, factory Factory) (store.Store, context.Context, optimization.ActivationChange)
ReviewedActivationFixture saves a complete recommendation for transport tests. Its deterministic evidence is not a live-provider qualification.
Types ¶
Source Files
¶
- activation.go
- activation_operator.go
- activation_recovery.go
- activation_service.go
- active_resume.go
- active_run.go
- active_team.go
- artifact_work.go
- artifacts.go
- candidate_evidence.go
- candidates.go
- concurrency.go
- conformance.go
- controller_adoption.go
- controller_decision_worker.go
- controller_decisions.go
- controller_worker.go
- creation_commands.go
- decisions.go
- discovery_controller.go
- discovery_inheritance.go
- discovery_learning.go
- discovery_reflection.go
- dispatch.go
- engine_compatibility.go
- evaluation_integrity.go
- evaluations.go
- improvement.go
- improvement_creation.go
- improvement_validation.go
- improvement_worker.go
- leases.go
- lesson_commands.go
- lesson_creation.go
- lesson_fixture.go
- lifecycle.go
- operator_commands.go
- operator_reads.go
- orchestration_fixture.go
- orchestration_trial.go
- paired_phase.go
- parallel.go
- phase_evidence.go
- process.go
- publication_delivery.go
- publication_recovery.go
- publication_retry.go
- publications.go
- readers.go
- reconciliation.go
- retain.go
- task.go
- trial_adapter.go
- trial_evidence.go
- trials.go
- usage.go
- validation.go