s3-orchestrator

storetest

import "github.com/afreidah/s3-orchestrator/internal/store/storetest"

Package storetest hosts the mockgen-generated MockMetadataStore used across the test suite as a single drop-in replacement for the hand-written wide store mocks that previously lived in internal/proxy, internal/store, internal/testutil, and internal/di.

Package storetest is a generated GoMock package.

Index

func Permissive

func Permissive(m *MockMetadataStore)

Permissive registers a permissive .AnyTimes() expectation that returns zero values for every method on MockMetadataStore. Call it at the end of test setup, after registering specific stricter expectations: gomock matches expectations in declaration order, so specific stubs fire first (until their Times() bound is reached) and unstubbed methods fall through to the catch-all here. Lets tests opt into mocking only the methods they care about without the system under test panicking on incidental calls (orphan-bytes adjustments, sweep rows, advisory locks, etc.).

helpers would be more boilerplate without meaningful structure.

type MetadataStore

MetadataStore is the union of every narrow store role interface. It exists only as a mockgen target so a single generated MockMetadataStore can stand in wherever a fully-populated proxy.Stores or a concreteStore-shaped DI value is needed. Production code never depends on this composite - production callers consume the narrow roles declared in internal/store/core directly.

QuotaStore.GetQuotaStats and DashboardStore.GetQuotaStats share a signature; embedded interfaces flatten to a single method on the outer interface, which is why this composite must be declared rather than synthesised by struct embedding of per-role mocks.

type MetadataStore interface {
    core.ObjectStore
    core.QuotaStore
    core.MultipartStore
    core.ReplicationStore
    core.CleanupStore
    core.PendingStore
    core.IntegrityStore
    core.ExpiredObjectsLister
    core.BackendLifecycleStore
    core.UsageFlusher
    core.AdvisoryLocker
    core.DashboardStore
    core.LifecycleAdmin
    core.EncryptionAdmin
    core.NotificationOutbox
}

type MockMetadataStore

MockMetadataStore is a mock of MetadataStore interface.

type MockMetadataStore struct {
    // contains filtered or unexported fields
}

func NewMockMetadataStore

func NewMockMetadataStore(ctrl *gomock.Controller) *MockMetadataStore

NewMockMetadataStore creates a new mock instance.

func (*MockMetadataStore) BackendObjectStats

func (m *MockMetadataStore) BackendObjectStats(ctx context.Context, backendName string) (int64, int64, error)

BackendObjectStats mocks base method.

func (*MockMetadataStore) ClaimPendingCleanups

func (m *MockMetadataStore) ClaimPendingCleanups(ctx context.Context, limit int, instanceID string, graceCutoff time.Time) ([]core.CleanupItem, error)

ClaimPendingCleanups mocks base method.

func (*MockMetadataStore) CleanupDLQDepth

func (m *MockMetadataStore) CleanupDLQDepth(ctx context.Context) (int64, error)

CleanupDLQDepth mocks base method.

func (*MockMetadataStore) CleanupQueueDepth

func (m *MockMetadataStore) CleanupQueueDepth(ctx context.Context) (int64, error)

CleanupQueueDepth mocks base method.

func (*MockMetadataStore) Close

func (m *MockMetadataStore) Close()

Close mocks base method.

func (*MockMetadataStore) CompleteCleanupItem

func (m *MockMetadataStore) CompleteCleanupItem(ctx context.Context, id int64) error

CompleteCleanupItem mocks base method.

func (*MockMetadataStore) CompleteNotification

func (m *MockMetadataStore) CompleteNotification(ctx context.Context, id int64) error

CompleteNotification mocks base method.

func (*MockMetadataStore) CountActiveMultipartUploads

func (m *MockMetadataStore) CountActiveMultipartUploads(ctx context.Context, bucketPrefix string) (int64, error)

CountActiveMultipartUploads mocks base method.

func (*MockMetadataStore) CountOverReplicatedObjects

func (m *MockMetadataStore) CountOverReplicatedObjects(ctx context.Context, factor int) (int64, error)

CountOverReplicatedObjects mocks base method.

func (*MockMetadataStore) CreateMultipartUpload

func (m *MockMetadataStore) CreateMultipartUpload(ctx context.Context, params *core.CreateMultipartUploadParams) error

CreateMultipartUpload mocks base method.

func (*MockMetadataStore) DecrementOrphanBytes

func (m *MockMetadataStore) DecrementOrphanBytes(ctx context.Context, backendName string, amount int64) error

DecrementOrphanBytes mocks base method.

func (*MockMetadataStore) DeleteBackendData

func (m *MockMetadataStore) DeleteBackendData(ctx context.Context, backendName string) error

DeleteBackendData mocks base method.

func (*MockMetadataStore) DeleteMultipartUpload

func (m *MockMetadataStore) DeleteMultipartUpload(ctx context.Context, uploadID string) error

DeleteMultipartUpload mocks base method.

func (*MockMetadataStore) DeleteObject

