- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for processEntries (0.33 sec)
-
cmd/tier-mem-journal.go
type tierMemJournal struct { entries chan jentry } func newTierMemJournal(nevents int) *tierMemJournal { return &tierMemJournal{ entries: make(chan jentry, nevents), } } func (j *tierMemJournal) processEntries(ctx context.Context) { for { select { case <-ctx.Done(): return case entry := <-j.entries: logger.LogIf(ctx, deleteObjectFromRemoteTier(ctx, entry.ObjName, entry.VersionID, entry.TierName)) } }
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-journal.go
for _, diskPath := range globalEndpoints.LocalDisksPaths() { t.diskPath = diskPath go t.deletePending(ctx) // for existing journal entries from previous MinIO versions go t.processEntries(ctx) // for newer journal entries circa free-versions return nil } return errors.New("no local drive found") } // rotate rotates the journal. If a read-only journal already exists it does
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)