meta

type Destination struct {
	Storage string
	Bucket  string
}

type MigrationCostService interface {
	GetMigrationCosts(ctx context.Context, from, to string) (MigrationCosts, error)
	MigrationCostsDelete(ctx context.Context, from, to string) error
	MigrationCostsStart(ctx context.Context, from, to string) error
	MigrationCostsIncBucket(ctx context.Context, from, to string) error
	MigrationCostsIncObj(ctx context.Context, from, to string) error
	MigrationCostsIncSize(ctx context.Context, from, to string, size int64) error
	MigrationCostsLastObjSet(ctx context.Context, from, to, bucket, prefix, object string) error
	MigrationCostsLastObjGet(ctx context.Context, from, to, bucket, prefix string) (string, error)
	MigrationCostsIncJob(ctx context.Context, from, to string) error
	MigrationCostsIncJobDone(ctx context.Context, from, to string) error
}

type MigrationCosts interface {
	Done() bool
	BucketsNum() int64
	ObjectsNum() int64
	ObjectsSize() int64
	StartedAt() *time.Time

	String() string
}

type Version struct {
	From int
	To   int
}

type VersionService interface {
	Cleanup(ctx context.Context, replID entity.UniversalReplicationID) error

	GetObj(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object) (Version, error)
	IncrementObj(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination) (int, error)
	UpdateIfGreater(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination, version int) error
	DeleteObjAll(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object) error

	GetACL(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object) (Version, error)
	IncrementACL(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination) (int, error)
	UpdateACLIfGreater(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination, version int) error

	GetTags(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object) (Version, error)
	IncrementTags(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination) (int, error)
	UpdateTagsIfGreater(ctx context.Context, replID entity.UniversalReplicationID, obj dom.Object, dest Destination, version int) error

	GetBucket(ctx context.Context, replID entity.UniversalReplicationID, bucket string) (Version, error)
	IncrementBucket(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination) (int, error)
	UpdateBucketIfGreater(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination, version int) error
	DeleteBucketAll(ctx context.Context, replID entity.UniversalReplicationID, bucket string) error

	GetBucketACL(ctx context.Context, replID entity.UniversalReplicationID, bucket string) (Version, error)
	IncrementBucketACL(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination) (int, error)
	UpdateBucketACLIfGreater(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination, version int) error

	GetBucketTags(ctx context.Context, replID entity.UniversalReplicationID, bucket string) (Version, error)
	IncrementBucketTags(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination) (int, error)
	UpdateBucketTagsIfGreater(ctx context.Context, replID entity.UniversalReplicationID, bucket string, dest Destination, version int) error
}