Method cleanup

worker/queue.go:276–284

cleanup deletes all expired tasks.

()

// cleanup deletes all expired tasks.
func (t *tasks) cleanup() {
	const taskTtl = 7 * 24 * time.Hour // 1 week
	minTs := time.Now().UTC().Add(-taskTtl).Unix()
	minMeta := uint64(minTs) << 32

	t.logMu.Lock()
	defer t.logMu.Unlock()
	t.log.DeleteBelow(minMeta)
}

// newId generates a random unique task ID. logMu must be acquired before calling this function.
//