tasks

type BucketCreatePayload struct {
	Bucket   string
	Location string
	// contains filtered or unexported fields
}

type BucketDeletePayload struct {
	Bucket string
	// contains filtered or unexported fields
}

type BucketSyncACLPayload struct {
	Bucket string
	// contains filtered or unexported fields
}

type BucketSyncTagsPayload struct {
	Bucket string
	// contains filtered or unexported fields
}

type ConsistencyCheckListObjectsPayload struct {
	User        string
	Prefix      string
	Locations   []MigrateLocation
	Index       int
	Versioned   bool
	IgnoreEtags bool
	IgnoreSizes bool
}

type ConsistencyCheckListVersionsPayload struct {
	User         string
	Prefix       string
	Locations    []MigrateLocation
	Index        int
	IgonoreEtags bool
	IgnoreSizes  bool
}

type ConsistencyCheckPayload struct {
	User        string
	Locations   []MigrateLocation
	Versioned   bool
	IgnoreEtags bool
	IgnoreSizes bool
}

type ListObjectVersionsPayload struct {
	Bucket string
	Prefix string
	// contains filtered or unexported fields
}

type MigrateBucketListObjectsPayload struct {
	Bucket    string
	Prefix    string
	Versioned bool
	// contains filtered or unexported fields
}

type MigrateLocation struct {
	Storage string
	Bucket  string
}

type MigrateObjCopyPayload struct {
	Bucket string
	Obj    ObjPayload
	// contains filtered or unexported fields
}

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

type MigrateVersionedObjectPayload struct {
	Bucket string
	Prefix string
	// contains filtered or unexported fields
}

type ObjInfo struct {
	Name      string
	VersionID string
}

type ObjPayload struct {
	Name        string
	VersionID   string
	ETag        string
	ContentType string
	Size        int64
}

type ObjSyncACLPayload struct {
	Object dom.Object
	// contains filtered or unexported fields
}

type ObjSyncTagsPayload struct {
	Object dom.Object
	// contains filtered or unexported fields
}

type ObjectSyncPayload struct {
	Object dom.Object

	//FromVersion int64
	ObjSize int64
	Deleted bool
	// contains filtered or unexported fields
}

type Queue string

type QueueService interface {
	UnprocessedCount(ctx context.Context, ignoreNotFound bool, queues ...string) (int, error)
	IsPaused(ctx context.Context, queueName string) (bool, error)
	Resume(ctx context.Context, queueName string) error
	Pause(ctx context.Context, queueName string) error
	Delete(ctx context.Context, queueName string, force bool) error
	Stats(ctx context.Context, queueName string) (*QueueStats, error)
	EnqueueTask(ctx context.Context, task any) error
}

type QueueServiceMock struct {
	Queues map[string]int
	Paused map[string]bool
}

type QueueStats struct {
	// Number of tasks to be processed in the queue.
	// Includes includes in_progress, not_started, and retied tasks.
	// In other words, all tasks except failed and processed tasks.
	Unprocessed int
	// Total number of tasks processed.
	ProcessedTotal int

	// Paused indicates whether the queue is paused.
	// If true, tasks in the queue will not be processed.
	Paused bool

	// Total number of bytes that the queue and its tasks require to be stored in redis.
	// It is an approximate memory usage value in bytes since the value is computed by sampling.
	MemoryUsage int64

	// Latency of the queue, measured by the oldest pending task in the queue.
	Latency time.Duration
}

type ReplicationTask interface {
	SetReplicationID(id entity.UniversalReplicationID)
	GetReplicationID() entity.UniversalReplicationID
}

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

type SwiftAccountUpdatePayload struct {

	// Date of the server response. Not Account modification date, so it cannot be
	// compared with Last-modified directly, but can be used as a reference
	// because Openstack Swift does not return Last-Modified for Account Updates
	Date string
	// contains filtered or unexported fields
}

type SwiftContainerMigrationPayload struct {
	Bucket string
	// contains filtered or unexported fields
}

type SwiftContainerUpdatePayload struct {
	Bucket string
	// Date of the server response. Not Container modification date, so it cannot be
	// compared with Last-modified directly, but can be used as a reference
	// because Openstack Swift does not return Last-Modified for Container Updates
	Date string
	// contains filtered or unexported fields
}

type SwiftObjectDeletePayload struct {
	Bucket    string
	Object    string
	VersionID string
	// Date of the server response. Not Object deletion date, so it cannot be
	// compared with Last-modified directly, but can be used as a reference
	// because Openstack Swift does not return Last-Modified for Object delete
	Date            string
	DeleteMultipart bool
	// contains filtered or unexported fields
}

type SwiftObjectMetaUpdatePayload struct {
	Bucket string
	Object string
	// Date of the server response. Not Object modification date, so it cannot be
	// compared with Last-modified directly, but can be used as a reference
	// because Openstack Swift does not return Last-Modified for Object Meta Updates
	Date string
	// contains filtered or unexported fields
}

type SwiftObjectMigrationPayload struct {
	Bucket          string
	ObjName         string
	ObjVersion      string
	ObjEtag         string
	ObjLastModified string
	ObjSize         int64
	// contains filtered or unexported fields
}

type SwiftObjectUpdatePayload struct {
	Bucket       string
	Object       string
	VersionID    string
	Etag         string
	LastModified string
	// contains filtered or unexported fields
}

type SwitchWithDowntimePayload struct {
	ID entity.UniversalReplicationID
}

type TaskPayload interface {
	BucketCreatePayload |
		BucketDeletePayload |
		BucketSyncTagsPayload |
		BucketSyncACLPayload |
		ObjectSyncPayload |
		ObjSyncTagsPayload |
		ObjSyncACLPayload |
		MigrateS3UserPayload |
		MigrateBucketListObjectsPayload |
		MigrateObjCopyPayload |
		ListObjectVersionsPayload |
		MigrateVersionedObjectPayload |
		ZeroDowntimeReplicationSwitchPayload |
		SwitchWithDowntimePayload |
		SwiftAccountUpdatePayload |
		SwiftContainerUpdatePayload |
		SwiftObjectMetaUpdatePayload |
		SwiftObjectUpdatePayload |
		SwiftObjectDeletePayload |
		SwiftAccountMigrationPayload |
		SwiftContainerMigrationPayload |
		SwiftObjectMigrationPayload |
		ConsistencyCheckPayload |
		ConsistencyCheckListObjectsPayload |
		ConsistencyCheckListVersionsPayload
}

type ZeroDowntimeReplicationSwitchPayload struct {
	ID entity.UniversalReplicationID
}