logCurrentQueue prints the number of things happening.
(now time.Time)
| 118 | |
| 119 | // logCurrentQueue prints the number of things happening. |
| 120 | func (u *Unpackerr) logCurrentQueue(now time.Time) { |
| 121 | stats := u.stats() |
| 122 | u.Printf("[Unpackerr] Queue: %d waiting, %d queued, %d extracting, %d extracted, %d imported, %d failed, %d deleted", |
| 123 | stats.Waiting, stats.Queued, stats.Extracting, stats.Extracted, stats.Imported, stats.Failed, stats.Deleted) |
| 124 | |
| 125 | u.Printf("[Unpackerr] Totals: %d retries, %d finished, %d|%d webhooks,"+ |
| 126 | " %d|%d cmdhooks, stacks; event:%d, hook:%d, del:%d, up %s", |
| 127 | u.Retries, u.Finished, stats.HookOK, stats.HookFail, stats.CmdOK, stats.CmdFail, |
| 128 | len(u.folders.Events)+len(u.updates)+len(u.folders.Updates), len(u.hookChan), len(u.delChan), |
| 129 | durafmt.Parse(now.Sub(version.Started)).LimitFirstN(3).Format(durafmtUnits)) //nolint:mnd |
| 130 | u.updateTray(stats, uint(len(u.folders.Events)+len(u.updates)+len(u.folders.Updates)+len(u.delChan)+len(u.hookChan))) |
| 131 | } |
| 132 | |
| 133 | // setupLogging splits log write into a file and/or stdout. |
| 134 | func (u *Unpackerr) setupLogging() { |
no test coverage detected