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 ConsistencyCheckID struct {
	Locations []ConsistencyCheckLocation
}

type ConsistencyCheckLocation struct {
	Storage string
	Bucket  string
}

type ConsistencyCheckObjectID struct {
	Storage            string
	Prefix             string
	ConsistencyCheckID ConsistencyCheckID
}

type ConsistencyCheckReportEntry struct {
	Object         string
	Etag           string
	StorageEntries []ConsistencyCheckSetEntry
	Size           uint64
	VersionIndex   uint64
}

type ConsistencyCheckReportEntryPage struct {
	Entries []ConsistencyCheckReportEntry
	Cursor  uint64
}

type ConsistencyCheckSetEntry struct {
	Location  ConsistencyCheckLocation
	VersionID string
}

type ConsistencyCheckSetID struct {
	Object             string
	Etag               string
	ConsistencyCheckID ConsistencyCheckID
	Size               uint64
	VersionIndex       uint64
}

type ConsistencyCheckSettings struct {
	Versioned bool
	WithSize  bool
	WithEtag  bool
}

type ConsistencyCheckStatus struct {
	Locations  []ConsistencyCheckLocation
	Queued     uint64
	Completed  uint64
	Ready      bool
	Consistent bool
	ConsistencyCheckSettings
}

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

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 ReplicationStatus struct {
	CreatedAt time.Time `redis:"created_at"`

	ArchivedAt *time.Time `redis:"archived_at,omitempty"`
	AgentURL   string     `redis:"agent_url,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 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 VersionedObjectID struct {
	Storage string
	Bucket  string
	Name    string
}