func (m *MockMetadataStore) DeleteObject(ctx context.Context, key string) ([]core.DeletedCopy, error)

DeleteObject mocks base method.

func (*MockMetadataStore) DeleteObjectLocation

func (m *MockMetadataStore) DeleteObjectLocation(ctx context.Context, key, backendName string) error

DeleteObjectLocation mocks base method.

func (*MockMetadataStore) DeleteObjectsBatch

func (m *MockMetadataStore) DeleteObjectsBatch(ctx context.Context, keys []string) (map[string][]core.DeletedCopy, error)

DeleteObjectsBatch mocks base method.

func (*MockMetadataStore) DeletePending

func (m *MockMetadataStore) DeletePending(ctx context.Context, intentID string) error

DeletePending mocks base method.

func (*MockMetadataStore) DeletePendingByBackend

func (m *MockMetadataStore) DeletePendingByBackend(ctx context.Context, backendName string) error

DeletePendingByBackend mocks base method.

func (*MockMetadataStore) EXPECT

func (m *MockMetadataStore) EXPECT() *MockMetadataStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataStore) EnqueueCleanup

func (m *MockMetadataStore) EnqueueCleanup(ctx context.Context, backendName, objectKey, reason string, sizeBytes int64) error

EnqueueCleanup mocks base method.

func (*MockMetadataStore) FlushUsageDeltas

func (m *MockMetadataStore) FlushUsageDeltas(ctx context.Context, backendName, period string, apiRequests, egressBytes, ingressBytes int64) error

FlushUsageDeltas mocks base method.

func (*MockMetadataStore) GetActiveMultipartCounts

func (m *MockMetadataStore) GetActiveMultipartCounts(ctx context.Context) (map[string]int64, error)

GetActiveMultipartCounts mocks base method.

func (*MockMetadataStore) GetAllObjectLocations

func (m *MockMetadataStore) GetAllObjectLocations(ctx context.Context, key string) ([]core.ObjectLocation, error)

GetAllObjectLocations mocks base method.

func (*MockMetadataStore) GetBackendWithSpace

func (m *MockMetadataStore) GetBackendWithSpace(ctx context.Context, size int64, backendOrder []string) (string, error)

GetBackendWithSpace mocks base method.

func (*MockMetadataStore) GetLeastUtilizedBackend

func (m *MockMetadataStore) GetLeastUtilizedBackend(ctx context.Context, size int64, eligible []string) (string, error)

GetLeastUtilizedBackend mocks base method.

func (*MockMetadataStore) GetMultipartUpload

func (m *MockMetadataStore) GetMultipartUpload(ctx context.Context, uploadID string) (*core.MultipartUpload, error)

GetMultipartUpload mocks base method.

func (*MockMetadataStore) GetMultipartUploadsByBackend

func (m *MockMetadataStore) GetMultipartUploadsByBackend(ctx context.Context, backendName string) ([]core.MultipartUpload, error)

GetMultipartUploadsByBackend mocks base method.

func (*MockMetadataStore) GetObjectBackendsForKeys

func (m *MockMetadataStore) GetObjectBackendsForKeys(ctx context.Context, keys []string) (map[string][]string, error)

GetObjectBackendsForKeys mocks base method.

func (*MockMetadataStore) GetObjectCounts

func (m *MockMetadataStore) GetObjectCounts(ctx context.Context) (map[string]int64, error)

GetObjectCounts mocks base method.

func (*MockMetadataStore) GetObjectsWithoutHash

func (m *MockMetadataStore) GetObjectsWithoutHash(ctx context.Context, limit, offset int) ([]core.ObjectLocation, error)

GetObjectsWithoutHash mocks base method.

func (*MockMetadataStore) GetOverReplicatedObjects

func (m *MockMetadataStore) GetOverReplicatedObjects(ctx context.Context, factor, limit int) ([]core.ObjectLocation, error)

GetOverReplicatedObjects mocks base method.

func (*MockMetadataStore) GetParts

func (m *MockMetadataStore) GetParts(ctx context.Context, uploadID string) ([]core.MultipartPart, error)

GetParts mocks base method.

func (*MockMetadataStore) GetPendingCleanups

func (m *MockMetadataStore) GetPendingCleanups(ctx context.Context, limit int) ([]core.CleanupItem, error)

GetPendingCleanups mocks base method.

func (*MockMetadataStore) GetPendingNotifications

func (m *MockMetadataStore) GetPendingNotifications(ctx context.Context, limit int) ([]core.NotificationRow, error)

GetPendingNotifications mocks base method.

func (*MockMetadataStore) GetQuotaStats

func (m *MockMetadataStore) GetQuotaStats(ctx context.Context) (map[string]core.QuotaStat, error)

GetQuotaStats mocks base method.

func (*MockMetadataStore) GetRandomHashedObjects

func (m *MockMetadataStore) GetRandomHashedObjects(ctx context.Context, limit int) ([]core.ObjectLocation, error)

GetRandomHashedObjects mocks base method.

