Versions in this module Expand all Collapse all v1 v1.8.1 Oct 20, 2026 v1.8.0 Oct 18, 2026 Changes in this version + func ActivateWriterFloor(ctx context.Context, backend WriterFloorAdminBackend, authority string, ...) (managed.WriterFloor, error) + func CheckWriterFloorMutation(ctx context.Context, snapshot WriterFloorSnapshot, authority string) error + func Clone(t *managed.Target) (*managed.Target, error) + func EqualIdentity(a, b managed.Identity) bool + func EqualProjectedInstance(a, b *instance.Instance) bool + func EqualProjectedOwner(a, b *workload.Workload) bool + func EqualProjectedRelease(a, b *deploy.Release) bool + func HeldRecordLimit(kind string) int + func ImmutableRecordLimit(kind string) int + func PhysicalKey(p managed.Physical) string + func ProjectionEntities(target managed.Identity, receipt managed.ActionReceipt, ...) (*instance.Instance, *workload.Workload, *deploy.Release, error) + func ProjectionOwnerOrigin(ctx context.Context, tx ControllerTransaction, target managed.Identity) (managed.Identity, error) + func ReserveProjectionOwner(ctx context.Context, tx ControllerTransaction, target managed.Identity, ...) error + func RunHeldQuiescenceObservationBatch(ctx context.Context, tx ControllerTransaction, ...) (managed.QuiescenceBatchReceipt, error) + func ValidateHeldRecordKeys(keys []ControllerRecordKey) error + func ValidateImmutableReceiptKeys(k managed.Key, operations []id.ID) error + func ValidateImmutableRecordKeys(keys []ControllerRecordKey) error + type Backend interface + Atomic func(ctx context.Context, key managed.Key, operation id.ID, digest string, ...) (managed.Receipt, error) + Create func(ctx context.Context, target *managed.Target) (*managed.Target, error) + List func(ctx context.Context, request managed.PageRequest, after string) ([]managed.Summary, error) + Obligations func(ctx context.Context, tenant string) (bool, error) + Read func(ctx context.Context, key managed.Key) (*managed.Target, error) + type ControllerBackend interface + ControllerAtomic func(ctx context.Context, serial string, keys []managed.Key, ...) error + type ControllerReceiptResult struct + Found bool + OperationID id.ID + Receipt managed.Receipt + type ControllerRecord struct + Data []byte + Key string + type ControllerRecordKey struct + Key string + Kind string + Scope string + type ControllerRecordResult struct + Data []byte + Found bool + Size int + type ControllerTransaction interface + ListRecords func(ctx context.Context, kind, scope, after string, limit int) ([]ControllerRecord, error) + Now func() time.Time + ProjectRows func(ctx context.Context, target managed.Identity, receipt managed.ActionReceipt, ...) error + ReadHeldRecords func(ctx context.Context, keys []ControllerRecordKey) ([]ControllerRecordResult, error) + ReadImmutableReceipts func(ctx context.Context, key managed.Key, operations []id.ID) ([]ControllerReceiptResult, error) + ReadImmutableRecords func(ctx context.Context, keys []ControllerRecordKey) ([]ControllerRecordResult, error) + ReadReceipt func(ctx context.Context, key managed.Key, operation id.ID, digest string) (managed.Receipt, error) + ReadRecord func(ctx context.Context, kind, scope, key string) ([]byte, error) + ReserveRows func(ctx context.Context, target managed.Identity, previous *managed.Identity) error + WriteRecord func(ctx context.Context, kind, scope, key string, raw []byte, insert bool) error + type DiscoveryPageTransaction interface + ListDiscoveryWork func(ctx context.Context, scope string, cursor string, limit int) ([]DiscoveryWorkRow, error) + type DiscoveryWorkRow struct + Data []byte + Key string + Size int + type ProviderEffectBindingRepository struct + func (r *ProviderEffectBindingRepository) RetainProviderEffectBinding(ctx context.Context, q managed.ProviderEffectBindingRequest) (managed.ProviderEffectBindingRecord, error) + type QuiescenceBatchCandidate struct + func (c *QuiescenceBatchCandidate) StageTarget(t *managed.Target) (*managed.Target, error) + func (c *QuiescenceBatchCandidate) Take(k managed.Key, batch id.ID, revision uint64) (QuiescenceBatchStage, error) + type QuiescenceBatchChildStage struct + Current []byte + First bool + History []byte + OperationID id.ID + Receipt managed.Receipt + Scope string + type QuiescenceBatchHooks interface + FreshQuiescenceBatchTime func(ctx context.Context) (time.Time, error) + StageQuiescenceBatch func(ctx context.Context, candidate *QuiescenceBatchCandidate) error + type QuiescenceBatchStage struct + Children []QuiescenceBatchChildStage + Manifest []byte + Receipt managed.Receipt + Scope string + type QuiescenceBatchTransaction interface + ApplyQuiescenceObservationBatch func(ctx context.Context, request managed.QuiescenceBatchAcceptanceRequest) (managed.QuiescenceBatchReceipt, error) + type Repository struct + func New(b Backend) *Repository + func (r *Repository) AbortManagedBinding(ctx context.Context, q managed.AbortRequest) (managed.Receipt, error) + func (r *Repository) AcceptManagedOriginalRegistration(ctx context.Context, q managed.OriginalRegistrationAcceptanceRequest) (managed.Receipt, error) + func (r *Repository) AcceptManagedQuiescence(ctx context.Context, q managed.QuiescenceAcceptanceRequest) (managed.Receipt, error) + func (r *Repository) AcceptManagedQuiescenceBatch(ctx context.Context, q managed.QuiescenceBatchAcceptanceRequest) (managed.QuiescenceBatchReceipt, error) + func (r *Repository) AcceptManagedRegistration(ctx context.Context, q managed.AcceptanceRequest) (managed.Receipt, error) + func (r *Repository) AcceptManagedRemovalRevalidation(ctx context.Context, request managed.RemovalRevalidationRequest) (managed.RecoveryRecord[managed.RemovalRevalidationFacts], error) + func (r *Repository) AcknowledgeManagedAudit(ctx context.Context, q managed.AuditAcknowledgment) error + func (r *Repository) ActivateManagedRemovalRecovery(ctx context.Context, request managed.RemovalRecoveryActivationRequest) (managed.RecoveryRecord[managed.RemovalRecoveryActivation], error) + func (r *Repository) AdmitManagedRemoval(ctx context.Context, q managed.AdmissionRequest) (managed.Receipt, error) + func (r *Repository) AdmitManagedRemovalAttempt(ctx context.Context, q managed.AttemptAdmissionRequest) (managed.Receipt, error) + func (r *Repository) AdvanceManagedContinuation(ctx context.Context, q managed.ContinuationAdvance) (managed.Continuation, error) + func (r *Repository) AdvanceManagedOperation(ctx context.Context, q managed.OperationAdvance) (managed.OperationState, error) + func (r *Repository) AllocateManagedReplacement(ctx context.Context, q managed.ReplacementRequest) (managed.Receipt, error) + func (r *Repository) AttachManagedPhaseOriginalResult(ctx context.Context, q managed.PhaseOriginalResultRequest) (managed.PhaseOriginalResult, error) + func (r *Repository) AuthorizeManagedAttemptCommand(ctx context.Context, q managed.AttemptCommandRequest) (managed.AttemptCommandGrant, error) + func (r *Repository) AuthorizeManagedAttemptRecovery(ctx context.Context, q managed.AttemptRecoveryRequest) (managed.AttemptRecoveryGrant, error) + func (r *Repository) AuthorizeManagedProviderStep(ctx context.Context, q managed.ProviderStepAuthorization) (managed.ProviderStepGrant, error) + func (r *Repository) AuthorizeManagedProviderStepRetry(ctx context.Context, request managed.ProviderStepRetryRequest) (managed.RecoveryRecord[managed.ProviderStepRetryAuthorization], error) + func (r *Repository) BeginManagedRemovalAttempt(ctx context.Context, q managed.AttemptStartRequest) (managed.AttemptReceipt, error) + func (r *Repository) BeginManagedRemovalContinuation(ctx context.Context, q managed.ContinuationRequest) (managed.ContinuationReceipt, error) + func (r *Repository) BindManagedRelease(ctx context.Context, q managed.ReleaseBindingRequest) (managed.ReleaseBinding, error) + func (r *Repository) BindManagedResources(ctx context.Context, q managed.ResourcesRequest) (managed.Receipt, error) + func (r *Repository) ClaimManagedLease(ctx context.Context, q managed.LeaseRequest) (managed.Receipt, error) + func (r *Repository) CloseManagedProviderInvocation(ctx context.Context, request managed.ProviderInvocationCloseRequest) (managed.RecoveryRecord[managed.ProviderInvocationClosure], error) + func (r *Repository) CommitManagedProviderInvocation(ctx context.Context, request managed.ProviderInvocationCommitRequest) (managed.ProviderInvocationGrant, error) + func (r *Repository) CreateManagedTarget(ctx context.Context, i managed.Identity) (*managed.Target, error) + func (r *Repository) CutoffManagedRemovalRecovery(ctx context.Context, request managed.RecoveryCommand) (managed.RecoveryRecord[managed.RemovalCutoffFacts], error) + func (r *Repository) FinishManagedBinding(ctx context.Context, q managed.AcceptanceRequest) (managed.Receipt, error) + func (r *Repository) HasManagedObligations(ctx context.Context, tenant string) (bool, error) + func (r *Repository) InspectManagedProtection(ctx context.Context, k managed.Key) (managed.Protection, error) + func (r *Repository) IssueManagedDeletion(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) IssueManagedProvision(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) IssueManagedRegistration(ctx context.Context, q managed.ReservationRequest) (managed.Receipt, error) + func (r *Repository) ListManagedAuditIntents(ctx context.Context, q managed.AuditPageRequest) (managed.AuditPage, error) + func (r *Repository) ListManagedControllerTargets(ctx context.Context, q managed.ControllerPageRequest) (managed.Page, error) + func (r *Repository) ListManagedTargets(ctx context.Context, q managed.PageRequest) (managed.Page, error) + func (r *Repository) ListManagedUnresolvedWork(ctx context.Context, q managed.WorkPageRequest) (managed.WorkPage, error) + func (r *Repository) MaterializeManagedGuardedOriginal(ctx context.Context, request managed.GuardedOriginalMaterializationRequest) (managed.RecoveryAssociation, error) + func (r *Repository) ObserveManagedUnknown(ctx context.Context, q managed.ReservationRequest) (managed.Receipt, error) + func (r *Repository) PrepareManagedGuardedOriginal(ctx context.Context, request managed.GuardedOriginalRequest) (managed.GuardedOriginalPermission, error) + func (r *Repository) ProjectManagedRows(ctx context.Context, q managed.ProjectionRequest) (managed.ProjectionReceipt, error) + func (r *Repository) ReadManagedAttemptBinding(ctx context.Context, k managed.AttemptBindingKey) (managed.AttemptBindingRecord, error) + func (r *Repository) ReadManagedAttemptCommand(ctx context.Context, k managed.AttemptCommandKey) (managed.AttemptCommandRecord, error) + func (r *Repository) ReadManagedAttemptHistoricalSettlement(ctx context.Context, q managed.AttemptSettlementReadRequest) (managed.AttemptHistoricalSettlement, error) + func (r *Repository) ReadManagedContinuation(ctx context.Context, q managed.ControllerKey) (managed.Continuation, error) + func (r *Repository) ReadManagedEffectiveRemovalCoverage(ctx context.Context, key managed.AttemptKey) (managed.RecoveryRecord[managed.EffectiveRemovalCoverage], error) + func (r *Repository) ReadManagedEffectiveRemovalCoverageExact(ctx context.Context, request managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.EffectiveRemovalCoverage], error) + func (r *Repository) ReadManagedHistoricalSettlement(ctx context.Context, q managed.HistoricalSettlementRequest) (managed.HistoricalSettlement, error) + func (r *Repository) ReadManagedOperation(ctx context.Context, q managed.OperationKey) (managed.OperationState, error) + func (r *Repository) ReadManagedOriginalLifecycle(ctx context.Context, k managed.OriginalLifecycleKey) (managed.OriginalLifecycleRecord, error) + func (r *Repository) ReadManagedPhaseCommand(ctx context.Context, ref managed.WorkReference) (managed.PhaseCommandRecord, error) + func (r *Repository) ReadManagedPhaseOriginalResult(ctx context.Context, work managed.WorkReference) (managed.PhaseOriginalResult, error) + func (r *Repository) ReadManagedProviderInvocation(ctx context.Context, key managed.ProviderInvocationKey) (managed.ProviderInvocationRecord, error) + func (r *Repository) ReadManagedProviderInvocationCommits(ctx context.Context, key managed.ProviderInvocationKey) ([]managed.RecoveryRecord[managed.ProviderNativeCommitFacts], error) + func (r *Repository) ReadManagedProviderInvocationCurrent(ctx context.Context, key managed.ProviderInvocationKey) (managed.ProviderStepRetryCurrent, error) + func (r *Repository) ReadManagedProviderInvocationSources(ctx context.Context, key managed.ProviderInvocationKey) (managed.ProviderInvocationSources, error) + func (r *Repository) ReadManagedProviderNativeCommit(ctx context.Context, q managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.ProviderNativeCommitFacts], error) + func (r *Repository) ReadManagedProviderStep(ctx context.Context, q managed.ProviderStepKey) (managed.ProviderStepRecord, error) + func (r *Repository) ReadManagedProviderStepAcceptance(ctx context.Context, q managed.ProviderStepAuthorization) (managed.ProviderStepAcceptance, error) + func (r *Repository) ReadManagedProviderStepFailure(ctx context.Context, q managed.ProviderStepKey) (managed.ProviderStepFailure, error) + func (r *Repository) ReadManagedProviderStepRetry(ctx context.Context, key managed.ProviderInvocationKey) (managed.RecoveryRecord[managed.ProviderStepRetryAuthorization], error) + func (r *Repository) ReadManagedQuiescence(ctx context.Context, k managed.QuiescenceKey) (managed.QuiescenceRecord, error) + func (r *Repository) ReadManagedQuiescenceBatch(ctx context.Context, k managed.QuiescenceBatchKey) (managed.QuiescenceBatchReceipt, error) + func (r *Repository) ReadManagedRecoveryActivation(ctx context.Context, key managed.AttemptKey) (managed.RecoveryRecord[managed.RemovalRecoveryActivation], error) + func (r *Repository) ReadManagedRecoveryNativeIntent(ctx context.Context, q managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.RecoveryNativeIntent], error) + func (r *Repository) ReadManagedRelease(ctx context.Context, q managed.ReleaseKey) (managed.ReleaseBinding, error) + func (r *Repository) ReadManagedRemovalAttempt(ctx context.Context, k managed.AttemptKey) (managed.AttemptRecord, error) + func (r *Repository) ReadManagedRemovalContinuation(ctx context.Context, k managed.ContinuationKey) (managed.ContinuationRecord, error) + func (r *Repository) ReadManagedRemovalCutoffExact(ctx context.Context, request managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.RemovalCutoffFacts], error) + func (r *Repository) ReadManagedRemovalGuardClose(ctx context.Context, request managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.RecoveryNativeCloseFacts], error) + func (r *Repository) ReadManagedRemovalRevalidation(ctx context.Context, request managed.RecoveryExactRequest) (managed.RecoveryRecord[managed.RemovalRevalidationFacts], error) + func (r *Repository) ReadManagedRemovalRevalidationSet(ctx context.Context, key managed.AttemptKey) (managed.RemovalRevalidationSet, error) + func (r *Repository) ReadManagedTarget(ctx context.Context, k managed.Key) (*managed.Target, error) + func (r *Repository) ReadManagedWork(ctx context.Context, ref managed.WorkReference) (managed.WorkReference, error) + func (r *Repository) ReadManagedWorkHead(ctx context.Context, k managed.Key) (managed.WorkHead, error) + func (r *Repository) ReadProviderEffectBinding(ctx context.Context, key managed.ProviderEffectBindingKey) (managed.ProviderEffectBindingRecord, error) + func (r *Repository) RecordManagedAccessAudit(ctx context.Context, q managed.AccessAuditRequest) (managed.AccessAuditReceipt, error) + func (r *Repository) RecordManagedAttemptAbort(ctx context.Context, q managed.AttemptAbortRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedAttemptBindingSettlement(ctx context.Context, q managed.AttemptBindingSettlementRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedAttemptFence(ctx context.Context, q managed.AttemptFenceRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedAttemptFinish(ctx context.Context, q managed.AttemptFinishRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedDrain(ctx context.Context, q managed.DrainRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedFence(ctx context.Context, q managed.FenceRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedOriginalDrain(ctx context.Context, q managed.OriginalDrainAcceptanceRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedProviderInvocationResult(ctx context.Context, request managed.ProviderInvocationObservationRequest) error + func (r *Repository) RecordManagedProviderNativeCommit(ctx context.Context, request managed.ProviderNativeCommitRequest) (managed.RecoveryRecord[managed.ProviderNativeCommitFacts], error) + func (r *Repository) RecordManagedProviderStepFailure(ctx context.Context, q managed.ProviderStepFailure) error + func (r *Repository) RecordManagedProviderStepResult(ctx context.Context, q managed.ProviderStepResult) error + func (r *Repository) RecordManagedRecoveryNativeIntent(ctx context.Context, request managed.RecoveryNativeIntentRequest) (managed.RecoveryRecord[managed.RecoveryNativeIntent], error) + func (r *Repository) RecordManagedRemovalGuardClose(ctx context.Context, request managed.RecoveryNativeCloseRequest) (managed.RecoveryRecord[managed.RecoveryNativeCloseFacts], error) + func (r *Repository) RecordManagedRemovalRecoveryAbort(ctx context.Context, request managed.AttemptAbortRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedRemovalRecoveryBindingSettlement(ctx context.Context, request managed.AttemptBindingSettlementRequest) (managed.Receipt, error) + func (r *Repository) RecordManagedRemovalRecoveryCommand(ctx context.Context, request managed.AttemptCommandRequest) (managed.AttemptCommandGrant, error) + func (r *Repository) RecordManagedRemovalRecoveryFinish(ctx context.Context, request managed.AttemptFinishRequest) (managed.Receipt, error) + func (r *Repository) ReserveManagedRegistration(ctx context.Context, q managed.ReserveRequest) (managed.Receipt, error) + func (r *Repository) RetainManagedPhaseCommand(ctx context.Context, input managed.PhaseCommandRequest) (managed.PhaseCommandGrant, error) + func (r *Repository) RevokeManagedDeletion(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) RevokeManagedRemovalAttempt(ctx context.Context, q managed.AttemptRequest) (managed.Receipt, error) + func (r *Repository) SealManagedEffectiveRemovalCoverage(ctx context.Context, command managed.RecoveryCommand) (managed.RecoveryRecord[managed.EffectiveRemovalCoverage], error) + func (r *Repository) SealManagedTarget(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) SetManagedDesired(ctx context.Context, q managed.DesiredRequest) (managed.Receipt, error) + func (r *Repository) SettleManagedDeletion(ctx context.Context, q managed.SettlementRequest) (managed.Receipt, error) + func (r *Repository) SettleManagedRemovalAttempt(ctx context.Context, q managed.AttemptSettlementRequest) (managed.Receipt, error) + func (r *Repository) SettleManagedRemovalRecovery(ctx context.Context, request managed.AttemptSettlementRequest) (managed.Receipt, error) + func (r *Repository) SubmitManagedAction(ctx context.Context, q managed.ActionSubmission) (managed.ActionReceipt, error) + func (r *Repository) TombstoneManagedRemovalAttempt(ctx context.Context, q managed.AttemptRequest) (managed.Receipt, error) + func (r *Repository) TombstoneManagedRemovalRecovery(ctx context.Context, q managed.AttemptRequest) (managed.Receipt, error) + func (r *Repository) TombstoneManagedTarget(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) TombstoneManagedUnissuedTarget(ctx context.Context, q managed.Command) (managed.Receipt, error) + func (r *Repository) WithProviderEffectBindings(host managed.ProviderEffectBindingHost) (*ProviderEffectBindingRepository, error) + func (r *Repository) WithRemovalRecovery(host managed.RemovalRecoveryHost) (*Repository, error) + type WriterFloorAdminBackend interface + WriterFloorAdminAtomic func(ctx context.Context, fn func(WriterFloorAdminTransaction) error) error + type WriterFloorAdminTransaction interface + AdvanceWriterFloor func(ctx context.Context, expectedDigest string, data []byte) error + InstallInitialWriterFloor func(ctx context.Context, data []byte) error + WriterFloorTime func(ctx context.Context) (time.Time, error) + type WriterFloorReadBackend interface + WriterFloorSnapshot func(ctx context.Context, fn func(WriterFloorSnapshot) error) error + type WriterFloorReader struct + func NewWriterFloorReader(backend WriterFloorReadBackend, authority string) (*WriterFloorReader, error) + func (r *WriterFloorReader) ReadManagedWriterFloor(ctx context.Context) (managed.WriterFloor, error) + func (r *WriterFloorReader) ReadManagedWriterFloorActivation(ctx context.Context, ref managed.WriterFloorReference) (managed.WriterFloor, error) + type WriterFloorSnapshot interface + ReadCurrentWriterFloor func(ctx context.Context) ([]byte, error) + ReadWriterFloorActivation func(ctx context.Context, activationID id.ID) ([]byte, error)
Go to main page