- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for CreateOrAdjustGlobalBuffer (0.18 sec)
-
internal/logger/targets.go
continue } var newTgt *http.Target for ii := range tgts { if currentTgt.Name() == tgts[ii].Name() { newTgt = tgts[ii] currentTgt.AssignMigrateTarget(newTgt) http.CreateOrAdjustGlobalBuffer(currentTgt, newTgt) break } } } for _, t := range tgts { err := t.Init(ctx) if err != nil { errs = append(errs, err) } } swapAuditMuRW.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/logger/target/http/http.go
if time.Since(h.lastStarted).Seconds() > 30 { return } } } } // CreateOrAdjustGlobalBuffer will create or adjust the global log entry buffers // which are used to migrate log entries between old and new targets. func CreateOrAdjustGlobalBuffer(currentTgt *Target, newTgt *Target) { logChLock.Lock() defer logChLock.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)