entity

type BucketLockID struct {
	Storage string
	Bucket  string
}

type BucketReplicationPolicy struct {
	User        string
	FromStorage string
	FromBucket  string
	ToStorage   string
	ToBucket    string
}

type BucketReplicationPolicyDestination struct {
	ToStorage string
	ToBucket  string
}

type BucketReplicationPolicyID struct {
	User       string
	FromBucket string
}

type BucketRoutingPolicyID struct {
	User   string
	Bucket string
}

type DiffCheckStatus struct {
	Settings   DiffSettings
	Queue      DiffQueueStatus
	Consistent bool
}

type DiffFixCopyObject struct {
	Name  string
	IsDir bool
}

type DiffFixID struct {
	Destination string
	DiffID      DiffID
}

type DiffID struct {
	Locations []DiffLocation
}

type DiffLocation struct {
	Storage string
	Bucket  string
}

type DiffObjectID struct {
	Storage string
	Prefix  string
	DiffID  DiffID
}

type DiffQueueStatus struct {
	Queued    uint64
	Completed uint64
	Ready     bool
}

type DiffReportEntry struct {
	Object         string
	Etag           string
	StorageEntries []DiffSetEntry
	Size           uint64
	VersionIndex   uint64
}

type DiffReportEntryPage struct {
	Entries []DiffReportEntry
	Cursor  uint64
}

type DiffSetEntry struct {
	Location  DiffLocation
	VersionID string
	IsDir     bool
}

type DiffSetID struct {
	Object       string
	Etag         string
	DiffID       DiffID
	Size         uint64
	VersionIndex uint64
}

type DiffSettings struct {
	User        string
	Versioned   bool
	IgnoreEtags bool
	IgnoreSizes bool
}

type DiffStatus struct {
	FixQueue  *DiffQueueStatus
	Locations []DiffLocation
	Check     DiffCheckStatus
}

type MigrationBucketID struct {
	User        string
	FromStorage string
	ToStorage   string
	FromBucket  string
	ToBucket    string
}

type MigrationObjectID struct {
	User        string
	FromStorage string
	ToStorage   string
	FromBucket  string
	ToBucket    string
	Prefix      string
}

type ObjectLockID struct {
	Storage string
	Bucket  string
	Name    string
	Version string
}

type ObjectVersionInfo struct {
	Version      string
	Size         uint64
	DeleteMarker bool
}

type QueueStats struct {
	// Number of tasks left. Includes, new, in_progress, and retried tasks.
	Unprocessed int
	// Total number of successfully processed tasks.
	Done int
	// Age of the oldest pending task in the queue.
	Latency time.Duration
	// Approx bytes used by the queue and its tasks in Redis.
	MemoryUsage int64
}

type ReplicationOptions struct {
	AgentURL    string
	EventSource dom.EventSource
}

type ReplicationStatus struct {
	CreatedAt time.Time `redis:"created_at"`

	ArchivedAt *time.Time `redis:"archived_at,omitempty"`

	// Options belongs to status to store in the same hash in Redis.
	// Embedded stucts are not supported by redis tag parser.
	// TODO: add other replication options here, like copy origin timestamp, etc.
	AgentURL    string `redis:"agent_url,omitempty"`
	EventSource string `redis:"event_source,omitempty"`

	IsArchived bool `redis:"archived"`
}

type ReplicationStatusExtended struct {
	*ReplicationStatus

	Switch *ReplicationSwitchInfo `redis:"-"`

	// True if at least one of the queues is paused.
	IsPaused bool
	// Aggregated stats for initial migration list buckets/object tasks.
	InitMigrationListing QueueStats
	// Aggregated stats for initial migration queues.
	InitMigration QueueStats
	// Aggregated stats for event migration queues.
	EventMigration QueueStats
}

type ReplicationSwitchDowntimeOpts struct {
	Cron                *string       `redis:"cron,omitempty"`
	StartAt             *time.Time    `redis:"startAt,omitempty"`
	MaxEventLag         *uint32       `redis:"maxEventLag,omitempty"`
	MaxDuration         time.Duration `redis:"maxDuration,omitempty"`
	StartOnInitDone     bool          `redis:"onInitDone"`
	SkipBucketCheck     bool          `redis:"skipBucketCheck,omitempty"`
	ContinueReplication bool          `redis:"continueReplication,omitempty"`
}

type ReplicationSwitchInfo struct {
	// Time of switch creation
	CreatedAt time.Time `redis:"createdAt"`
	// Time of last switch was in progress
	LastStartedAt *time.Time `redis:"startedAt,omitempty"`
	// Time of last switch was done
	DoneAt *time.Time `redis:"doneAt,omitempty"`
	// Options for downtime switch
	ReplicationSwitchDowntimeOpts
	// ID of replication policy of this switch
	ReplicationIDStr string `redis:"replicationID"`
	// Last status of switch
	LastStatus ReplicationSwitchStatus `redis:"lastStatus,omitempty"`
	// History of switch status changes
	History []string `redis:"-"`
	// Options for zero downtime switch
	ReplicationSwitchZeroDowntimeOpts
}

type ReplicationSwitchStatus string

type ReplicationSwitchZeroDowntimeOpts struct {
	MultipartTTL time.Duration `redis:"multipartTTL,omitempty"`
}

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

type UserReplicationPolicy struct {
	User        string
	FromStorage string
	ToStorage   string
}

type UserUploadObject struct {
	Object   string
	UploadID string
}

type UserUploadObjectID struct {
	User   string
	Bucket string
}

type VersionedObjectID struct {
	Storage string
	Bucket  string
	Name    string
}