func (*MockMetadataStore) GetStaleMultipartUploads

func (m *MockMetadataStore) GetStaleMultipartUploads(ctx context.Context, olderThan time.Duration) ([]core.MultipartUpload, error)

GetStaleMultipartUploads mocks base method.

func (*MockMetadataStore) GetStalePending

func (m *MockMetadataStore) GetStalePending(ctx context.Context, olderThan time.Time, limit int) ([]core.PendingObject, error)

GetStalePending mocks base method.

func (*MockMetadataStore) GetUnderReplicatedObjects

func (m *MockMetadataStore) GetUnderReplicatedObjects(ctx context.Context, factor, limit int) ([]core.ObjectLocation, error)

GetUnderReplicatedObjects mocks base method.

func (*MockMetadataStore) GetUnderReplicatedObjectsExcluding

func (m *MockMetadataStore) GetUnderReplicatedObjectsExcluding(ctx context.Context, factor, limit int, excludedBackends []string) ([]core.ObjectLocation, error)

GetUnderReplicatedObjectsExcluding mocks base method.

func (*MockMetadataStore) GetUnverifiedObjectCounts

func (m *MockMetadataStore) GetUnverifiedObjectCounts(ctx context.Context) (map[string]int64, error)

GetUnverifiedObjectCounts mocks base method.

func (*MockMetadataStore) GetUsageForPeriod

func (m *MockMetadataStore) GetUsageForPeriod(ctx context.Context, period string) (map[string]core.UsageStat, error)

GetUsageForPeriod mocks base method.

func (*MockMetadataStore) ImportObject

func (m *MockMetadataStore) ImportObject(ctx context.Context, key, backend string, size int64) (bool, error)

ImportObject mocks base method.

func (*MockMetadataStore) IncrementOrphanBytes

func (m *MockMetadataStore) IncrementOrphanBytes(ctx context.Context, backendName string, amount int64) error

IncrementOrphanBytes mocks base method.

func (*MockMetadataStore) InsertNotification

func (m *MockMetadataStore) InsertNotification(ctx context.Context, eventType, payload, endpointURL string) error

InsertNotification mocks base method.

func (*MockMetadataStore) InsertPending

func (m *MockMetadataStore) InsertPending(ctx context.Context, p *core.PendingObject) error

InsertPending mocks base method.

func (*MockMetadataStore) ListAllEncryptedLocations

func (m *MockMetadataStore) ListAllEncryptedLocations(ctx context.Context, limit, offset int) ([]core.DecryptableLocation, error)

ListAllEncryptedLocations mocks base method.

func (*MockMetadataStore) ListDirectoryChildren

func (m *MockMetadataStore) ListDirectoryChildren(ctx context.Context, prefix, startAfter string, maxKeys int) (*core.DirectoryListResult, error)

ListDirectoryChildren mocks base method.

func (*MockMetadataStore) ListEncryptedLocations

func (m *MockMetadataStore) ListEncryptedLocations(ctx context.Context, keyID string, limit, offset int) ([]core.EncryptedLocation, error)

ListEncryptedLocations mocks base method.

func (*MockMetadataStore) ListExpiredObjects

func (m *MockMetadataStore) ListExpiredObjects(ctx context.Context, prefix string, cutoff time.Time, limit int) ([]core.ObjectLocation, error)

ListExpiredObjects mocks base method.

func (*MockMetadataStore) ListMultipartUploads

func (m *MockMetadataStore) ListMultipartUploads(ctx context.Context, prefix string, maxUploads int) ([]core.MultipartUpload, error)

ListMultipartUploads mocks base method.

func (*MockMetadataStore) ListObjects

func (m *MockMetadataStore) ListObjects(ctx context.Context, prefix, startAfter string, maxKeys int) (*core.ListObjectsResult, error)

ListObjects mocks base method.

func (*MockMetadataStore) ListObjectsByBackend

func (m *MockMetadataStore) ListObjectsByBackend(ctx context.Context, backendName string, limit int) ([]core.ObjectLocation, error)

ListObjectsByBackend mocks base method.

func (*MockMetadataStore) ListObjectsByBackendKeyAsc

func (m *MockMetadataStore) ListObjectsByBackendKeyAsc(ctx context.Context, backendName, afterKey string, limit int) ([]core.ObjectLocation, error)

ListObjectsByBackendKeyAsc mocks base method.

func (*MockMetadataStore) ListUnencryptedLocations

func (m *MockMetadataStore) ListUnencryptedLocations(ctx context.Context, limit, offset int) ([]core.UnencryptedLocation, error)

ListUnencryptedLocations mocks base method.

func (*MockMetadataStore) MarkObjectDecrypted

func (m *MockMetadataStore) MarkObjectDecrypted(ctx context.Context, objectKey, backendName string, plaintextSize int64) error

MarkObjectDecrypted mocks base method.

func (*MockMetadataStore) MarkObjectEncrypted

func (m *MockMetadataStore) MarkObjectEncrypted(ctx context.Context, objectKey, backendName string, encryptionKey []byte, keyID string, plaintextSize, ciphertextSize int64) error

MarkObjectEncrypted mocks base method.

func (*MockMetadataStore) MoveCleanupToDLQ

func (m *MockMetadataStore) MoveCleanupToDLQ(ctx context.Context, id int64, lastError string) (bool, error)

MoveCleanupToDLQ mocks base method.

func (*MockMetadataStore) MoveObjectLocation

func (m *MockMetadataStore) MoveObjectLocation(ctx context.Context, key, fromBackend, toBackend string) (int64, error)

MoveObjectLocation mocks base method.

func (*MockMetadataStore) PendingDepth

func (m *MockMetadataStore) PendingDepth(ctx context.Context) (int64, error)

PendingDepth mocks base method.

func (*MockMetadataStore) PromotePending

func (m *MockMetadataStore) PromotePending(ctx context.Context, p *core.PendingObject) (core.PendingPromoteResult, []core.DeletedCopy, error)

PromotePending mocks base method.

func (*MockMetadataStore) RecordObject

func (m *MockMetadataStore) RecordObject(ctx context.Context, key, backend string, size int64, enc *core.EncryptionMeta) ([]core.DeletedCopy, error)

RecordObject mocks base method.

func (*MockMetadataStore) RecordObjectAndClearPending

func (m *MockMetadataStore) RecordObjectAndClearPending(ctx context.Context, key, backend string, size int64, enc *core.EncryptionMeta, intentID string) ([]core.DeletedCopy, error)

RecordObjectAndClearPending mocks base method.

func (*MockMetadataStore) RecordPart

func (m *MockMetadataStore) RecordPart(ctx context.Context, uploadID string, partNumber int, etag string, size int64, enc *core.EncryptionMeta) error

RecordPart mocks base method.

func (*MockMetadataStore) RecordReplica

func (m *MockMetadataStore) RecordReplica(ctx context.Context, key, targetBackend, sourceBackend string) (int64, bool, error)

RecordReplica mocks base method.

func (*MockMetadataStore) RemoveExcessCopy

func (m *MockMetadataStore) RemoveExcessCopy(ctx context.Context, key, backendName string, size int64) error

RemoveExcessCopy mocks base method.

func (*MockMetadataStore) RetryCleanupItem

func (m *MockMetadataStore) RetryCleanupItem(ctx context.Context, id int64, backoff time.Duration, lastError string) error

RetryCleanupItem mocks base method.

func (*MockMetadataStore) RetryNotification

func (m *MockMetadataStore) RetryNotification(ctx context.Context, id int64, backoff time.Duration, lastError string) error

RetryNotification mocks base method.

func (*MockMetadataStore) RunMigrations

func (m *MockMetadataStore) RunMigrations(ctx context.Context) error

RunMigrations mocks base method.

func (*MockMetadataStore) SweepStaleCleanupQueueRows

func (m *MockMetadataStore) SweepStaleCleanupQueueRows(ctx context.Context, key, backend string) (int64, error)

SweepStaleCleanupQueueRows mocks base method.

func (*MockMetadataStore) SyncQuotaLimits

func (m *MockMetadataStore) SyncQuotaLimits(ctx context.Context, backends []config.BackendConfig) error

SyncQuotaLimits mocks base method.

func (*MockMetadataStore) UpdateContentHash

func (m *MockMetadataStore) UpdateContentHash(ctx context.Context, key, backendName, hash string) error

UpdateContentHash mocks base method.

func (*MockMetadataStore) UpdateEncryptionKey

func (m *MockMetadataStore) UpdateEncryptionKey(ctx context.Context, objectKey, backendName string, newEncryptionKey []byte, newKeyID string) error

UpdateEncryptionKey mocks base method.

func (*MockMetadataStore) VerifySchemaVersion

func (m *MockMetadataStore) VerifySchemaVersion(ctx context.Context) error

VerifySchemaVersion mocks base method.

func (*MockMetadataStore) WithAdvisoryLock

func (m *MockMetadataStore) WithAdvisoryLock(ctx context.Context, lockID int64, fn func(context.Context) error) (bool, error)

WithAdvisoryLock mocks base method.

type MockMetadataStoreMockRecorder

MockMetadataStoreMockRecorder is the mock recorder for MockMetadataStore.

type MockMetadataStoreMockRecorder struct {
    // contains filtered or unexported fields
}

func (*MockMetadataStoreMockRecorder) BackendObjectStats

func (mr *MockMetadataStoreMockRecorder) BackendObjectStats(ctx, backendName any) *gomock.Call

BackendObjectStats indicates an expected call of BackendObjectStats.

func (*MockMetadataStoreMockRecorder) ClaimPendingCleanups

func (mr *MockMetadataStoreMockRecorder) ClaimPendingCleanups(ctx, limit, instanceID, graceCutoff any) *gomock.Call

ClaimPendingCleanups indicates an expected call of ClaimPendingCleanups.

func (*MockMetadataStoreMockRecorder) CleanupDLQDepth

func (mr *MockMetadataStoreMockRecorder) CleanupDLQDepth(ctx any) *gomock.Call

CleanupDLQDepth indicates an expected call of CleanupDLQDepth.

func (*MockMetadataStoreMockRecorder) CleanupQueueDepth

func (mr *MockMetadataStoreMockRecorder) CleanupQueueDepth(ctx any) *gomock.Call

CleanupQueueDepth indicates an expected call of CleanupQueueDepth.

func (*MockMetadataStoreMockRecorder) Close

func (mr *MockMetadataStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMetadataStoreMockRecorder) CompleteCleanupItem

func (mr *MockMetadataStoreMockRecorder) CompleteCleanupItem(ctx, id any) *gomock.Call

CompleteCleanupItem indicates an expected call of CompleteCleanupItem.

func (*MockMetadataStoreMockRecorder) CompleteNotification

func (mr *MockMetadataStoreMockRecorder) CompleteNotification(ctx, id any) *gomock.Call

CompleteNotification indicates an expected call of CompleteNotification.

func (*MockMetadataStoreMockRecorder) CountActiveMultipartUploads

func (mr *MockMetadataStoreMockRecorder) CountActiveMultipartUploads(ctx, bucketPrefix any) *gomock.Call

CountActiveMultipartUploads indicates an expected call of CountActiveMultipartUploads.

func (*MockMetadataStoreMockRecorder) CountOverReplicatedObjects

func (mr *MockMetadataStoreMockRecorder) CountOverReplicatedObjects(ctx, factor any) *gomock.Call

CountOverReplicatedObjects indicates an expected call of CountOverReplicatedObjects.

func (*MockMetadataStoreMockRecorder) CreateMultipartUpload

func (mr *MockMetadataStoreMockRecorder) CreateMultipartUpload(ctx, params any) *gomock.Call

CreateMultipartUpload indicates an expected call of CreateMultipartUpload.

func (*MockMetadataStoreMockRecorder) DecrementOrphanBytes

func (mr *MockMetadataStoreMockRecorder) DecrementOrphanBytes(ctx, backendName, amount any) *gomock.Call

DecrementOrphanBytes indicates an expected call of DecrementOrphanBytes.

func (*MockMetadataStoreMockRecorder) DeleteBackendData

func (mr *MockMetadataStoreMockRecorder) DeleteBackendData(ctx, backendName any) *gomock.Call

DeleteBackendData indicates an expected call of DeleteBackendData.

func (*MockMetadataStoreMockRecorder) DeleteMultipartUpload

func (mr *MockMetadataStoreMockRecorder) DeleteMultipartUpload(ctx, uploadID any) *gomock.Call

DeleteMultipartUpload indicates an expected call of DeleteMultipartUpload.

func (*MockMetadataStoreMockRecorder) DeleteObject

func (mr *MockMetadataStoreMockRecorder) DeleteObject(ctx, key any) *gomock.Call

DeleteObject indicates an expected call of DeleteObject.

func (*MockMetadataStoreMockRecorder) DeleteObjectLocation

func (mr *MockMetadataStoreMockRecorder) DeleteObjectLocation(ctx, key, backendName any) *gomock.Call

DeleteObjectLocation indicates an expected call of DeleteObjectLocation.

func (*MockMetadataStoreMockRecorder) DeleteObjectsBatch

func (mr *MockMetadataStoreMockRecorder) DeleteObjectsBatch(ctx, keys any) *gomock.Call

DeleteObjectsBatch indicates an expected call of DeleteObjectsBatch.

func (*MockMetadataStoreMockRecorder) DeletePending

func (mr *MockMetadataStoreMockRecorder) DeletePending(ctx, intentID any) *gomock.Call

DeletePending indicates an expected call of DeletePending.

func (*MockMetadataStoreMockRecorder) DeletePendingByBackend

func (mr *MockMetadataStoreMockRecorder) DeletePendingByBackend(ctx, backendName any) *gomock.Call

DeletePendingByBackend indicates an expected call of DeletePendingByBackend.

func (*MockMetadataStoreMockRecorder) EnqueueCleanup

func (mr *MockMetadataStoreMockRecorder) EnqueueCleanup(ctx, backendName, objectKey, reason, sizeBytes any) *gomock.Call

EnqueueCleanup indicates an expected call of EnqueueCleanup.

func (*MockMetadataStoreMockRecorder) FlushUsageDeltas

func (mr *MockMetadataStoreMockRecorder) FlushUsageDeltas(ctx, backendName, period, apiRequests, egressBytes, ingressBytes any) *gomock.Call

FlushUsageDeltas indicates an expected call of FlushUsageDeltas.

func (*MockMetadataStoreMockRecorder) GetActiveMultipartCounts

func (mr *MockMetadataStoreMockRecorder) GetActiveMultipartCounts(ctx any) *gomock.Call

