entity

package

Go to main page

Versions in this module

v0

v0.7.8

Jul 17, 2026

v0.7.7

Jul 14, 2026

v0.7.6

May 26, 2026

v0.7.5

May 8, 2026

v0.7.4

Mar 31, 2026

v0.7.3

Mar 12, 2026

Changes in this version

type BucketReplicationPolicy

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

+ type DiffCheckStatus struct

+ Consistent bool

+ Queue DiffQueueStatus

+ Settings DiffSettings

+ type DiffFixCopyObject struct

+ IsDir bool

+ Name string

+ func NewDiffFixCopyObject(name string, isDir bool) DiffFixCopyObject

+ type DiffFixID struct

+ Destination string

+ DiffID DiffID

+ func NewDiffFixID(diffID DiffID, destination string) DiffFixID

+ type DiffID struct

+ Locations []DiffLocation

+ func NewDiffID(locations ...DiffLocation) DiffID

+ type DiffLocation struct

+ Bucket string

+ Storage string

+ func NewDiffLocation(storage string, bucket string) DiffLocation

+ type DiffObjectID struct

+ DiffID DiffID

+ Prefix string

+ Storage string

+ func NewDiffObjectID(diffID DiffID, storage string, prefix string) DiffObjectID

+ type DiffQueueStatus struct

+ Completed uint64

+ Queued uint64

+ Ready bool

+ type DiffReportEntry struct

+ Etag string

+ Object string

+ Size uint64

+ StorageEntries []DiffSetEntry

+ VersionIndex uint64

+ func NewDiffReportEntry(object string, versionIndex uint64, size uint64, etag string, ...) DiffReportEntry

+ type DiffReportEntryPage struct

+ Cursor uint64

+ Entries []DiffReportEntry

+ func NewDiffReportEntryPage(entries []DiffReportEntry, cursor uint64) DiffReportEntryPage

+ type DiffSetEntry struct

+ IsDir bool

+ Location DiffLocation

+ VersionID string

+ func NewDiffSetEntry(location DiffLocation, isDir bool) DiffSetEntry

+ func NewVersionedDiffSetEntry(location DiffLocation, versionID string) DiffSetEntry

+ type DiffSetID struct

+ DiffID DiffID

+ Etag string

+ Object string

+ Size uint64

+ VersionIndex uint64

+ func NewEtagDiffSetID(diffID DiffID, object string, size uint64, etag string) DiffSetID

+ func NewNameDiffSetID(diffID DiffID, object string) DiffSetID

+ func NewSizeDiffSetID(diffID DiffID, object string, size uint64) DiffSetID

+ func NewVersionedEtagDiffSetID(diffID DiffID, object string, versionIndex uint64, size uint64, etag string) DiffSetID

+ func NewVersionedNameDiffSetID(diffID DiffID, object string, versionIndex uint64) DiffSetID

+ func NewVersionedSizeDiffSetID(diffID DiffID, object string, versionIndex uint64, size uint64) DiffSetID

+ type DiffSettings struct

+ IgnoreEtags bool

+ IgnoreSizes bool

+ User string

+ Versioned bool

+ func NewDiffSettings(user string, versioned bool, ignoreSizes bool, ignoreEtags bool) DiffSettings

+ type DiffStatus struct

+ Check DiffCheckStatus

+ FixQueue *DiffQueueStatus

+ Locations []DiffLocation

type ObjectVersionInfo

+ DeleteMarker bool

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