repository

func (*BunAdminSessionRepo) Create ¶

func (r *BunAdminSessionRepo) Create(ctx context.Context, session *adminsession.Session) error

func (*BunAdminSessionRepo) Delete ¶

func (r *BunAdminSessionRepo) Delete(ctx context.Context, hash string) error

func (*BunAdminSessionRepo) DeleteExpired ¶

func (r *BunAdminSessionRepo) DeleteExpired(ctx context.Context, now time.Time, limit int) (int64, error)

func (*BunAdminSessionRepo) ExtendActive ¶

func (r *BunAdminSessionRepo) ExtendActive(ctx context.Context, hash string, now, expiresAt time.Time) (bool, error)

func (*BunAdminSessionRepo) GetActive ¶

func (r *BunAdminSessionRepo) GetActive(ctx context.Context, hash string, now time.Time) (*adminsession.Session, error)

func (*BunBucketRepo) ActiveReplicaSlots ¶

func (r *BunBucketRepo) ActiveReplicaSlots(ctx context.Context, bucketID int64) ([]int, error)

ActiveReplicaSlots lists the copy indexes still open for new writes.

func (*BunBucketRepo) AggregateCountsByOwner ¶

func (r *BunBucketRepo) AggregateCountsByOwner(ctx context.Context) (map[string]int, error)

func (*BunBucketRepo) CountByOwner ¶

func (r *BunBucketRepo) CountByOwner(ctx context.Context, ownerAccessKey string) (int, error)

func (*BunBucketRepo) CountByStatus ¶

func (r *BunBucketRepo) CountByStatus(ctx context.Context) ([]BucketStatusCount, error)

func (*BunBucketRepo) CountStorageDataSets ¶

func (r *BunBucketRepo) CountStorageDataSets(ctx context.Context) (int, error)

func (*BunBucketRepo) Create ¶

func (r *BunBucketRepo) Create(ctx context.Context, bucket *model.Bucket) error

Create inserts a bucket together with the replica slots its durability policy asks for, so a bucket never exists without the slots its data sets bind to.

func (*BunBucketRepo) GetByID ¶

func (r *BunBucketRepo) GetByID(ctx context.Context, id int64) (*model.Bucket, error)

func (*BunBucketRepo) GetByName ¶

func (r *BunBucketRepo) GetByName(ctx context.Context, name string) (*model.Bucket, error)

func (*BunBucketRepo) GetNamesByIDs ¶

func (r *BunBucketRepo) GetNamesByIDs(ctx context.Context, ids []int64) (map[int64]string, error)

func (*BunBucketRepo) List ¶

func (r *BunBucketRepo) List(ctx context.Context) ([]model.Bucket, error)

func (*BunBucketRepo) ListACLs ¶

func (r *BunBucketRepo) ListACLs(ctx context.Context) ([]BucketACLSnapshot, error)

func (*BunBucketRepo) ListActive ¶

func (r *BunBucketRepo) ListActive(ctx context.Context) ([]model.Bucket, error)

func (*BunBucketRepo) LockByID ¶

func (r *BunBucketRepo) LockByID(ctx context.Context, id int64) error

func (*BunBucketRepo) PromoteReadyIfProvisioned ¶

func (r *BunBucketRepo) PromoteReadyIfProvisioned(ctx context.Context, id int64, requiredDataSets int) (bool, error)

func (*BunBucketRepo) SetACL ¶

func (r *BunBucketRepo) SetACL(ctx context.Context, name string, acl []byte) error

func (*BunBucketRepo) SetDefaultCopies ¶

func (r *BunBucketRepo) SetDefaultCopies(ctx context.Context, name string, copies *int) error

func (*BunBucketRepo) SetOwnerAndACL ¶

func (r *BunBucketRepo) SetOwnerAndACL(ctx context.Context, name string, ownerAccessKey *string, acl []byte) error

func (*BunBucketRepo) UpdateCopyPolicy ¶

func (r *BunBucketRepo) UpdateCopyPolicy(ctx context.Context, input UpdateBucketCopyPolicyInput) (*model.Bucket, error)

func (*BunBucketRepo) UpdateStatus ¶

func (r *BunBucketRepo) UpdateStatus(ctx context.Context, id int64, from, to model.BucketStatus) error

func (*BunCacheEvictionRepo) ActiveEvictionBytes ¶

func (r *BunCacheEvictionRepo) ActiveEvictionBytes(ctx context.Context) (int64, error)

func (*BunCacheEvictionRepo) AuthorizeDeletion ¶

func (r *BunCacheEvictionRepo) AuthorizeDeletion(
	ctx context.Context,
	contentID, generation, taskID int64,
	expectedAccess *time.Time,
) (*cacheeviction.AuthorizedDeletion, error)

func (*BunCacheEvictionRepo) BindDurabilityTask ¶

func (r *BunCacheEvictionRepo) BindDurabilityTask(ctx context.Context, bucketID, generation, taskID int64) error

func (*BunCacheEvictionRepo) BindEvictionTask ¶

func (r *BunCacheEvictionRepo) BindEvictionTask(ctx context.Context, contentID, generation, taskID int64) error

func (*BunCacheEvictionRepo) CompleteBucketDurability ¶

func (r *BunCacheEvictionRepo) CompleteBucketDurability(ctx context.Context, bucketID, generation, taskID int64) error

func (*BunCacheEvictionRepo) DeletionRecorded ¶

func (r *BunCacheEvictionRepo) DeletionRecorded(ctx context.Context, contentID, generation int64) (bool, error)

func (*BunCacheEvictionRepo) GetCacheEntry ¶

func (r *BunCacheEvictionRepo) GetCacheEntry(ctx context.Context, contentID int64) (*model.ObjectCache, error)

func (*BunCacheEvictionRepo) ListBucketDurabilityCandidates ¶

func (r *BunCacheEvictionRepo) ListBucketDurabilityCandidates(ctx context.Context, bucketID, generation, taskID int64, limit int) ([]model.StorageContent, error)

func (*BunCacheEvictionRepo) ListLRUCandidates ¶

func (r *BunCacheEvictionRepo) ListLRUCandidates(ctx context.Context, limit int, after ...CacheLRUCursor) ([]cacheeviction.Candidate, error)

func (*BunCacheEvictionRepo) NextBucketDurabilityCandidate ¶

func (r *BunCacheEvictionRepo) NextBucketDurabilityCandidate(ctx context.Context, bucketID, generation, taskID int64) (*model.StorageContent, error)

func (*BunCacheEvictionRepo) NextDurabilityGeneration ¶

func (r *BunCacheEvictionRepo) NextDurabilityGeneration(ctx context.Context, bucketID int64) (int64, error)

func (*BunCacheEvictionRepo) NextEvictionGeneration ¶

func (r *BunCacheEvictionRepo) NextEvictionGeneration(ctx context.Context, contentID int64) (int64, error)

func (*BunCacheEvictionRepo) PrepareEviction ¶

func (r *BunCacheEvictionRepo) PrepareEviction(ctx context.Context, contentID int64) (CacheEvictionReservation, error)

PrepareEviction locks one cache entry and either reuses its matching live eviction or reserves the next generation for the caller to enqueue and bind before its surrounding transaction commits.

func (*BunCacheEvictionRepo) ReclaimableLRUBytes ¶

func (r *BunCacheEvictionRepo) ReclaimableLRUBytes(ctx context.Context) (int64, error)

func (*BunCacheEvictionRepo) RecordDeletion ¶

func (r *BunCacheEvictionRepo) RecordDeletion(ctx context.Context, contentID, generation, taskID int64) error

func (*BunCacheEvictionRepo) ReleaseBucketDurability ¶ added in v0.1.1

func (r *BunCacheEvictionRepo) ReleaseBucketDurability(ctx context.Context, bucketID, generation, taskID int64) error

func (*BunCacheEvictionRepo) ReleaseEviction ¶

func (r *BunCacheEvictionRepo) ReleaseEviction(ctx context.Context, contentID, generation, taskID int64) error

func (*BunCacheEvictionRepo) TransferDurabilityTaskOwner ¶

func (r *BunCacheEvictionRepo) TransferDurabilityTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunCacheEvictionRepo) TransferEvictionTaskOwner ¶

func (r *BunCacheEvictionRepo) TransferEvictionTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunCacheLocalRepo) DeleteQuarantinedIfSafe ¶ added in v0.1.1

func (r *BunCacheLocalRepo) DeleteQuarantinedIfSafe(ctx context.Context, contentID int64, remove func() error) (bool, error)

DeleteQuarantinedIfSafe holds the durability decision through a single-file deletion. The caller holds the content deletion gate before its transaction.

func (*BunCacheLocalRepo) ListStates ¶ added in v0.1.1

func (r *BunCacheLocalRepo) ListStates(ctx context.Context, contentIDs []int64) (map[int64]CacheLocalState, error)

func (*BunCacheLocalRepo) RestorePresence ¶ added in v0.1.1

func (r *BunCacheLocalRepo) RestorePresence(ctx context.Context, observed CacheLocalState) (bool, error)

func (*BunDeploymentIdentityRepo) BindOrVerify ¶

func (r *BunDeploymentIdentityRepo) BindOrVerify(ctx context.Context, input BindDeploymentIdentityInput) (*model.DeploymentIdentity, error)

func (*BunMultipartRepo) CountActiveByBucket ¶

func (r *BunMultipartRepo) CountActiveByBucket(ctx context.Context, bucketID int64) (int64, error)

func (*BunMultipartRepo) Create ¶

func (r *BunMultipartRepo) Create(ctx context.Context, upload *model.MultipartUpload) error

func (*BunMultipartRepo) CreatePart ¶

func (r *BunMultipartRepo) CreatePart(ctx context.Context, part *model.MultipartPart) error

CreatePart upserts a part record. If the same (upload_id, part_number) exists, its bytes are replaced but created_at keeps the first upload's time: a re-uploaded part is the same part, not a new one.

func (*BunMultipartRepo) Delete ¶

func (r *BunMultipartRepo) Delete(ctx context.Context, uploadID string) error

func (*BunMultipartRepo) DeleteParts ¶

func (r *BunMultipartRepo) DeleteParts(ctx context.Context, uploadID string) error

func (*BunMultipartRepo) DeletePartsExcept ¶

func (r *BunMultipartRepo) DeletePartsExcept(ctx context.Context, uploadID string, keep []int) error

func (*BunMultipartRepo) GetByUploadID ¶

func (r *BunMultipartRepo) GetByUploadID(ctx context.Context, uploadID string) (*model.MultipartUpload, error)

func (*BunMultipartRepo) GetParts ¶

func (r *BunMultipartRepo) GetParts(ctx context.Context, uploadID string, partNumberMarker, maxParts int) ([]model.MultipartPart, error)

func (*BunMultipartRepo) GetPartsByNumbers ¶

func (r *BunMultipartRepo) GetPartsByNumbers(ctx context.Context, uploadID string, numbers []int) ([]model.MultipartPart, error)

func (*BunMultipartRepo) ListByBucket ¶

func (r *BunMultipartRepo) ListByBucket(
	ctx context.Context,
	bucketID int64,
	prefix, keyMarker, uploadIDMarker string,
	maxUploads int,
) ([]model.MultipartUpload, error)

func (*BunMultipartRepo) ReleaseInterruptedCompletions ¶

func (r *BunMultipartRepo) ReleaseInterruptedCompletions(ctx context.Context) (int64, error)

ReleaseInterruptedCompletions returns every completing upload to initiated. A completion commits completed together with the version it creates, so an upload still completing when the process starts belongs to a completion that never finished; its parts are still on disk. bucket_id leads the only index on status, so the filter names it to let that index serve the scan.

func (*BunMultipartRepo) SetStatus ¶

func (r *BunMultipartRepo) SetStatus(ctx context.Context, uploadID string, from, to model.MultipartStatus) error

SetStatus atomically transitions a multipart upload from one status to another (CAS). Returns an error if the upload is not in the expected 'from' status.

func (*BunObjectRepo) AggregateByBucket ¶

func (r *BunObjectRepo) AggregateByBucket(ctx context.Context) (map[int64]BucketObjectStats, error)

AggregateByBucket returns current object count and total size for all buckets in a single query.

func (*BunObjectRepo) BucketStats ¶

func (r *BunObjectRepo) BucketStats(ctx context.Context, bucketID int64) (BucketObjectStats, error)

BucketStats returns current object count and total size for a single bucket.

func (*BunObjectRepo) ClearContentCachePresence ¶

func (r *BunObjectRepo) ClearContentCachePresence(ctx context.Context, contentID int64) error

func (*BunObjectRepo) ContentIsUnreferenced ¶

func (r *BunObjectRepo) ContentIsUnreferenced(ctx context.Context, contentID int64) (bool, error)

ContentIsUnreferenced reports whether any live object version still points at the content, so callers outside a deletion transaction can decide whether releasing its cached bytes is safe.

func (*BunObjectRepo) CountByBucket ¶

func (r *BunObjectRepo) CountByBucket(ctx context.Context, bucketID int64) (int64, error)

CountByBucket returns the number of current objects in a bucket.

func (*BunObjectRepo) CountByState ¶

func (r *BunObjectRepo) CountByState(ctx context.Context) ([]ObjectStateCount, error)

func (*BunObjectRepo) CreateDeleteMarkerAndSetCurrent ¶

func (r *BunObjectRepo) CreateDeleteMarkerAndSetCurrent(ctx context.Context, bucketID int64, key string, versionID string, conditions ...ObjectCondition) (*model.ObjectVersion, error)

func (*BunObjectRepo) CreateRestoredVersionAndSetCurrent ¶

func (r *BunObjectRepo) CreateRestoredVersionAndSetCurrent(ctx context.Context, version *model.ObjectVersion, sourceVersionID, expectedCurrentVersionID string) (int64, error)

func (*BunObjectRepo) CreateVersionAndSetCurrent ¶

func (r *BunObjectRepo) CreateVersionAndSetCurrent(ctx context.Context, version *model.ObjectVersion, conditions ...ObjectCondition) (int64, error)

func (*BunObjectRepo) CreateVersionAndSetCurrentIfChanged ¶

func (r *BunObjectRepo) CreateVersionAndSetCurrentIfChanged(ctx context.Context, version *model.ObjectVersion) (ObjectVersionWriteResult, error)

func (*BunObjectRepo) DeleteDeletedObjectPermanently ¶

func (r *BunObjectRepo) DeleteDeletedObjectPermanently(ctx context.Context, input DeleteDeletedObjectInput) (DeleteDeletedObjectResult, error)

func (*BunObjectRepo) DeleteMarkerVersion ¶

func (r *BunObjectRepo) DeleteMarkerVersion(ctx context.Context, bucketID int64, key string, versionID string, conditions ...ObjectCondition) error

func (*BunObjectRepo) DeleteObjectVersionPermanently ¶

func (r *BunObjectRepo) DeleteObjectVersionPermanently(ctx context.Context, input DeleteObjectVersionInput) (DeleteObjectVersionResult, error)

func (*BunObjectRepo) GetContentFileSample ¶

func (r *BunObjectRepo) GetContentFileSample(ctx context.Context, contentID int64) (*ContentFileSample, error)

func (*BunObjectRepo) GetCurrentVersionByBucketAndKey ¶

func (r *BunObjectRepo) GetCurrentVersionByBucketAndKey(ctx context.Context, bucketID int64, key string) (*model.ObjectVersion, error)

func (*BunObjectRepo) GetCurrentVersionByObjectID ¶

func (r *BunObjectRepo) GetCurrentVersionByObjectID(ctx context.Context, objectID int64) (*model.ObjectVersion, error)

func (*BunObjectRepo) GetObjectByBucketAndKey ¶

func (r *BunObjectRepo) GetObjectByBucketAndKey(ctx context.Context, bucketID int64, key string) (*model.Object, error)

func (*BunObjectRepo) GetObjectByID ¶

func (r *BunObjectRepo) GetObjectByID(ctx context.Context, id int64) (*model.Object, error)

func (*BunObjectRepo) GetVersionByBucketKeyAndID ¶

func (r *BunObjectRepo) GetVersionByBucketKeyAndID(ctx context.Context, bucketID int64, key string, versionID string) (*model.ObjectVersion, error)

func (*BunObjectRepo) GetVersionByID ¶

func (r *BunObjectRepo) GetVersionByID(ctx context.Context, versionID string) (*model.ObjectVersion, error)

func (*BunObjectRepo) ListCurrentVersionsByBucket ¶

func (r *BunObjectRepo) ListCurrentVersionsByBucket(ctx context.Context, bucketID int64, prefix string, afterKey string, maxKeys int) ([]model.ObjectVersion, error)

func (*BunObjectRepo) ListCurrentVersionsByBucketAtOrAfter ¶

func (r *BunObjectRepo) ListCurrentVersionsByBucketAtOrAfter(ctx context.Context, bucketID int64, prefix string, fromKey string, maxKeys int) ([]model.ObjectVersion, error)

func (*BunObjectRepo) ListRecoverableDeleteMarkers ¶

func (r *BunObjectRepo) ListRecoverableDeleteMarkers(ctx context.Context, bucketID int64, prefix string, afterKey string, maxKeys int) ([]RecoverableDeleteMarker, error)

func (*BunObjectRepo) ListVersionsByBucket ¶

func (r *BunObjectRepo) ListVersionsByBucket(ctx context.Context, bucketID int64, prefix string, keyMarker string, versionIDMarker string, maxKeys int) ([]ObjectVersionListItem, error)

func (*BunObjectRepo) ListVersionsByBucketAtOrAfter ¶ added in v0.1.1

func (r *BunObjectRepo) ListVersionsByBucketAtOrAfter(ctx context.Context, bucketID int64, prefix, fromKey string, maxKeys int) ([]ObjectVersionListItem, error)

func (*BunObjectRepo) ListVersionsByKey ¶

func (r *BunObjectRepo) ListVersionsByKey(ctx context.Context, bucketID int64, key string, afterVersionID string, maxKeys int) ([]ObjectVersionListItem, error)

func (*BunObjectRepo) OverviewSnapshot ¶

func (r *BunObjectRepo) OverviewSnapshot(ctx context.Context) (ObjectOverviewSnapshot, error)

func (*BunObjectRepo) RecordContentCacheAccess ¶

func (r *BunObjectRepo) RecordContentCacheAccess(ctx context.Context, contentID int64, accessedAt time.Time) error

RecordContentCacheAccess advances LRU recency for one content payload without asserting that its bytes are present.

func (*BunObjectRepo) RecordContentCacheCommit ¶

func (r *BunObjectRepo) RecordContentCacheCommit(ctx context.Context, contentID int64, accessedAt time.Time) error

RecordContentCacheCommit marks a freshly written cache file present and advances its recency in the same write.

func (*BunObjectRepo) ReleaseContentCacheIfUnreferenced ¶

func (r *BunObjectRepo) ReleaseContentCacheIfUnreferenced(
	ctx context.Context,
	contentID int64,
	release func() error,
) (bool, error)

func (*BunObjectRepo) RestoreCurrentDeleteMarkerStack ¶

func (r *BunObjectRepo) RestoreCurrentDeleteMarkerStack(ctx context.Context, bucketID int64, key string, currentMarkerVersionID string) (*model.ObjectVersion, error)

func (*BunObjectRepo) SetVersionCachePresence ¶

func (r *BunObjectRepo) SetVersionCachePresence(ctx context.Context, versionID string, inCache bool) error

func (*BunObjectRepo) TotalSizeByBucket ¶

func (r *BunObjectRepo) TotalSizeByBucket(ctx context.Context, bucketID int64) (int64, error)

TotalSizeByBucket returns the sum of current object sizes in a bucket.

func (*BunObservabilityRepo) GetDataSetStatesByLocalIDs ¶

func (r *BunObservabilityRepo) GetDataSetStatesByLocalIDs(ctx context.Context, localIDs []int64) (map[int64]observability.DataSetState, error)

func (*BunObservabilityRepo) GetProviderSubject ¶

func (r *BunObservabilityRepo) GetProviderSubject(ctx context.Context, id types.OnChainID) (*ProviderSubject, error)

func (*BunObservabilityRepo) GetProviderTierSnapshot ¶

func (r *BunObservabilityRepo) GetProviderTierSnapshot(ctx context.Context, tier string) (*observability.ProviderTierSnapshot, error)

func (*BunObservabilityRepo) ListDataSetStates ¶

func (r *BunObservabilityRepo) ListDataSetStates(ctx context.Context, opts observability.ListOptions) (observability.DataSetStatePage, error)

func (*BunObservabilityRepo) ListProviderStates ¶

func (r *BunObservabilityRepo) ListProviderStates(ctx context.Context, opts observability.ListOptions) (observability.ProviderStatePage, error)

func (*BunObservabilityRepo) OverviewStorageStates ¶

func (r *BunObservabilityRepo) OverviewStorageStates(ctx context.Context) ([]model.StorageDataSet, []observability.ProviderState, []observability.DataSetState, *time.Time, *time.Time, error)

OverviewStorageStates scopes health to local dependencies without changing global observations.

func (*BunObservabilityRepo) ProviderProfiles ¶

func (r *BunObservabilityRepo) ProviderProfiles(ctx context.Context, ids []types.OnChainID) (map[string]observability.ProviderProfile, error)

func (*BunObservabilityRepo) RecordApprovedProviders ¶

func (r *BunObservabilityRepo) RecordApprovedProviders(ctx context.Context, startedAt time.Time, ids []types.OnChainID) (time.Time, error)

RecordApprovedProviders stores a complete approved-tier read and returns the collection time the stored snapshot carries, which is a newer read's time when that read already committed.

func (*BunObservabilityRepo) RecordEndorsedProviders ¶

func (r *BunObservabilityRepo) RecordEndorsedProviders(ctx context.Context, startedAt time.Time, ids []types.OnChainID) (time.Time, error)

RecordEndorsedProviders is RecordApprovedProviders for the endorsed tier.

func (*BunObservabilityRepo) ReplaceDataSetStates ¶

func (r *BunObservabilityRepo) ReplaceDataSetStates(ctx context.Context, checkedAt time.Time, states []observability.DataSetState) error

func (*BunObservabilityRepo) ReplaceProviderStates ¶

func (r *BunObservabilityRepo) ReplaceProviderStates(ctx context.Context, checkedAt time.Time, states []observability.ProviderState) error

func (*BunObservabilityRepo) UpsertProviderObservation ¶

func (r *BunObservabilityRepo) UpsertProviderObservation(ctx context.Context, checkedAt time.Time, state observability.ProviderState) error

func (*BunProviderUploadSpeedRepo) Begin ¶

func (r *BunProviderUploadSpeedRepo) Begin(ctx context.Context, providerID, hash string, taskID int64) error

func (*BunProviderUploadSpeedRepo) BeginIfDue ¶

func (r *BunProviderUploadSpeedRepo) BeginIfDue(ctx context.Context, providerID, hash string, taskID int64, testedBefore time.Time, nonMeasuredCodes []string) error

func (*BunProviderUploadSpeedRepo) FailActiveTask ¶

func (r *BunProviderUploadSpeedRepo) FailActiveTask(ctx context.Context, taskID int64, failureCode string) error

func (*BunProviderUploadSpeedRepo) Finish ¶

func (r *BunProviderUploadSpeedRepo) Finish(ctx context.Context, providerID string, taskID int64, state providerbenchmark.State, sampleBytes, durationMS, bytesPerSecond int64, failureCode string) error

func (*BunProviderUploadSpeedRepo) Get ¶

func (r *BunProviderUploadSpeedRepo) Get(ctx context.Context, providerID string) (*providerbenchmark.Result, error)

func (*BunProviderUploadSpeedRepo) ListByProviderIDs ¶

func (r *BunProviderUploadSpeedRepo) ListByProviderIDs(ctx context.Context, ids []string) (map[string]providerbenchmark.Result, error)

func (*BunProviderUploadSpeedRepo) ListLastSuccessByProviderURLs ¶

func (r *BunProviderUploadSpeedRepo) ListLastSuccessByProviderURLs(ctx context.Context, hashes map[string]string) (map[string]providerbenchmark.SuccessfulMeasurement, error)

ListLastSuccessByProviderURLs reads completed measurements for the requested URL fingerprints.

func (*BunProviderUploadSpeedRepo) TransferTaskOwner ¶

func (r *BunProviderUploadSpeedRepo) TransferTaskOwner(ctx context.Context, oldID, newID int64) error

func (*BunS3AccountRepo) Create ¶

func (r *BunS3AccountRepo) Create(ctx context.Context, account *model.S3Account) error

func (*BunS3AccountRepo) Delete ¶

func (r *BunS3AccountRepo) Delete(ctx context.Context, accessKey string) error

func (*BunS3AccountRepo) GetByAccessKey ¶

func (r *BunS3AccountRepo) GetByAccessKey(ctx context.Context, accessKey string) (*model.S3Account, error)

func (*BunS3AccountRepo) GetRoot ¶

func (r *BunS3AccountRepo) GetRoot(ctx context.Context) (*model.S3Account, error)

func (*BunS3AccountRepo) ListNonRoot ¶

func (r *BunS3AccountRepo) ListNonRoot(ctx context.Context) ([]model.S3Account, error)

func (*BunS3AccountRepo) LockByAccessKey ¶

func (r *BunS3AccountRepo) LockByAccessKey(ctx context.Context, accessKey string) (*model.S3Account, error)

func (*BunS3AccountRepo) Update ¶

func (r *BunS3AccountRepo) Update(ctx context.Context, accessKey string, update S3AccountUpdate) error

func (*BunStorageCleanupRepo) AuthorizeTask ¶

func (r *BunStorageCleanupRepo) AuthorizeTask(ctx context.Context, contentID, generation, taskID int64) ([]model.StorageCleanupCopy, error)

func (*BunStorageCleanupRepo) BindTask ¶

func (r *BunStorageCleanupRepo) BindTask(ctx context.Context, contentID, generation, taskID int64) error

func (*BunStorageCleanupRepo) CleanupHasObjectReferences ¶

func (r *BunStorageCleanupRepo) CleanupHasObjectReferences(ctx context.Context, contentID int64) (bool, error)

func (*BunStorageCleanupRepo) FinalizeContent ¶

func (r *BunStorageCleanupRepo) FinalizeContent(ctx context.Context, contentID, generation, taskID int64) error

FinalizeContent deletes the current-state rows of content whose remote cleanup finished: its cache record, its copies, and the content row. Commit, pull, replacement, cleanup, and deletion ledgers keep their rows and name the content by value. Unresolved pulls or other unfinished work return ErrContentCleanupNotReady. It must run in the caller's transaction.

func (*BunStorageCleanupRepo) MarkCopyUnsupported ¶

func (r *BunStorageCleanupRepo) MarkCopyUnsupported(ctx context.Context, id int64, message string) error

func (*BunStorageCleanupRepo) ReauthorizeFailedCopies ¶ added in v0.1.1

func (r *BunStorageCleanupRepo) ReauthorizeFailedCopies(ctx context.Context, contentID, generation, taskID int64) error

func (*BunStorageCleanupRepo) TransferTaskOwner ¶

func (r *BunStorageCleanupRepo) TransferTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunStorageCleanupRepo) UploadHasObjectReferences ¶

func (r *BunStorageCleanupRepo) UploadHasObjectReferences(ctx context.Context, contentID int64) (bool, error)

func (*BunStorageContentRepo) AbandonCommitRequest ¶

func (r *BunStorageContentRepo) AbandonCommitRequest(ctx context.Context, input AbandonCommitRequestInput) ([]model.StorageCopy, error)

AbandonCommitRequest settles the request as abandoned and releases its members. Sealed members that were waiting to register return to piece_ready; the caller decides whether each joins another request or fails. It returns the members as they were before release.

func (*BunStorageContentRepo) AbandonMigrationPull ¶

func (r *BunStorageContentRepo) AbandonMigrationPull(ctx context.Context, copyID, generation, taskID int64, pullAttemptID string) error

func (*BunStorageContentRepo) AuthorizeCopyTask ¶

func (r *BunStorageContentRepo) AuthorizeCopyTask(ctx context.Context, copyID, generation, taskID, claimGeneration int64) (*model.StorageCopy, error)

func (*BunStorageContentRepo) AuthorizeDataSetEnsureTask ¶

func (r *BunStorageContentRepo) AuthorizeDataSetEnsureTask(ctx context.Context, dataSetID, taskID int64) (*model.StorageDataSet, error)

func (*BunStorageContentRepo) AuthorizeDataSetRetirementTask ¶

func (r *BunStorageContentRepo) AuthorizeDataSetRetirementTask(ctx context.Context, dataSetID, generation, taskID int64) (*model.StorageDataSet, error)

func (*BunStorageContentRepo) BackfillClientDataSetID ¶

func (r *BunStorageContentRepo) BackfillClientDataSetID(ctx context.Context, input BackfillClientDataSetIDInput) error

func (*BunStorageContentRepo) BeginCommitSubmission ¶

func (r *BunStorageContentRepo) BeginCommitSubmission(ctx context.Context, input BeginCommitSubmissionInput) error

BeginCommitSubmission records that the request is about to be sent. It refuses with storagecommit.ErrNotEligible unless the request is the oldest eligible ready request of a data set that has room and still takes commits.

func (*BunStorageContentRepo) BeginIngressStoreProgress ¶

func (r *BunStorageContentRepo) BeginIngressStoreProgress(ctx context.Context, input BeginIngressStoreProgressInput) (*model.StorageCopy, error)

BeginIngressStoreProgress starts a fresh, fenced progress attempt on the Store copy. The caller runs this in the same transaction as the task checkpoint that authorizes the provider request.

func (*BunStorageContentRepo) BindCopyTask ¶

func (r *BunStorageContentRepo) BindCopyTask(ctx context.Context, copyID, generation, taskID int64) error

func (*BunStorageContentRepo) BindDataSetEnsureTask ¶

func (r *BunStorageContentRepo) BindDataSetEnsureTask(ctx context.Context, dataSetID, taskID int64) error

func (*BunStorageContentRepo) BindDataSetRetirementTask ¶

func (r *BunStorageContentRepo) BindDataSetRetirementTask(ctx context.Context, dataSetID, generation, taskID int64) error

func (*BunStorageContentRepo) BindReadableUploadForContent ¶

func (r *BunStorageContentRepo) BindReadableUploadForContent(ctx context.Context, input BindReadableUploadInput) ([]ObjectVersionRef, error)

BindReadableUploadForContent records that one content became readable at a provider. Versions already point at the content from creation, so this only settles the content row and reports the versions it backs.

func (*BunStorageContentRepo) BindReadableUploadForVersion ¶

func (r *BunStorageContentRepo) BindReadableUploadForVersion(ctx context.Context, input BindReadableUploadForVersionInput) ([]ObjectVersionRef, error)

BindReadableUploadForVersion is BindReadableUploadForContent scoped to the refs of a single version.

func (*BunStorageContentRepo) CommitQueueState ¶

func (r *BunStorageContentRepo) CommitQueueState(ctx context.Context, storageDataSetID int64, now time.Time) (CommitQueueState, error)

CommitQueueState reads the data set's registration queue at now.

func (*BunStorageContentRepo) CompleteCopyTask ¶

func (r *BunStorageContentRepo) CompleteCopyTask(ctx context.Context, copyID, generation, taskID int64) error

func (*BunStorageContentRepo) CompleteDataSetEnsureTask ¶

func (r *BunStorageContentRepo) CompleteDataSetEnsureTask(ctx context.Context, dataSetID, taskID int64) error

func (*BunStorageContentRepo) CompleteDataSetRetirementTask ¶

func (r *BunStorageContentRepo) CompleteDataSetRetirementTask(ctx context.Context, dataSetID, generation, taskID int64) error