GetActiveMultipartCounts indicates an expected call of GetActiveMultipartCounts.

func (*MockMetadataStoreMockRecorder) GetAllObjectLocations

func (mr *MockMetadataStoreMockRecorder) GetAllObjectLocations(ctx, key any) *gomock.Call

GetAllObjectLocations indicates an expected call of GetAllObjectLocations.

func (*MockMetadataStoreMockRecorder) GetBackendWithSpace

func (mr *MockMetadataStoreMockRecorder) GetBackendWithSpace(ctx, size, backendOrder any) *gomock.Call

GetBackendWithSpace indicates an expected call of GetBackendWithSpace.

func (*MockMetadataStoreMockRecorder) GetLeastUtilizedBackend

func (mr *MockMetadataStoreMockRecorder) GetLeastUtilizedBackend(ctx, size, eligible any) *gomock.Call

GetLeastUtilizedBackend indicates an expected call of GetLeastUtilizedBackend.

func (*MockMetadataStoreMockRecorder) GetMultipartUpload

func (mr *MockMetadataStoreMockRecorder) GetMultipartUpload(ctx, uploadID any) *gomock.Call

GetMultipartUpload indicates an expected call of GetMultipartUpload.

func (*MockMetadataStoreMockRecorder) GetMultipartUploadsByBackend

func (mr *MockMetadataStoreMockRecorder) GetMultipartUploadsByBackend(ctx, backendName any) *gomock.Call

GetMultipartUploadsByBackend indicates an expected call of GetMultipartUploadsByBackend.

func (*MockMetadataStoreMockRecorder) GetObjectBackendsForKeys

func (mr *MockMetadataStoreMockRecorder) GetObjectBackendsForKeys(ctx, keys any) *gomock.Call

GetObjectBackendsForKeys indicates an expected call of GetObjectBackendsForKeys.

func (*MockMetadataStoreMockRecorder) GetObjectCounts

func (mr *MockMetadataStoreMockRecorder) GetObjectCounts(ctx any) *gomock.Call

GetObjectCounts indicates an expected call of GetObjectCounts.

func (*MockMetadataStoreMockRecorder) GetObjectsWithoutHash

func (mr *MockMetadataStoreMockRecorder) GetObjectsWithoutHash(ctx, limit, offset any) *gomock.Call

GetObjectsWithoutHash indicates an expected call of GetObjectsWithoutHash.

func (*MockMetadataStoreMockRecorder) GetOverReplicatedObjects

func (mr *MockMetadataStoreMockRecorder) GetOverReplicatedObjects(ctx, factor, limit any) *gomock.Call

GetOverReplicatedObjects indicates an expected call of GetOverReplicatedObjects.

func (*MockMetadataStoreMockRecorder) GetParts

func (mr *MockMetadataStoreMockRecorder) GetParts(ctx, uploadID any) *gomock.Call

GetParts indicates an expected call of GetParts.

func (*MockMetadataStoreMockRecorder) GetPendingCleanups

func (mr *MockMetadataStoreMockRecorder) GetPendingCleanups(ctx, limit any) *gomock.Call

GetPendingCleanups indicates an expected call of GetPendingCleanups.

func (*MockMetadataStoreMockRecorder) GetPendingNotifications

func (mr *MockMetadataStoreMockRecorder) GetPendingNotifications(ctx, limit any) *gomock.Call

GetPendingNotifications indicates an expected call of GetPendingNotifications.

func (*MockMetadataStoreMockRecorder) GetQuotaStats

func (mr *MockMetadataStoreMockRecorder) GetQuotaStats(ctx any) *gomock.Call

GetQuotaStats indicates an expected call of GetQuotaStats.

func (*MockMetadataStoreMockRecorder) GetRandomHashedObjects

func (mr *MockMetadataStoreMockRecorder) GetRandomHashedObjects(ctx, limit any) *gomock.Call

GetRandomHashedObjects indicates an expected call of GetRandomHashedObjects.

func (*MockMetadataStoreMockRecorder) GetStaleMultipartUploads

func (mr *MockMetadataStoreMockRecorder) GetStaleMultipartUploads(ctx, olderThan any) *gomock.Call

GetStaleMultipartUploads indicates an expected call of GetStaleMultipartUploads.

func (*MockMetadataStoreMockRecorder) GetStalePending

func (mr *MockMetadataStoreMockRecorder) GetStalePending(ctx, olderThan, limit any) *gomock.Call

GetStalePending indicates an expected call of GetStalePending.

func (*MockMetadataStoreMockRecorder) GetUnderReplicatedObjects

func (mr *MockMetadataStoreMockRecorder) GetUnderReplicatedObjects(ctx, factor, limit any) *gomock.Call

GetUnderReplicatedObjects indicates an expected call of GetUnderReplicatedObjects.

func (*MockMetadataStoreMockRecorder) GetUnderReplicatedObjectsExcluding

func (mr *MockMetadataStoreMockRecorder) GetUnderReplicatedObjectsExcluding(ctx, factor, limit, excludedBackends any) *gomock.Call

