entity

package

Go to main page

Versions in this module

v0

v0.7.2

Feb 20, 2026

Changes in this version

type ReplicationOptions

+ EventSource dom.EventSource

type ReplicationStatus

+ EventSource string

v0.7.1

Feb 5, 2026

v0.7.0

Jan 27, 2026

Changes in this version

+ type MigrationBucketID struct

+ FromBucket string

+ FromStorage string

+ ToBucket string

+ ToStorage string

+ User string

+ func NewMigrationBucketIDFromUniversalReplicationID(replicationID UniversalReplicationID) MigrationBucketID

+ type MigrationObjectID struct

+ FromBucket string

+ FromStorage string

+ Prefix string

+ ToBucket string

+ ToStorage string

+ User string

+ func NewMigrationObjectID(user string, fromStorage string, fromBucket string, toStorage string, ...) MigrationObjectID

+ func NewMigrationObjectIDFromUniversalReplicationID(replicationID UniversalReplicationID, bucket string, prefix string) MigrationObjectID

+ func NewNonRecursiveMigrationObjectIDFromUniversalReplicationID(replicationID UniversalReplicationID, bucket string) MigrationObjectID

+ type ObjectVersionInfo struct

+ Size uint64

+ Version string

+ type ReplicationOptions struct

+ AgentURL string

type ReplicationStatus

+ func StatusFromOptions(opts ReplicationOptions) ReplicationStatus

type ReplicationStatusExtended

+ InitMigrationListing QueueStats

+ func (r *ReplicationStatusExtended) Latency() time.Duration

+ type UserUploadObject struct

+ Object string

+ UploadID string

+ func NewUserUploadObject(object string, uploadID string) UserUploadObject

+ type UserUploadObjectID struct

+ Bucket string

+ User string

+ func NewUserUploadObjectID(user string, bucket string) UserUploadObjectID

v0.6.0

Oct 15, 2025

Changes in this version

+ var TimeNow = time.Now

+ type BucketLockID struct

+ Bucket string

+ Storage string

+ func NewBucketLockID(storage string, bucket string) BucketLockID

+ type BucketReplicationPolicy struct

+ FromBucket string

+ FromStorage string

+ ToBucket string

+ ToStorage string

+ User string

+ func NewBucketRepliationPolicy(user string, fromStorage string, fromBucket string, toStorage string, ...) BucketReplicationPolicy

+ func (p BucketReplicationPolicy) Destination() BucketReplicationPolicyDestination

+ func (p BucketReplicationPolicy) LookupID() BucketReplicationPolicyID

+ func (p BucketReplicationPolicy) RoutingID() BucketRoutingPolicyID

+ func (p BucketReplicationPolicy) Validate() error

+ type BucketReplicationPolicyDestination struct

+ ToBucket string

+ ToStorage string

+ type BucketReplicationPolicyID struct

+ FromBucket string

+ User string

+ func NewBucketReplicationPolicyID(user string, fromBucket string) BucketReplicationPolicyID

+ type BucketRoutingPolicyID struct

+ Bucket string

+ User string

+ func NewBucketRoutingPolicyID(user string, bucket string) BucketRoutingPolicyID

+ type ConsistencyCheckID struct

+ Locations []ConsistencyCheckLocation

+ func NewConsistencyCheckID(locations ...ConsistencyCheckLocation) ConsistencyCheckID

+ type ConsistencyCheckLocation struct

+ Bucket string

+ Storage string

+ func NewConsistencyCheckLocation(storage string, bucket string) ConsistencyCheckLocation

+ type ConsistencyCheckObjectID struct

+ ConsistencyCheckID ConsistencyCheckID

+ Prefix string

+ Storage string

+ func NewConsistencyCheckObjectID(consistencyCheckID ConsistencyCheckID, storage string, prefix string) ConsistencyCheckObjectID

+ type ConsistencyCheckReportEntry struct

+ Etag string

+ Object string

+ Size uint64

+ StorageEntries []ConsistencyCheckSetEntry

+ VersionIndex uint64

+ func NewConsistencyCheckReportEntry(object string, versionIndex uint64, size uint64, etag string, ...) ConsistencyCheckReportEntry

+ type ConsistencyCheckReportEntryPage struct

+ Cursor uint64

+ Entries []ConsistencyCheckReportEntry

+ func NewConsistencyCheckReportEntryPage(entries []ConsistencyCheckReportEntry, cursor uint64) ConsistencyCheckReportEntryPage

+ type ConsistencyCheckSetEntry struct

+ Location ConsistencyCheckLocation

+ VersionID string

+ func NewConsistencyCheckSetEntry(location ConsistencyCheckLocation) ConsistencyCheckSetEntry

+ func NewVersionedConsistencyCheckSetEntry(location ConsistencyCheckLocation, versionID string) ConsistencyCheckSetEntry

+ type ConsistencyCheckSetID struct

+ ConsistencyCheckID ConsistencyCheckID

+ Etag string

+ Object string

+ Size uint64

+ VersionIndex uint64

+ func NewEtagConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string, size uint64, etag string) ConsistencyCheckSetID

+ func NewNameConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string) ConsistencyCheckSetID

+ func NewSizeConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string, size uint64) ConsistencyCheckSetID