func (*BunStorageContentRepo) ConfirmCommitRequest ¶

func (r *BunStorageContentRepo) ConfirmCommitRequest(ctx context.Context, input ConfirmCommitRequestInput) ([]model.StorageCopy, error)

ConfirmCommitRequest settles the request and commits every member, including one still being transferred again: the chain already holds its piece. It returns the members as they were before settlement. A replay of the same confirmation returns the members again and changes nothing.

func (*BunStorageContentRepo) ContentPipelineState ¶

func (r *BunStorageContentRepo) ContentPipelineState(ctx context.Context, contentID int64) (model.ObjectState, error)

GetIngressCopy returns the copy that performs the ingress transfer for this content, or nil when there is none. Progress lives there rather than on the content shared by every replica. ContentPipelineState derives how far a content has travelled from its copy rows. Nothing stores this: a stored column would be a second copy of facts the copies already own, and the two would drift.

func (*BunStorageContentRepo) CopyRetryStates ¶

func (r *BunStorageContentRepo) CopyRetryStates(ctx context.Context, copyIDs []int64) (map[int64]CopyRetryState, error)

CopyRetryStates batches the facts for display; callers must recheck admission.

func (*BunStorageContentRepo) CountCommitBacklog ¶

func (r *BunStorageContentRepo) CountCommitBacklog(ctx context.Context, storageDataSetID int64) (int, error)

CountCommitBacklog counts the copies transferred to a data set that wait for a request that has not been sent.

func (*BunStorageContentRepo) CountCurrentGenerationCopySlots ¶

func (r *BunStorageContentRepo) CountCurrentGenerationCopySlots(ctx context.Context, contentID int64) (int, error)

CountCurrentGenerationCopySlots counts logical replica slots, not physical generation rows.

func (*BunStorageContentRepo) CountStoppedCommitAttentionByDataSet ¶

func (r *BunStorageContentRepo) CountStoppedCommitAttentionByDataSet(ctx context.Context) (map[int64]int64, error)

CountStoppedCommitAttentionByDataSet counts, per data set, the flagged requests whose task stopped for an operator.

func (*BunStorageContentRepo) CreateCollectingCommitRequest ¶

func (r *BunStorageContentRepo) CreateCollectingCommitRequest(ctx context.Context, input CreateCommitRequestInput) error

CreateCollectingCommitRequest inserts a collecting request and adds the copies to it.

func (*BunStorageContentRepo) CreateUploadCopiesForBindings ¶

func (r *BunStorageContentRepo) CreateUploadCopiesForBindings(ctx context.Context, contentID int64, copies []UploadCopyBindingInput) error

func (*BunStorageContentRepo) DataSetCreationStopped ¶

func (r *BunStorageContentRepo) DataSetCreationStopped(ctx context.Context, id int64) (bool, error)

func (*BunStorageContentRepo) DiscardOrphanedContent ¶

func (r *BunStorageContentRepo) DiscardOrphanedContent(ctx context.Context, contentID int64, release func() error) (bool, error)

DiscardOrphanedContent deletes content no object version has ever named, after release removes its cached file. The file goes first: if the row delete then fails, a row without a file is left for the next discard, and a later write of the same bytes commits its own file before naming the row. The reverse order could leave a file that nothing names. It reports whether the content was deleted.

func (*BunStorageContentRepo) DropCommitEvidence ¶

func (r *BunStorageContentRepo) DropCommitEvidence(ctx context.Context, requestID string, taskID int64, lastError string, now time.Time) error

DropCommitEvidence forgets a receipt that did not describe the request. The request stays submitted: only its nonce can tell whether a send landed.

func (*BunStorageContentRepo) EnsureContent ¶

func (r *BunStorageContentRepo) EnsureContent(ctx context.Context, input EnsureContentInput) (*model.StorageContent, error)

EnsureContent returns the content row for one byte payload in a bucket, creating it if this is the first time those bytes are written. A uniqueness conflict returns the existing row unchanged: the requested-copy target is set when a version first names the content, not here. A finishing cleanup or the discard of a failed write can delete the conflicting row before it is read; the insert is then tried again.

func (*BunStorageContentRepo) EnsureDataSetBinding ¶

func (r *BunStorageContentRepo) EnsureDataSetBinding(ctx context.Context, input EnsureDataSetBindingInput) (*model.StorageDataSet, error)

func (*BunStorageContentRepo) FinalizeUploadIfTargetCopiesMet ¶

func (r *BunStorageContentRepo) FinalizeUploadIfTargetCopiesMet(ctx context.Context, input FinalizeUploadInput) (bool, []ObjectVersionRef, error)

func (*BunStorageContentRepo) GetByID ¶

func (r *BunStorageContentRepo) GetByID(ctx context.Context, contentID int64) (*model.StorageContent, error)

func (*BunStorageContentRepo) GetByIDs ¶

func (r *BunStorageContentRepo) GetByIDs(ctx context.Context, contentIDs []int64) (map[int64]model.StorageContent, error)

func (*BunStorageContentRepo) GetCommitBatch ¶

func (r *BunStorageContentRepo) GetCommitBatch(ctx context.Context, requestID string) (*CommitBatch, error)

func (*BunStorageContentRepo) GetCommitRequest ¶

func (r *BunStorageContentRepo) GetCommitRequest(ctx context.Context, requestID string) (*storagecommit.Request, error)

GetCommitRequest loads one request.

func (*BunStorageContentRepo) GetCommitSubject ¶

func (r *BunStorageContentRepo) GetCommitSubject(ctx context.Context, requestID string) (*StorageSubject, error)

func (*BunStorageContentRepo) GetContentSubject ¶

func (r *BunStorageContentRepo) GetContentSubject(ctx context.Context, id int64) (*StorageSubject, error)

func (*BunStorageContentRepo) GetCopySubject ¶

func (r *BunStorageContentRepo) GetCopySubject(ctx context.Context, id int64) (*StorageSubject, error)

func (*BunStorageContentRepo) GetDataSetBindingByCopyIndex ¶

func (r *BunStorageContentRepo) GetDataSetBindingByCopyIndex(ctx context.Context, bucketID int64, copyIndex int) (*model.StorageDataSet, error)

GetDataSetBindingByCopyIndex returns the generation that currently owns the slot. Historical generations stay readable but never receive new writes.

func (*BunStorageContentRepo) GetDataSetBindingByID ¶

func (r *BunStorageContentRepo) GetDataSetBindingByID(ctx context.Context, id int64) (*model.StorageDataSet, error)

func (*BunStorageContentRepo) GetDataSetSubject ¶

func (r *BunStorageContentRepo) GetDataSetSubject(ctx context.Context, id int64) (*StorageSubject, error)

func (*BunStorageContentRepo) GetIngressCopy ¶

func (r *BunStorageContentRepo) GetIngressCopy(ctx context.Context, contentID int64) (*model.StorageCopy, error)

func (*BunStorageContentRepo) GetLastAbandonedPullAttempt ¶

func (r *BunStorageContentRepo) GetLastAbandonedPullAttempt(ctx context.Context, contentID, storageDataSetID int64) (*storagepull.Attempt, error)

func (*BunStorageContentRepo) GetLiveVersionForUpload ¶

func (r *BunStorageContentRepo) GetLiveVersionForUpload(ctx context.Context, contentID int64) (*model.ObjectVersion, error)

func (*BunStorageContentRepo) GetPullAttempt ¶

func (r *BunStorageContentRepo) GetPullAttempt(ctx context.Context, attemptID string, contentID, storageDataSetID int64) (*storagepull.Attempt, error)

GetPullAttempt requires the copy identity as well as the checkpoint's ID.

func (*BunStorageContentRepo) GetUnresolvedPullAttempt ¶

func (r *BunStorageContentRepo) GetUnresolvedPullAttempt(ctx context.Context, contentID, storageDataSetID int64) (*storagepull.Attempt, error)

GetUnresolvedPullAttempt recovers evidence retained independently of a task.

func (*BunStorageContentRepo) GetUploadCopy ¶

func (r *BunStorageContentRepo) GetUploadCopy(ctx context.Context, contentID int64, copyIndex int) (*model.StorageCopy, error)

GetUploadCopy resolves a slot to the copy on its current generation, so a task that carries only (upload, slot) can never address a replaced or a not-yet-activated generation.

func (*BunStorageContentRepo) GetUploadCopyByID ¶

func (r *BunStorageContentRepo) GetUploadCopyByID(ctx context.Context, id int64) (*model.StorageCopy, error)

func (*BunStorageContentRepo) GetUploadCopyForDataSet ¶

func (r *BunStorageContentRepo) GetUploadCopyForDataSet(ctx context.Context, contentID, storageDataSetID int64) (*model.StorageCopy, error)

GetUploadCopyForDataSet addresses one concrete generation, which is how replacement work targets the new provider while the old one still exists.

func (*BunStorageContentRepo) GetUploadProvenance ¶

func (r *BunStorageContentRepo) GetUploadProvenance(ctx context.Context, contentID int64) (*StorageContentProvenance, error)

func (*BunStorageContentRepo) HasCacheDependentCommitMembers ¶

func (r *BunStorageContentRepo) HasCacheDependentCommitMembers(ctx context.Context, requestID string) (bool, error)

func (*BunStorageContentRepo) HasReadableCommittedCopy ¶

func (r *BunStorageContentRepo) HasReadableCommittedCopy(ctx context.Context, contentID int64) (bool, error)

func (*BunStorageContentRepo) IsPendingReplacementCopy ¶

func (r *BunStorageContentRepo) IsPendingReplacementCopy(ctx context.Context, copyID int64) (bool, error)

func (*BunStorageContentRepo) JoinCollectingCommitRequest ¶

func (r *BunStorageContentRepo) JoinCollectingCommitRequest(ctx context.Context, input JoinCommitRequestInput) (string, int, error)

JoinCollectingCommitRequest adds the copy to the oldest collecting request of its data set with a live task. It returns the request and its member count, or ErrNotFound when no such request exists.

The data set stays locked until the caller's transaction ends, so a caller that then creates a request on ErrNotFound does so before any other copy of the data set looks for one: copies transferred together share a request. The joining copy belongs to no request yet, so no holder of the data set lock waits for it.

func (*BunStorageContentRepo) ListBucketStorageHealthAffectedVersions ¶

func (r *BunStorageContentRepo) ListBucketStorageHealthAffectedVersions(ctx context.Context, input BucketStorageHealthAffectedVersionsInput) (BucketStorageHealthAffectedVersionPage, error)

func (*BunStorageContentRepo) ListBucketStorageHealthSummaries ¶

func (r *BunStorageContentRepo) ListBucketStorageHealthSummaries(ctx context.Context, bucketID int64, staleBefore time.Time, affectedVersionCap int) ([]BucketStorageHealthSummary, error)

func (*BunStorageContentRepo) ListCommitAttention ¶

func (r *BunStorageContentRepo) ListCommitAttention(ctx context.Context, limit int) ([]storagecommit.AttentionRecord, error)

ListCommitAttention lists submitted requests flagged for attention, oldest flag first.

func (*BunStorageContentRepo) ListCommitAttentionForTasks ¶

func (r *BunStorageContentRepo) ListCommitAttentionForTasks(ctx context.Context, taskIDs []int64) ([]storagecommit.AttentionRecord, error)

ListCommitAttentionForTasks lists the flagged requests driven by the tasks.

func (*BunStorageContentRepo) ListCommitBatchMembers ¶

func (r *BunStorageContentRepo) ListCommitBatchMembers(ctx context.Context, requestID string) ([]CommitBatchMember, error)

func (*BunStorageContentRepo) ListCommitBatches ¶

func (r *BunStorageContentRepo) ListCommitBatches(ctx context.Context, filter CommitBatchFilter) ([]CommitBatch, error)

func (*BunStorageContentRepo) ListCommitRequestMembers ¶

func (r *BunStorageContentRepo) ListCommitRequestMembers(ctx context.Context, requestID string) ([]CommitRequestMember, error)

ListCommitRequestMembers returns the copies that belong to a request: sealed members in position order, then collecting members in the order they became ready.

func (*BunStorageContentRepo) ListCommitRequestPieces ¶

func (r *BunStorageContentRepo) ListCommitRequestPieces(ctx context.Context, requestID string) ([]storagecommit.RequestPiece, error)

ListCommitRequestPieces returns a sealed request's pieces in position order.

func (*BunStorageContentRepo) ListCopies ¶

func (r *BunStorageContentRepo) ListCopies(ctx context.Context, contentID int64) ([]model.StorageCopy, error)

func (*BunStorageContentRepo) ListDataSetBindings ¶

func (r *BunStorageContentRepo) ListDataSetBindings(ctx context.Context, bucketID int64) ([]model.StorageDataSet, error)

ListDataSetBindings returns every generation, including retired ones, because callers need the full provider history as well as the current write targets.

func (*BunStorageContentRepo) ListDataSetSummaries ¶

func (r *BunStorageContentRepo) ListDataSetSummaries(ctx context.Context, bucketID int64) ([]StorageDataSetSummary, error)

func (*BunStorageContentRepo) ListInFlightCopiesForDataSet ¶

func (r *BunStorageContentRepo) ListInFlightCopiesForDataSet(ctx context.Context, storageDataSetID int64) ([]model.StorageCopy, error)

ListInFlightCopiesForDataSet lists every copy that may still write to the data set, including copies whose content no live version needs.

func (*BunStorageContentRepo) ListIncompleteCopiesForDataSet ¶

func (r *BunStorageContentRepo) ListIncompleteCopiesForDataSet(ctx context.Context, storageDataSetID int64) ([]model.StorageCopy, error)

func (*BunStorageContentRepo) ListOrphanedContents ¶

func (r *BunStorageContentRepo) ListOrphanedContents(ctx context.Context, createdBefore time.Time, afterID int64, limit int) ([]OrphanedContent, error)

ListOrphanedContents pages through content created before createdBefore that no object version has ever named.

func (*BunStorageContentRepo) ListReadableCommittedCopies ¶

func (r *BunStorageContentRepo) ListReadableCommittedCopies(ctx context.Context, contentID int64) ([]ReadableStorageCopy, error)

func (*BunStorageContentRepo) ListReadyBucketProviderIDs ¶

func (r *BunStorageContentRepo) ListReadyBucketProviderIDs(ctx context.Context) ([]string, error)

func (*BunStorageContentRepo) LockForCopyCreation ¶

func (r *BunStorageContentRepo) LockForCopyCreation(ctx context.Context, contentID int64) (*model.StorageContent, error)

LockForCopyCreation holds the content lock until the caller's transaction ends and rejects content reserved for cleanup.

func (*BunStorageContentRepo) MarkCommitRequestAttention ¶

func (r *BunStorageContentRepo) MarkCommitRequestAttention(ctx context.Context, requestID string, taskID int64, code storagecommit.AttentionCode, now time.Time) error

MarkCommitRequestAttention flags a submitted request. The first code it is flagged with is kept until a receipt or a settlement clears it.

func (*BunStorageContentRepo) MarkDataSetCreating ¶

func (r *BunStorageContentRepo) MarkDataSetCreating(ctx context.Context, input MarkDataSetCreatingInput) error

MarkDataSetCreating records a creation request that went out. A generation that replacement drained while the request was in flight stays draining; the request is still recorded so the data set it creates can be resolved.

func (*BunStorageContentRepo) MarkDataSetDraining ¶

func (r *BunStorageContentRepo) MarkDataSetDraining(ctx context.Context, id int64, lastError string) error

func (*BunStorageContentRepo) MarkDataSetReady ¶

func (r *BunStorageContentRepo) MarkDataSetReady(ctx context.Context, input MarkDataSetReadyInput) error

func (*BunStorageContentRepo) MarkUploadCopyFailed ¶

func (r *BunStorageContentRepo) MarkUploadCopyFailed(ctx context.Context, input MarkUploadCopyFailedInput) error

func (*BunStorageContentRepo) MarkUploadCopyPieceReady ¶

func (r *BunStorageContentRepo) MarkUploadCopyPieceReady(ctx context.Context, input MarkUploadCopyPieceReadyInput) error

MarkUploadCopyPieceReady records a finished transfer. A copy waiting in no signed request becomes piece_ready; a signed member sent back to transfer returns to committing, its request's registering state.

func (*BunStorageContentRepo) NextCopyWorkGeneration ¶

func (r *BunStorageContentRepo) NextCopyWorkGeneration(ctx context.Context, copyID int64) (int64, error)

func (*BunStorageContentRepo) NextDataSetRetirementGeneration ¶

func (r *BunStorageContentRepo) NextDataSetRetirementGeneration(ctx context.Context, dataSetID int64) (int64, error)

func (*BunStorageContentRepo) NextFinalizableCopyForDataSet ¶

func (r *BunStorageContentRepo) NextFinalizableCopyForDataSet(ctx context.Context, storageDataSetID int64) (*model.StorageCopy, error)

func (*BunStorageContentRepo) PendingUploadPlansForReplica ¶

func (r *BunStorageContentRepo) PendingUploadPlansForReplica(ctx context.Context, bucketID int64, copyIndex int) ([]int64, error)

func (*BunStorageContentRepo) PromotePendingIngress ¶

func (r *BunStorageContentRepo) PromotePendingIngress(ctx context.Context, contentID int64) (*model.StorageCopy, error)

func (*BunStorageContentRepo) ProviderDataSetLoads ¶

func (r *BunStorageContentRepo) ProviderDataSetLoads(ctx context.Context, ids []types.OnChainID) (map[string]int, error)

func (*BunStorageContentRepo) RecordCommitResend ¶

func (r *BunStorageContentRepo) RecordCommitResend(ctx context.Context, input CommitSendInput) error

RecordCommitResend records that the request is about to be sent again.

func (*BunStorageContentRepo) RecordCommitSubmission ¶

func (r *BunStorageContentRepo) RecordCommitSubmission(ctx context.Context, input CommitSubmissionInput) error

RecordCommitSubmission keeps the receipt of the latest send. The first receipt answers whatever attention an unacknowledged send was flagged with.

func (*BunStorageContentRepo) RecordCommitSubmitFailure ¶

func (r *BunStorageContentRepo) RecordCommitSubmitFailure(ctx context.Context, input CommitSubmitFailureInput) error

func (*BunStorageContentRepo) RecordDataSetClientID ¶

func (r *BunStorageContentRepo) RecordDataSetClientID(ctx context.Context, id, ensureTaskID int64, clientDataSetID types.OnChainID) error

func (*BunStorageContentRepo) RecordDataSetCreationError ¶

func (r *BunStorageContentRepo) RecordDataSetCreationError(ctx context.Context, id, taskID int64, message string) error

RecordDataSetCreationError keeps why a creation request whose outcome is unknown failed. It changes nothing once another task owns the data set or the creation has moved on; creation evidence and readiness clear it.

func (*BunStorageContentRepo) RecordIngressStoreProgress ¶

func (r *BunStorageContentRepo) RecordIngressStoreProgress(ctx context.Context, input RecordIngressStoreProgressInput) (*model.StorageCopy, error)

func (*BunStorageContentRepo) ReleaseMemberTransfer ¶

func (r *BunStorageContentRepo) ReleaseMemberTransfer(ctx context.Context, input ReleaseMemberTransferInput) error

ReleaseMemberTransfer ends the transfer task of a signed member that could not be transferred again. The member keeps its place in its request, whose task can read the chain and decides what becomes of it, so that task is woken.

func (*BunStorageContentRepo) ReopenFailedIngressForPull ¶

func (r *BunStorageContentRepo) ReopenFailedIngressForPull(ctx context.Context, contentID int64) ([]model.StorageCopy, error)

func (*BunStorageContentRepo) ReopenFailedUploadCopy ¶

func (r *BunStorageContentRepo) ReopenFailedUploadCopy(ctx context.Context, copyID int64) error

func (*BunStorageContentRepo) ReplaceCopyTask ¶

func (r *BunStorageContentRepo) ReplaceCopyTask(ctx context.Context, copyID, generation, taskID, nextGeneration, nextTaskID int64) error

func (*BunStorageContentRepo) RequestCommitSeal ¶

func (r *BunStorageContentRepo) RequestCommitSeal(ctx context.Context, requestID string) (*storagecommit.Request, error)

RequestCommitSeal records collection intent; the existing task owns signing.

func (*BunStorageContentRepo) ReservePullRequest ¶

func (r *BunStorageContentRepo) ReservePullRequest(ctx context.Context, input ReservePullRequestInput) error

ReservePullRequest records a provider-side copy request before it is sent. The attempt lives in its own ledger row, so a crash between writing it and sending it leaves a fully identified operation recovery can observe instead of nullable columns that may be half written.

func (*BunStorageContentRepo) ResumeFailedStoreCopy ¶

func (r *BunStorageContentRepo) ResumeFailedStoreCopy(ctx context.Context, input ResumeFailedStoreCopyInput) error

ResumeFailedStoreCopy requires the cache read gate and a checkpoint whose upload session has been validated by the transfer owner.

func (*BunStorageContentRepo) RetryFailedCopy ¶

func (r *BunStorageContentRepo) RetryFailedCopy(ctx context.Context, copyID int64) (*model.StorageCopy, error)

RetryFailedCopy requires the shared cache gate before entering its transaction. The bucket policy lock also serializes replacement authorization and activation.

func (*BunStorageContentRepo) ReturnCommitMembersToTransfer ¶

func (r *BunStorageContentRepo) ReturnCommitMembersToTransfer(ctx context.Context, requestID string, taskID int64, copyIDs []int64, now time.Time) error

ReturnCommitMembersToTransfer sends sealed members whose pieces the provider dropped back to transfer. They keep their positions, so the request is sent whole again once every member is transferred.

func (*BunStorageContentRepo) ReturnCommitRequestToReady ¶

func (r *BunStorageContentRepo) ReturnCommitRequestToReady(ctx context.Context, input ReturnCommitRequestInput) error

func (*BunStorageContentRepo) SealCommitRequest ¶

func (r *BunStorageContentRepo) SealCommitRequest(ctx context.Context, input SealCommitRequestInput) ([]int64, error)

SealCommitRequest records the request's signature and its members' positions. Every signed member must still be waiting in the request; copies that joined after the members were read are returned to the caller, outside any request, so they can join the next one.

func (*BunStorageContentRepo) SetCopyCacheRestore ¶

func (r *BunStorageContentRepo) SetCopyCacheRestore(ctx context.Context, copyID, generation, taskID int64, pullAttemptID, lastError string) error

SetCopyCacheRestore is fenced by the copy task and cache availability. Locking the cache entry before the content uses the same order as eviction.

func (*BunStorageContentRepo) TransferCommitTaskOwner ¶

func (r *BunStorageContentRepo) TransferCommitTaskOwner(ctx context.Context, id string, oldID, newID int64) error

func (*BunStorageContentRepo) TransferCopyTaskOwner ¶

func (r *BunStorageContentRepo) TransferCopyTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunStorageContentRepo) TransferEnsureTaskOwner ¶

func (r *BunStorageContentRepo) TransferEnsureTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunStorageContentRepo) TransferRetireTaskOwner ¶

func (r *BunStorageContentRepo) TransferRetireTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunStorageContentRepo) WakeCacheDependentCommitTasks ¶

func (r *BunStorageContentRepo) WakeCacheDependentCommitTasks(ctx context.Context) error

func (*BunStorageContentRepo) WakeCollectingCommitTask ¶

func (r *BunStorageContentRepo) WakeCollectingCommitTask(ctx context.Context, requestID string) error

WakeCollectingCommitTask wakes collection after a join unless the queue is blocked.

func (*BunStorageContentRepo) WakeCommitRequestTask ¶

func (r *BunStorageContentRepo) WakeCommitRequestTask(ctx context.Context, requestID string) error

WakeCommitRequestTask makes one request's task runnable.

func (*BunStorageRemovalRepo) AbandonRemovalRequest ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) AbandonRemovalRequest(ctx context.Context, input RemovalRequestInput) error

func (*BunStorageRemovalRepo) AdmitRemovalSend ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) AdmitRemovalSend(ctx context.Context, input AdmitRemovalSendInput) error

func (*BunStorageRemovalRepo) AdoptLegacyCleanupCopy ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) AdoptLegacyCleanupCopy(ctx context.Context, input AdoptLegacyCleanupCopyInput) (*storageremoval.Request, error)

func (*BunStorageRemovalRepo) ClearRemovalAttention ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) ClearRemovalAttention(ctx context.Context, input RemovalRequestInput) error

func (*BunStorageRemovalRepo) DetachMembers ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) DetachMembers(ctx context.Context, input RemovalMembersInput) error

func (*BunStorageRemovalRepo) GetRemovalRequest ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) GetRemovalRequest(ctx context.Context, id string) (*storageremoval.Request, error)

func (*BunStorageRemovalRepo) JoinOrCreateCollecting ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) JoinOrCreateCollecting(ctx context.Context, input JoinRemovalInput) (*storageremoval.Request, error)

func (*BunStorageRemovalRepo) ListRemovalBatchesForTasks ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) ListRemovalBatchesForTasks(ctx context.Context, ids []int64) ([]storageremoval.TaskBatch, error)

func (*BunStorageRemovalRepo) ListRemovalMembers ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) ListRemovalMembers(ctx context.Context, id string) ([]model.StorageCleanupCopy, error)

func (*BunStorageRemovalRepo) ListRemovalSends ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) ListRemovalSends(ctx context.Context, id string) ([]storageremoval.Send, error)

func (*BunStorageRemovalRepo) MarkMemberFailed ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) MarkMemberFailed(ctx context.Context, input RemovalMembersInput) error

func (*BunStorageRemovalRepo) MarkMembersRemoved ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) MarkMembersRemoved(ctx context.Context, input RemovalMembersInput) error

func (*BunStorageRemovalRepo) MarkQueuedWithoutSend ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) MarkQueuedWithoutSend(ctx context.Context, input RemovalQueuedInput) error

func (*BunStorageRemovalRepo) MarkRemovalQueued ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) MarkRemovalQueued(ctx context.Context, input RemovalQueuedInput) error

func (*BunStorageRemovalRepo) MarkRemovalReverted ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) MarkRemovalReverted(ctx context.Context, input RemovalRequestInput) error

func (*BunStorageRemovalRepo) RecordSendReceipt ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) RecordSendReceipt(ctx context.Context, input RemovalSendEvidenceInput) error

func (*BunStorageRemovalRepo) RecordSendRefused ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) RecordSendRefused(ctx context.Context, input RemovalSendEvidenceInput) error

func (*BunStorageRemovalRepo) RecordSendSubmission ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) RecordSendSubmission(ctx context.Context, input RemovalSendEvidenceInput) error

func (*BunStorageRemovalRepo) RecordSendUnsent ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) RecordSendUnsent(ctx context.Context, input RemovalSendEvidenceInput) error

func (*BunStorageRemovalRepo) SealRemovalRequest ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) SealRemovalRequest(ctx context.Context, input SealRemovalInput) error

func (*BunStorageRemovalRepo) SetRemovalAttention ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) SetRemovalAttention(ctx context.Context, input RemovalAttentionInput) error

func (*BunStorageRemovalRepo) SettleRemovalRequest ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) SettleRemovalRequest(ctx context.Context, input RemovalRequestInput) error

func (*BunStorageRemovalRepo) TransferRemovalTaskOwner ¶ added in v0.1.1

func (r *BunStorageRemovalRepo) TransferRemovalTaskOwner(ctx context.Context, id string, oldTaskID, newTaskID int64) error

func (*BunStorageReplacementRepo) AbandonUncreatedCopiesBatch ¶

func (r *BunStorageReplacementRepo) AbandonUncreatedCopiesBatch(ctx context.Context, replacementID, generation, taskID int64, limit int) (bool, error)

AbandonUncreatedCopiesBatch transfers local obligations before releasing old copy fences. The caller fences this transaction with the live engine claim.

func (*BunStorageReplacementRepo) AcquireItem ¶

func (r *BunStorageReplacementRepo) AcquireItem(ctx context.Context, input AcquireReplacementItemInput) (*ReplacementItemSnapshot, error)

func (*BunStorageReplacementRepo) AcquireItemsForCoordinator ¶

func (r *BunStorageReplacementRepo) AcquireItemsForCoordinator(ctx context.Context, replacementID, generation, taskID, afterID int64, limit int) (ReplacementItemBatch, error)

func (*BunStorageReplacementRepo) Activate ¶

func (r *BunStorageReplacementRepo) Activate(ctx context.Context, replacementID, generation, taskID int64) error

Activate is the single atomic switch: the target starts receiving writes and the source retires locally or starts draining its remote service.

func (*BunStorageReplacementRepo) AttachTargetCopy ¶

func (r *BunStorageReplacementRepo) AttachTargetCopy(ctx context.Context, input AttachReplacementTargetCopyInput) (*model.StorageCopy, error)

AttachTargetCopy resolves the copy an item already names. Seeding created both the item and its pending copy, so this only reads back the binding the item was born with and refuses an item that belongs to another content.

func (*BunStorageReplacementRepo) Authorize ¶

func (r *BunStorageReplacementRepo) Authorize(ctx context.Context, input AuthorizeReplacementInput) (*storagereplacement.Replacement, bool, error)

Authorize is the only way a replacement comes into existence. It records domain authorization and topology state only; TaskService binds the coordinator in the caller's transaction.

func (*BunStorageReplacementRepo) AuthorizeTask ¶

func (r *BunStorageReplacementRepo) AuthorizeTask(ctx context.Context, replacementID, generation, taskID int64) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) BeginRetirement ¶

func (r *BunStorageReplacementRepo) BeginRetirement(ctx context.Context, replacementID int64) error

func (*BunStorageReplacementRepo) BeginTerminationAttempt ¶

func (r *BunStorageReplacementRepo) BeginTerminationAttempt(ctx context.Context, input BeginTerminationAttemptInput) error

BeginTerminationAttempt admits one request for the current retirement owner. A new attempt requires a reverted predecessor; repeating its admission is inert. A released attempt is admitted again in place, by its task or a successor, and so is an unresolved one by a successor when ResumeUnresolved.

func (*BunStorageReplacementRepo) BindTask ¶

func (r *BunStorageReplacementRepo) BindTask(ctx context.Context, replacementID, generation, taskID int64) error

func (*BunStorageReplacementRepo) CompleteAbandonedTargetTermination ¶

func (r *BunStorageReplacementRepo) CompleteAbandonedTargetTermination(ctx context.Context, replacementID int64) error

CompleteAbandonedTargetTermination retires the superseded target once its end of term has been recorded, refusing to retire one that has none. It never touches the replacement record, which stays superseded, and it refuses a generation that still owns its slot.

func (*BunStorageReplacementRepo) CompleteRetirement ¶

func (r *BunStorageReplacementRepo) CompleteRetirement(ctx context.Context, replacementID int64, observedEpoch int64) error

CompleteRetirement re-runs every predicate inside its own transaction, so a caller outside the worker cannot retire a source that is still needed.

func (*BunStorageReplacementRepo) CompleteTask ¶

func (r *BunStorageReplacementRepo) CompleteTask(ctx context.Context, replacementID, generation, taskID int64) error

func (*BunStorageReplacementRepo) CompleteWithoutRemoteSource ¶

func (r *BunStorageReplacementRepo) CompleteWithoutRemoteSource(ctx context.Context, replacementID, generation, taskID int64) error

CompleteWithoutRemoteSource cannot bypass retirement of an existing service.

func (*BunStorageReplacementRepo) CountAbandonedTargetSoleCopies ¶

func (r *BunStorageReplacementRepo) CountAbandonedTargetSoleCopies(ctx context.Context, targetDataSetID int64) (int, error)

CountAbandonedTargetSoleCopies reports how many uploads would lose their only readable copy if this generation's service ended. An abandoned target holds partially migrated data that the retiring source should still have, so the answer is normally zero; anything else means terminating it would destroy the last copy of something.

func (*BunStorageReplacementRepo) EnsureTaskReplacement ¶

func (r *BunStorageReplacementRepo) EnsureTaskReplacement(ctx context.Context, taskID int64) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) EvaluateRetirementGate ¶

func (r *BunStorageReplacementRepo) EvaluateRetirementGate(ctx context.Context, replacementID int64, observedEpoch *int64) (RetirementGate, error)

EvaluateRetirementGate answers one question: can this source stop existing without losing anything? Pass a nil observedEpoch to evaluate everything except the epoch, which must be read outside a transaction.

func (*BunStorageReplacementRepo) FailForEngineTask ¶

func (r *BunStorageReplacementRepo) FailForEngineTask(ctx context.Context, taskID int64, lastError string) error

FailForEngineTask records on the replacement that the Engine failed its current coordinator claim itself. A replacement resumes only through the Data Sets retry, which accepts a failed or cleanup-attention replacement, so the failure lands there. A coordinator that no longer owns the replacement changes nothing.

func (*BunStorageReplacementRepo) GetActiveForDataSet ¶

func (r *BunStorageReplacementRepo) GetActiveForDataSet(ctx context.Context, dataSetID int64) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) GetByClientRequestID ¶

func (r *BunStorageReplacementRepo) GetByClientRequestID(
	ctx context.Context,
	bucketID int64,
	clientRequestID string,
) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) GetByID ¶

func (r *BunStorageReplacementRepo) GetByID(ctx context.Context, id int64) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) GetReplacementSubject ¶

func (r *BunStorageReplacementRepo) GetReplacementSubject(ctx context.Context, id int64) (*ReplacementSubject, error)

func (*BunStorageReplacementRepo) HandOverSourceWritesBatch ¶

func (r *BunStorageReplacementRepo) HandOverSourceWritesBatch(ctx context.Context, replacementID, generation, taskID int64, limit int) ([]model.StorageCopy, bool, error)

HandOverSourceWritesBatch moves unsigned writes still bound to an activated remote source to its target. A sealed registration member or a copy with an unresolved pull attempt carries a signed authorization and stays until its outcome is known. The caller fences this transaction with the live engine claim.

func (*BunStorageReplacementRepo) HasInProgressForDataSet ¶

func (r *BunStorageReplacementRepo) HasInProgressForDataSet(ctx context.Context, dataSetID int64) (bool, error)

HasInProgressForDataSet covers both generations a replacement owns. The target matters as much as the source: in-place recovery would otherwise queue repair work on the generation the coordinator is actively writing, and the two would race over the same copy row. It excludes operator-paused failed and attention states so that generation can still recover and repair in place; the replacement nevertheless retains its source, target, and slot identity.

func (*BunStorageReplacementRepo) HasUnsignedSourceWrites ¶

func (r *BunStorageReplacementRepo) HasUnsignedSourceWrites(ctx context.Context, sourceDataSetID int64) (bool, error)

HasUnsignedSourceWrites reports whether a source has writes that can be handed over.

func (*BunStorageReplacementRepo) InspectItem ¶

func (r *BunStorageReplacementRepo) InspectItem(ctx context.Context, input AcquireReplacementItemInput) (*ReplacementItemSnapshot, error)

AcquireItem re-derives the current domain snapshot. Replacement items are ledgers, not workers; task claim and lease state never appears here.

func (*BunStorageReplacementRepo) ListActive ¶

func (r *BunStorageReplacementRepo) ListActive(ctx context.Context, afterID int64, limit int) ([]storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) ListForBucket ¶

func (r *BunStorageReplacementRepo) ListForBucket(ctx context.Context, bucketID int64, limit int) ([]storagereplacement.Replacement, error)

ListForBucket returns the whole replacement history, newest first, so the API can present a stable order.

func (*BunStorageReplacementRepo) ListPendingReplacementItemsAfter ¶

func (r *BunStorageReplacementRepo) ListPendingReplacementItemsAfter(ctx context.Context, replacementID, afterID int64, limit int) ([]storagereplacement.Item, error)

func (*BunStorageReplacementRepo) ListTerminationAttempts ¶

func (r *BunStorageReplacementRepo) ListTerminationAttempts(ctx context.Context, replacementIDs []int64) ([]storagereplacement.TerminationAttempt, error)

func (*BunStorageReplacementRepo) ListUnscheduledSuperseded ¶

func (r *BunStorageReplacementRepo) ListUnscheduledSuperseded(ctx context.Context, successorID int64) ([]storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) LockCoordinatorProgress ¶

func (r *BunStorageReplacementRepo) LockCoordinatorProgress(ctx context.Context, replacementID, generation, taskID int64) (*storagereplacement.Replacement, error)

func (*BunStorageReplacementRepo) LockCoordinatorTask ¶

func (r *BunStorageReplacementRepo) LockCoordinatorTask(ctx context.Context, replacementID, generation, taskID int64) (*storagereplacement.Replacement, error)

LockCoordinatorTask holds the replacement's domain fence for transaction-local writes.

func (*BunStorageReplacementRepo) MarkCleanupAttention ¶

func (r *BunStorageReplacementRepo) MarkCleanupAttention(ctx context.Context, replacementID int64, lastError string) error

MarkCleanupAttention is committed in the same transaction that stops the coordinator task, so automatic retry can never resume suppressed cleanup. Marking a replacement that already waits for attention only refreshes its error, so a retried task that stops again for the same reason can still settle.

func (*BunStorageReplacementRepo) MarkFailed ¶

func (r *BunStorageReplacementRepo) MarkFailed(
	ctx context.Context,
	replacementID int64,
	reason *storagereplacement.FailureReason,
	lastError string,
) error

func (*BunStorageReplacementRepo) MarkInitializationFailed ¶

func (r *BunStorageReplacementRepo) MarkInitializationFailed(ctx context.Context, id, generation, taskID, childID int64, message string) error

func (*BunStorageReplacementRepo) MarkMigrating ¶

func (r *BunStorageReplacementRepo) MarkMigrating(ctx context.Context, replacementID int64) error

func (*BunStorageReplacementRepo) MarkReplacementItemAttention ¶

func (r *BunStorageReplacementRepo) MarkReplacementItemAttention(ctx context.Context, replacementID, itemID int64, lastError string) error

func (*BunStorageReplacementRepo) MarkReplacementItemCancelled ¶

func (r *BunStorageReplacementRepo) MarkReplacementItemCancelled(ctx context.Context, replacementID, itemID int64) error

func (*BunStorageReplacementRepo) MarkReplacementItemCopied ¶

func (r *BunStorageReplacementRepo) MarkReplacementItemCopied(ctx context.Context, replacementID, itemID, targetCopyID int64) error

func (*BunStorageReplacementRepo) MarkWaiting ¶

func (r *BunStorageReplacementRepo) MarkWaiting(ctx context.Context, replacementID int64, reason storagereplacement.WaitReason) error

MarkWaiting records a recoverable pause. It never consumes retry budget and is never reported as a failure.

func (*BunStorageReplacementRepo) NextPendingReplacementItem ¶

func (r *BunStorageReplacementRepo) NextPendingReplacementItem(ctx context.Context, replacementID int64) (*storagereplacement.Item, error)

func (*BunStorageReplacementRepo) Preflight ¶

func (r *BunStorageReplacementRepo) Preflight(ctx context.Context, dataSetID int64) (*ReplacementPreflight, error)

func (*BunStorageReplacementRepo) PrepareCoordinatorRetry ¶

func (r *BunStorageReplacementRepo) PrepareCoordinatorRetry(ctx context.Context, id, generation, taskID int64) (*model.StorageDataSet, error)

func (*BunStorageReplacementRepo) RecordTerminationEvidence ¶

func (r *BunStorageReplacementRepo) RecordTerminationEvidence(ctx context.Context, input RecordTerminationEvidenceInput) error

RecordTerminationEvidence preserves each attempt's immutable transaction pair and receipt outcome. The service epoch is independent of any failed attempt.

func (*BunStorageReplacementRepo) RecordTerminationUnsent ¶ added in v0.1.1

func (r *BunStorageReplacementRepo) RecordTerminationUnsent(ctx context.Context, input RecordTerminationEvidenceInput) error

RecordTerminationUnsent releases the latest admission after the current retirement owner proved that no transaction from it can land. Releasing again is inert; an attempt with any transaction evidence cannot be released.

func (*BunStorageReplacementRepo) ReplacementExecution ¶

func (r *BunStorageReplacementRepo) ReplacementExecution(
	ctx context.Context,
	replacementID int64,
) (storagereplacement.ExecutionSnapshot, error)

func (*BunStorageReplacementRepo) ReplacementProgresses ¶

func (r *BunStorageReplacementRepo) ReplacementProgresses(
	ctx context.Context,
	replacementIDs []int64,
) (map[int64]storagereplacement.ProgressSnapshot, error)

func (*BunStorageReplacementRepo) ResumeCoordinatorTask ¶

func (r *BunStorageReplacementRepo) ResumeCoordinatorTask(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunStorageReplacementRepo) Retry ¶

func (r *BunStorageReplacementRepo) Retry(ctx context.Context, input RetryReplacementInput) (*storagereplacement.Replacement, error)

Retry resumes the same approved target. The phase is re-derived from the data rather than remembered, so a retry always restarts at the stage the replacement actually reached.

func (*BunStorageReplacementRepo) RetryEligibility ¶

func (r *BunStorageReplacementRepo) RetryEligibility(ctx context.Context, replacementID int64) error

func (*BunStorageReplacementRepo) SeedMigrationBatch ¶

func (r *BunStorageReplacementRepo) SeedMigrationBatch(ctx context.Context, replacementID int64, limit int) (int, bool, error)

func (*BunStorageReplacementRepo) SourceEligibility ¶

func (r *BunStorageReplacementRepo) SourceEligibility(ctx context.Context, dataSetID int64) (*model.StorageDataSet, bool, error)

SourceEligibility is shared by presentation, preflight, and authorization. The bool distinguishes a local handoff from replacement of a remote service.

func (*BunStorageReplacementRepo) TransferTaskOwner ¶

func (r *BunStorageReplacementRepo) TransferTaskOwner(ctx context.Context, id, generation, oldID, newID int64) error

func (*BunTaskRepo) AcknowledgeFailed ¶

func (r *BunTaskRepo) AcknowledgeFailed(ctx context.Context, id int64) error

func (*BunTaskRepo) AcknowledgeFailedForSubject ¶

func (r *BunTaskRepo) AcknowledgeFailedForSubject(ctx context.Context, subjectType, subjectKey string) (int, error)