GetUnderReplicatedObjectsExcluding indicates an expected call of GetUnderReplicatedObjectsExcluding.

func (*MockMetadataStoreMockRecorder) GetUnverifiedObjectCounts

func (mr *MockMetadataStoreMockRecorder) GetUnverifiedObjectCounts(ctx any) *gomock.Call

GetUnverifiedObjectCounts indicates an expected call of GetUnverifiedObjectCounts.

func (*MockMetadataStoreMockRecorder) GetUsageForPeriod

func (mr *MockMetadataStoreMockRecorder) GetUsageForPeriod(ctx, period any) *gomock.Call

GetUsageForPeriod indicates an expected call of GetUsageForPeriod.

func (*MockMetadataStoreMockRecorder) ImportObject

func (mr *MockMetadataStoreMockRecorder) ImportObject(ctx, key, backend, size any) *gomock.Call

ImportObject indicates an expected call of ImportObject.

func (*MockMetadataStoreMockRecorder) IncrementOrphanBytes

func (mr *MockMetadataStoreMockRecorder) IncrementOrphanBytes(ctx, backendName, amount any) *gomock.Call

IncrementOrphanBytes indicates an expected call of IncrementOrphanBytes.

func (*MockMetadataStoreMockRecorder) InsertNotification

func (mr *MockMetadataStoreMockRecorder) InsertNotification(ctx, eventType, payload, endpointURL any) *gomock.Call

InsertNotification indicates an expected call of InsertNotification.

func (*MockMetadataStoreMockRecorder) InsertPending

func (mr *MockMetadataStoreMockRecorder) InsertPending(ctx, p any) *gomock.Call

InsertPending indicates an expected call of InsertPending.

func (*MockMetadataStoreMockRecorder) ListAllEncryptedLocations

func (mr *MockMetadataStoreMockRecorder) ListAllEncryptedLocations(ctx, limit, offset any) *gomock.Call

ListAllEncryptedLocations indicates an expected call of ListAllEncryptedLocations.

func (*MockMetadataStoreMockRecorder) ListDirectoryChildren

func (mr *MockMetadataStoreMockRecorder) ListDirectoryChildren(ctx, prefix, startAfter, maxKeys any) *gomock.Call

ListDirectoryChildren indicates an expected call of ListDirectoryChildren.

func (*MockMetadataStoreMockRecorder) ListEncryptedLocations

func (mr *MockMetadataStoreMockRecorder) ListEncryptedLocations(ctx, keyID, limit, offset any) *gomock.Call

ListEncryptedLocations indicates an expected call of ListEncryptedLocations.

func (*MockMetadataStoreMockRecorder) ListExpiredObjects

func (mr *MockMetadataStoreMockRecorder) ListExpiredObjects(ctx, prefix, cutoff, limit any) *gomock.Call

ListExpiredObjects indicates an expected call of ListExpiredObjects.

func (*MockMetadataStoreMockRecorder) ListMultipartUploads

func (mr *MockMetadataStoreMockRecorder) ListMultipartUploads(ctx, prefix, maxUploads any) *gomock.Call

ListMultipartUploads indicates an expected call of ListMultipartUploads.

func (*MockMetadataStoreMockRecorder) ListObjects

func (mr *MockMetadataStoreMockRecorder) ListObjects(ctx, prefix, startAfter, maxKeys any) *gomock.Call

ListObjects indicates an expected call of ListObjects.

func (*MockMetadataStoreMockRecorder) ListObjectsByBackend

func (mr *MockMetadataStoreMockRecorder) ListObjectsByBackend(ctx, backendName, limit any) *gomock.Call

ListObjectsByBackend indicates an expected call of ListObjectsByBackend.

func (*MockMetadataStoreMockRecorder) ListObjectsByBackendKeyAsc

func (mr *MockMetadataStoreMockRecorder) ListObjectsByBackendKeyAsc(ctx, backendName, afterKey, limit any) *gomock.Call

ListObjectsByBackendKeyAsc indicates an expected call of ListObjectsByBackendKeyAsc.

func (*MockMetadataStoreMockRecorder) ListUnencryptedLocations

func (mr *MockMetadataStoreMockRecorder) ListUnencryptedLocations(ctx, limit, offset any) *gomock.Call

ListUnencryptedLocations indicates an expected call of ListUnencryptedLocations.

func (*MockMetadataStoreMockRecorder) MarkObjectDecrypted

func (mr *MockMetadataStoreMockRecorder) MarkObjectDecrypted(ctx, objectKey, backendName, plaintextSize any) *gomock.Call

MarkObjectDecrypted indicates an expected call of MarkObjectDecrypted.

func (*MockMetadataStoreMockRecorder) MarkObjectEncrypted

func (mr *MockMetadataStoreMockRecorder) MarkObjectEncrypted(ctx, objectKey, backendName, encryptionKey, keyID, plaintextSize, ciphertextSize any) *gomock.Call

MarkObjectEncrypted indicates an expected call of MarkObjectEncrypted.

func (*MockMetadataStoreMockRecorder) MoveCleanupToDLQ

func (mr *MockMetadataStoreMockRecorder) MoveCleanupToDLQ(ctx, id, lastError any) *gomock.Call

MoveCleanupToDLQ indicates an expected call of MoveCleanupToDLQ.

func (*MockMetadataStoreMockRecorder) MoveObjectLocation

func (mr *MockMetadataStoreMockRecorder) MoveObjectLocation(ctx, key, fromBackend, toBackend any) *gomock.Call

MoveObjectLocation indicates an expected call of MoveObjectLocation.

func (*MockMetadataStoreMockRecorder) PendingDepth

func (mr *MockMetadataStoreMockRecorder) PendingDepth(ctx any) *gomock.Call

PendingDepth indicates an expected call of PendingDepth.

func (*MockMetadataStoreMockRecorder) PromotePending

func (mr *MockMetadataStoreMockRecorder) PromotePending(ctx, p any) *gomock.Call

PromotePending indicates an expected call of PromotePending.

func (*MockMetadataStoreMockRecorder) RecordObject

func (mr *MockMetadataStoreMockRecorder) RecordObject(ctx, key, backend, size, enc any) *gomock.Call

RecordObject indicates an expected call of RecordObject.

func (*MockMetadataStoreMockRecorder) RecordObjectAndClearPending

func (mr *MockMetadataStoreMockRecorder) RecordObjectAndClearPending(ctx, key, backend, size, enc, intentID any) *gomock.Call

RecordObjectAndClearPending indicates an expected call of RecordObjectAndClearPending.

func (*MockMetadataStoreMockRecorder) RecordPart

func (mr *MockMetadataStoreMockRecorder) RecordPart(ctx, uploadID, partNumber, etag, size, enc any) *gomock.Call

RecordPart indicates an expected call of RecordPart.

func (*MockMetadataStoreMockRecorder) RecordReplica

func (mr *MockMetadataStoreMockRecorder) RecordReplica(ctx, key, targetBackend, sourceBackend any) *gomock.Call

RecordReplica indicates an expected call of RecordReplica.

func (*MockMetadataStoreMockRecorder) RemoveExcessCopy

func (mr *MockMetadataStoreMockRecorder) RemoveExcessCopy(ctx, key, backendName, size any) *gomock.Call

RemoveExcessCopy indicates an expected call of RemoveExcessCopy.

func (*MockMetadataStoreMockRecorder) RetryCleanupItem

func (mr *MockMetadataStoreMockRecorder) RetryCleanupItem(ctx, id, backoff, lastError any) *gomock.Call

RetryCleanupItem indicates an expected call of RetryCleanupItem.

func (*MockMetadataStoreMockRecorder) RetryNotification

func (mr *MockMetadataStoreMockRecorder) RetryNotification(ctx, id, backoff, lastError any) *gomock.Call

RetryNotification indicates an expected call of RetryNotification.

func (*MockMetadataStoreMockRecorder) RunMigrations

func (mr *MockMetadataStoreMockRecorder) RunMigrations(ctx any) *gomock.Call

RunMigrations indicates an expected call of RunMigrations.

func (*MockMetadataStoreMockRecorder) SweepStaleCleanupQueueRows

func (mr *MockMetadataStoreMockRecorder) SweepStaleCleanupQueueRows(ctx, key, backend any) *gomock.Call

SweepStaleCleanupQueueRows indicates an expected call of SweepStaleCleanupQueueRows.

func (*MockMetadataStoreMockRecorder) SyncQuotaLimits

func (mr *MockMetadataStoreMockRecorder) SyncQuotaLimits(ctx, backends any) *gomock.Call

SyncQuotaLimits indicates an expected call of SyncQuotaLimits.

func (*MockMetadataStoreMockRecorder) UpdateContentHash

func (mr *MockMetadataStoreMockRecorder) UpdateContentHash(ctx, key, backendName, hash any) *gomock.Call

UpdateContentHash indicates an expected call of UpdateContentHash.

func (*MockMetadataStoreMockRecorder) UpdateEncryptionKey

func (mr *MockMetadataStoreMockRecorder) UpdateEncryptionKey(ctx, objectKey, backendName, newEncryptionKey, newKeyID any) *gomock.Call

UpdateEncryptionKey indicates an expected call of UpdateEncryptionKey.

func (*MockMetadataStoreMockRecorder) VerifySchemaVersion

func (mr *MockMetadataStoreMockRecorder) VerifySchemaVersion(ctx any) *gomock.Call

VerifySchemaVersion indicates an expected call of VerifySchemaVersion.

func (*MockMetadataStoreMockRecorder) WithAdvisoryLock

func (mr *MockMetadataStoreMockRecorder) WithAdvisoryLock(ctx, lockID, fn any) *gomock.Call

WithAdvisoryLock indicates an expected call of WithAdvisoryLock.

Generated by gomarkdoc