+ func NewVersionedEtagConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string, versionIndex uint64, ...) ConsistencyCheckSetID

+ func NewVersionedNameConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string, versionIndex uint64) ConsistencyCheckSetID

+ func NewVersionedSizeConsistencyCheckSetID(consistencyCheckID ConsistencyCheckID, object string, versionIndex uint64, ...) ConsistencyCheckSetID

+ type ConsistencyCheckSettings struct

+ Versioned bool

+ WithEtag bool

+ WithSize bool

+ func NewConsistencyCheckSettings(versioned bool, withSize bool, withEtag bool) ConsistencyCheckSettings

+ type ConsistencyCheckStatus struct

+ Completed uint64

+ Consistent bool

+ Locations []ConsistencyCheckLocation

+ Queued uint64

+ Ready bool

+ type ObjectLockID struct

+ Bucket string

+ Name string

+ Storage string

+ Version string

+ func NewObjectLockID(storage string, bucket string, name string) ObjectLockID

+ func NewVersionedObjectLockID(storage string, bucket string, name string, version string) ObjectLockID

+ type QueueStats struct

+ Done int

+ Latency time.Duration

+ MemoryUsage int64

+ Unprocessed int

+ type ReplicationStatus struct

+ AgentURL string

+ ArchivedAt *time.Time

+ CreatedAt time.Time

+ IsArchived bool

+ type ReplicationStatusExtended struct

+ EventMigration QueueStats

+ InitMigration QueueStats

+ IsPaused bool

+ Switch *ReplicationSwitchInfo

+ func (r *ReplicationStatusExtended) InitDone() bool

+ type ReplicationSwitchDowntimeOpts struct

+ ContinueReplication bool

+ Cron *string

+ MaxDuration time.Duration

+ MaxEventLag *uint32

+ SkipBucketCheck bool

+ StartAt *time.Time

+ StartOnInitDone bool

+ func (w *ReplicationSwitchDowntimeOpts) GetCron() (string, bool)

+ func (w *ReplicationSwitchDowntimeOpts) GetMaxDuration() (time.Duration, bool)

+ func (w *ReplicationSwitchDowntimeOpts) GetMaxEventLag() (uint32, bool)

+ func (w *ReplicationSwitchDowntimeOpts) GetStartAt() (time.Time, bool)

+ type ReplicationSwitchInfo struct

+ CreatedAt time.Time

+ DoneAt *time.Time

+ History []string

+ LastStartedAt *time.Time

+ LastStatus ReplicationSwitchStatus

+ ReplicationIDStr string

+ func (s *ReplicationSwitchInfo) GetLastStartAt() (time.Time, bool)

+ func (s *ReplicationSwitchInfo) IsTimeToStart() (bool, error)

+ func (s *ReplicationSwitchInfo) IsZeroDowntime() bool

+ func (s *ReplicationSwitchInfo) ReplicationID() UniversalReplicationID

+ func (s *ReplicationSwitchInfo) SetReplicationID(id UniversalReplicationID)

+ func (s *ReplicationSwitchInfo) Validate() error

+ type ReplicationSwitchStatus string

+ const StatusCheckInProgress

+ const StatusDone

+ const StatusError

+ const StatusInProgress

+ const StatusNotStarted

+ const StatusSkipped

+ func (s *ReplicationSwitchStatus) UnmarshalBinary(data []byte) error

+ func (s ReplicationSwitchStatus) MarshalBinary() (data []byte, err error)

+ type ReplicationSwitchZeroDowntimeOpts struct

+ MultipartTTL time.Duration

+ type UniversalReplicationID struct

+ func UniversalFromBucketReplication(id BucketReplicationPolicy) UniversalReplicationID

+ func UniversalFromUserReplication(policy UserReplicationPolicy) UniversalReplicationID

+ func UniversalIDFromString(s string) (UniversalReplicationID, error)

+ func (r *UniversalReplicationID) AsBucketID() (BucketReplicationPolicy, bool)

+ func (r *UniversalReplicationID) AsString() string

+ func (r *UniversalReplicationID) AsUserID() (UserReplicationPolicy, bool)

+ func (r *UniversalReplicationID) FromStorage() string

+ func (r *UniversalReplicationID) FromToBuckets(taskBucket string) (from, to string)

+ func (r *UniversalReplicationID) IsEmpty() bool

+ func (r *UniversalReplicationID) Swap() UniversalReplicationID

+ func (r *UniversalReplicationID) ToStorage() string

+ func (r *UniversalReplicationID) UnmarshalJSON(data []byte) error

+ func (r *UniversalReplicationID) User() string

+ func (r *UniversalReplicationID) Validate() error

+ func (r UniversalReplicationID) MarshalJSON() ([]byte, error)

+ type UserReplicationPolicy struct

+ FromStorage string

+ ToStorage string

+ User string

+ func NewUserReplicationPolicy(user string, fromStorage string, toStorage string) UserReplicationPolicy

+ func (p UserReplicationPolicy) LookupID() string

+ func (p UserReplicationPolicy) RoutingID() string

+ func (p UserReplicationPolicy) Validate() error

+ type VersionedObjectID struct

+ Bucket string

+ Name string

+ Storage string

+ func NewVersionedObjectID(storage string, bucket string, name string) VersionedObjectID

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL