- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for TierName (0.15 sec)
-
cmd/tier-journal.go
break } err = fn(ctx, entry.ObjName, entry.VersionID, entry.TierName) if err != nil && !isErrObjectNotFound(err) { logger.LogIf(ctx, fmt.Errorf("tier-journal: failed to delete transitioned object %s from %s due to %s", entry.ObjName, entry.TierName, err)) // We add the entry into the active journal to try again // later. jd.addEntry(entry) } }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/tier.go
// IsTierValid returns true if there exists a remote tier by name tierName, // otherwise returns false. func (config *TierConfigMgr) IsTierValid(tierName string) bool { config.RLock() defer config.RUnlock() _, valid := config.isTierNameInUse(tierName) return valid } // isTierNameInUse returns tier type and true if there exists a remote tier by // name tierName, otherwise returns madmin.Unsupported and false. N B this
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/tier-mem-journal.go
logger.LogIf(ctx, deleteObjectFromRemoteTier(ctx, entry.ObjName, entry.VersionID, entry.TierName)) } } } func (j *tierMemJournal) AddEntry(je jentry) error { select { case j.entries <- je: default: return fmt.Errorf("failed to remove tiered content at %s with version %s from tier %s, will be retried later.", je.ObjName, je.VersionID, je.TierName) } return nil
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Aug 03 21:16:15 GMT 2023 - 1.5K bytes - Viewed (0) -
cmd/tier-sweeper.go
globalExpiryState.enqueueTierJournalEntry(je) } } type jentry struct { ObjName string VersionID string TierName string } func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error { w, err := globalTierConfigMgr.getDriver(ctx, tierName) if err != nil { return err } return w.Remove(ctx, objName, remoteVersionID(rvID))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} func (n newerNoncurrentTask) OpHash() uint64 { return xxh3.HashString(n.bucket + n.versions[0].ObjectV.ObjectName) } func (j jentry) OpHash() uint64 { return xxh3.HashString(j.TierName + j.ObjName) } func (e expiryTask) OpHash() uint64 { return xxh3.HashString(e.objInfo.Bucket + e.objInfo.Name) } // expiryState manages all ILM related expiration activities. type expiryState struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0)