Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsistencyCheckObject ¶ added in v0.5.14
type ConsistencyCheckRecord ¶ added in v0.5.14
type ConsistencyCheckResultEntry ¶ added in v0.5.14
type ConsistencyCheckResultPage ¶ added in v0.5.14
type ConsistencyCheckResultPage struct {
Entries []ConsistencyCheckResultEntry
Cursor uint64
}
type Service ¶
type Service interface {
GetLastListedObj(ctx context.Context, task tasks.MigrateBucketListObjectsPayload) (string, error)
SetLastListedObj(ctx context.Context, task tasks.MigrateBucketListObjectsPayload, val string) error
DelLastListedObj(ctx context.Context, task tasks.MigrateBucketListObjectsPayload) error
CleanLastListedObj(ctx context.Context, fromStor, toStor, fromBucket string, toBucket *string) error
StoreUploadID(ctx context.Context, user, bucket, object, uploadID string, ttl time.Duration) error
DeleteUploadID(ctx context.Context, user, bucket, object, uploadID string) error
ExistsUploadID(ctx context.Context, user, bucket, object, uploadID string) (bool, error)
ExistsUploads(ctx context.Context, user, bucket string) (bool, error)
GetLastListedConsistencyCheckObj(ctx context.Context, obj *ConsistencyCheckObject) (string, error)
SetLastListedConsistencyCheckObj(ctx context.Context, obj *ConsistencyCheckObject, value string) error
DeleteLastListedConsistencyCheckObj(ctx context.Context, obj *ConsistencyCheckObject) error
DeleteAllLastListedConsistencyCheckObj(ctx context.Context, id string) error
IncrementConsistencyCheckScheduledCounter(ctx context.Context, id string, count int64) error
IncrementConsistencyCheckCompletedCounter(ctx context.Context, id string, count int64) error
DecrementConsistencyCheckScheduledCounter(ctx context.Context, id string, count int64) error
DecrementConsistencyCheckCompletedCounter(ctx context.Context, id string, count int64) error
GetConsistencyCheckScheduledCounter(ctx context.Context, id string) (uint64, error)
GetConsistencyCheckCompletedCounter(ctx context.Context, id string) (uint64, error)
DeleteConsistencyCheckScheduledCounter(ctx context.Context, id string) error
DeleteConsistencyCheckCompletedCounter(ctx context.Context, id string) error
StoreConsistencyCheckID(ctx context.Context, id string) error
DeleteConsistencyCheckID(ctx context.Context, id string) error
ListConsistencyCheckIDs(ctx context.Context) ([]string, error)
AddToConsistencyCheckSet(ctx context.Context, record *ConsistencyCheckRecord) error
FindConsistencyCheckSets(ctx context.Context, id string) ([]ConsistencyCheckResultEntry, error)
FindConsistencyCheckSetsPageable(ctx context.Context, id string, cursor uint64, pageSize int64) (*ConsistencyCheckResultPage, error)
HasConsistencyCheckSets(ctx context.Context, id string) (bool, error)
DeleteAllConsistencyCheckSets(ctx context.Context, id string) error
SetConsistencyCheckReadiness(ctx context.Context, id string, ready bool) error
GetConsistencyCheckReadiness(ctx context.Context, id string) (bool, error)
DeleteConsistencyCheckReadiness(ctx context.Context, id string) error
SetConsistencyCheckStorages(ctx context.Context, id string, storages []string) error
GetConsistencyCheckStorages(ctx context.Context, id string) ([]string, error)
DeleteConsistencyCheckStorages(ctx context.Context, id string) error
}
func New ¶
func New(client redis.UniversalClient) Service
Click to show internal directories.
Click to hide internal directories.