func (*BunTaskRepo) AcknowledgeFailedMatching ¶

func (r *BunTaskRepo) AcknowledgeFailedMatching(ctx context.Context, filter TaskAcknowledgeFilter) (int, error)

func (*BunTaskRepo) AdmitEffect ¶

func (r *BunTaskRepo) AdmitEffect(ctx context.Context, id, generation int64, key string, checkpoint json.RawMessage) error

func (*BunTaskRepo) AppendEvent ¶

func (r *BunTaskRepo) AppendEvent(ctx context.Context, taskID int64, eventType string, details json.RawMessage) error

func (*BunTaskRepo) ClaimNext ¶

func (r *BunTaskRepo) ClaimNext(ctx context.Context, leaseDuration time.Duration, filter TaskClaimFilter) (*model.Task, error)

func (*BunTaskRepo) CountByScope ¶

func (r *BunTaskRepo) CountByScope(ctx context.Context, scope TaskScope) ([]TaskStatusCount, error)

func (*BunTaskRepo) CountFailedMatching ¶

func (r *BunTaskRepo) CountFailedMatching(ctx context.Context, filter TaskAcknowledgeFilter) (int, error)

func (*BunTaskRepo) CountOverviewActivePipeline ¶

func (r *BunTaskRepo) CountOverviewActivePipeline(ctx context.Context) ([]TaskPipelineCount, error)

func (*BunTaskRepo) CountUnacknowledgedFailed ¶

func (r *BunTaskRepo) CountUnacknowledgedFailed(ctx context.Context) (int64, error)

func (*BunTaskRepo) Enqueue ¶

func (r *BunTaskRepo) Enqueue(ctx context.Context, task *model.Task) (*model.Task, bool, error)

func (*BunTaskRepo) GetByID ¶

func (r *BunTaskRepo) GetByID(ctx context.Context, id int64) (*model.Task, error)

func (*BunTaskRepo) GetByIdentity ¶

func (r *BunTaskRepo) GetByIdentity(ctx context.Context, taskType model.TaskType, subjectType, subjectKey string, generation int64) (*model.Task, error)

func (*BunTaskRepo) GetDirectSuccessor ¶

func (r *BunTaskRepo) GetDirectSuccessor(ctx context.Context, id int64) (*model.Task, error)

func (*BunTaskRepo) GetForUpdate ¶

func (r *BunTaskRepo) GetForUpdate(ctx context.Context, id int64) (*model.Task, error)

func (*BunTaskRepo) LatestForSubject ¶

func (r *BunTaskRepo) LatestForSubject(ctx context.Context, subjectType, subjectKey string, types ...model.TaskType) (*model.Task, error)

func (*BunTaskRepo) LatestForSubjects ¶

func (r *BunTaskRepo) LatestForSubjects(ctx context.Context, subjectType string, subjectKeys []string, types ...model.TaskType) (map[string]model.Task, error)

func (*BunTaskRepo) List ¶

func (r *BunTaskRepo) List(ctx context.Context, filter TaskListFilter) (TaskPage, error)

func (*BunTaskRepo) ListCurrentFailedForSubject ¶

func (r *BunTaskRepo) ListCurrentFailedForSubject(ctx context.Context, subjectType, subjectKey string, beforeID int64, limit int, types ...model.TaskType) (TaskPage, error)

func (*BunTaskRepo) ListEvents ¶

func (r *BunTaskRepo) ListEvents(ctx context.Context, taskID, beforeID int64, limit int) ([]model.TaskEvent, error)

func (*BunTaskRepo) ListHistory ¶

func (r *BunTaskRepo) ListHistory(ctx context.Context, anchorID, beforeID int64, limit int) (TaskPage, error)

func (*BunTaskRepo) MarkWorkStarted ¶

func (r *BunTaskRepo) MarkWorkStarted(ctx context.Context, id, generation int64, startedAt time.Time) error

MarkWorkStarted preserves the first operation time under the live claim fence.

func (*BunTaskRepo) ObserveOperation ¶

func (r *BunTaskRepo) ObserveOperation(ctx context.Context, id, generation int64, key string) (time.Time, error)

func (*BunTaskRepo) PreviousStoreCheckpoints ¶

func (r *BunTaskRepo) PreviousStoreCheckpoints(ctx context.Context, copyID, taskID int64) ([]model.Task, error)

func (*BunTaskRepo) RenewLease ¶

func (r *BunTaskRepo) RenewLease(ctx context.Context, id, generation int64, leaseDuration time.Duration) (time.Time, error)

func (*BunTaskRepo) ResolveOperation ¶

func (r *BunTaskRepo) ResolveOperation(ctx context.Context, id, generation int64, key string) error

func (*BunTaskRepo) Settle ¶

func (r *BunTaskRepo) Settle(ctx context.Context, id, generation int64, transition TaskTransition) error

func (*BunTaskRepo) ShortenLease ¶

func (r *BunTaskRepo) ShortenLease(ctx context.Context, id, generation int64, duration time.Duration) error

func (*BunTaskRepo) SupersedeTerminal ¶

func (r *BunTaskRepo) SupersedeTerminal(ctx context.Context, id int64) error

func (*BunTaskRepo) ValidateClaim ¶

func (r *BunTaskRepo) ValidateClaim(ctx context.Context, id, generation int64) error

func (*BunTaskRepo) WakePending ¶

func (r *BunTaskRepo) WakePending(ctx context.Context, ids []int64) (int, error)

func (*BunTaskRepo) WakePendingOfTypes ¶

func (r *BunTaskRepo) WakePendingOfTypes(ctx context.Context, ids []int64, types []model.TaskType, skipWaitReasons []string) (int, error)

WakePendingOfTypes applies type and wait-reason authorization in the update.

func (*BunTaskRepo) WriteCheckpoint ¶

func (r *BunTaskRepo) WriteCheckpoint(ctx context.Context, id, generation int64, checkpoint json.RawMessage) error

func (*BunTaskScheduleRepo) Ensure ¶

func (r *BunTaskScheduleRepo) Ensure(ctx context.Context, key string, nextRunAt time.Time) error

func (*BunTaskScheduleRepo) GetByTaskID ¶

func (r *BunTaskScheduleRepo) GetByTaskID(ctx context.Context, taskID int64) (*model.TaskSchedule, error)

func (*BunTaskScheduleRepo) GetForUpdate ¶

func (r *BunTaskScheduleRepo) GetForUpdate(ctx context.Context, key string) (*model.TaskSchedule, error)

func (*BunTaskScheduleRepo) ListDue ¶

func (r *BunTaskScheduleRepo) ListDue(ctx context.Context, now time.Time) ([]model.TaskSchedule, error)

func (*BunTaskScheduleRepo) ScheduleNext ¶

func (r *BunTaskScheduleRepo) ScheduleNext(ctx context.Context, key string, taskID int64, nextRunAt time.Time) error

func (*BunTaskScheduleRepo) SetHead ¶

func (r *BunTaskScheduleRepo) SetHead(ctx context.Context, key string, expectedGeneration, generation int64, expectedTaskID, taskID *int64, nextRunAt time.Time) error

func (*BunWalletOperationRepo) BindTask ¶

func (r *BunWalletOperationRepo) BindTask(ctx context.Context, id, taskID int64) error

func (*BunWalletOperationRepo) CreateOrGet ¶

func (r *BunWalletOperationRepo) CreateOrGet(ctx context.Context, input CreateWalletOperationInput) (*model.WalletOperation, bool, error)

CreateOrGet records a wallet request once per client request ID. A request that loses a race to the same ID gets the winner's operation: the conflict never raises an error, which on PostgreSQL would abort the caller's transaction before the winner could be read.

func (*BunWalletOperationRepo) GetByID ¶

func (r *BunWalletOperationRepo) GetByID(ctx context.Context, id int64) (*model.WalletOperation, error)

func (*BunWalletOperationRepo) GetOperationSubject ¶

func (r *BunWalletOperationRepo) GetOperationSubject(ctx context.Context, id int64) (*model.WalletOperation, error)

func (*BunWalletOperationRepo) ListRecent ¶

func (r *BunWalletOperationRepo) ListRecent(ctx context.Context, limit int) ([]model.WalletOperation, error)

func (*BunWalletOperationRepo) MarkBroadcastAttempted ¶

func (r *BunWalletOperationRepo) MarkBroadcastAttempted(ctx context.Context, id, taskID int64) error

func (*BunWalletOperationRepo) MarkConfirmed ¶

func (r *BunWalletOperationRepo) MarkConfirmed(ctx context.Context, id, taskID int64, txHash string) error

func (*BunWalletOperationRepo) MarkConfirmedWithoutTransaction ¶

func (r *BunWalletOperationRepo) MarkConfirmedWithoutTransaction(ctx context.Context, id, taskID int64) error

func (*BunWalletOperationRepo) MarkFailed ¶

func (r *BunWalletOperationRepo) MarkFailed(ctx context.Context, id, taskID int64, lastError string) error

func (*BunWalletOperationRepo) MarkSubmissionUnknown ¶ added in v0.1.1

func (r *BunWalletOperationRepo) MarkSubmissionUnknown(ctx context.Context, id, taskID int64, lastError string) error

MarkSubmissionUnknown stops a submitted operation whose transaction can no longer land when what took its place is unknown. Its transaction evidence is kept.

func (*BunWalletOperationRepo) MarkSubmitted ¶

func (r *BunWalletOperationRepo) MarkSubmitted(ctx context.Context, id, taskID int64, txHash string) error

func (*BunWalletOperationRepo) MarkUnknown ¶

func (r *BunWalletOperationRepo) MarkUnknown(ctx context.Context, id, taskID int64, lastError string) error

func (*BunWalletOperationRepo) RecordConfirmationError ¶

func (r *BunWalletOperationRepo) RecordConfirmationError(ctx context.Context, id, taskID int64, lastError string) error

func (*BunWalletOperationRepo) RecordSubmission ¶

func (r *BunWalletOperationRepo) RecordSubmission(ctx context.Context, id, taskID int64, txHash string, signedTransaction []byte, lastError string) error

RecordSubmission only fills missing transaction evidence or repeats it unchanged.

func (*BunWalletOperationRepo) ReopenUnsentForRetry ¶ added in v0.1.1

func (r *BunWalletOperationRepo) ReopenUnsentForRetry(ctx context.Context, id, oldTaskID, newTaskID int64) error

func (*BunWalletOperationRepo) TransferTaskOwner ¶

func (r *BunWalletOperationRepo) TransferTaskOwner(ctx context.Context, id, oldID, newID int64) error

func (*CopyRetryBlockedError) Error ¶

func (e *CopyRetryBlockedError) Error() string

func (*CopyRetryBlockedError) Unwrap ¶