mirror of https://github.com/knative/pkg.git
parent
f97925ab85
commit
0ecf6f86c1
|
@ -263,7 +263,7 @@ func (c *Impl) EnqueueAfter(obj interface{}, after time.Duration) {
|
||||||
func (c *Impl) EnqueueSlowKey(key types.NamespacedName) {
|
func (c *Impl) EnqueueSlowKey(key types.NamespacedName) {
|
||||||
c.workQueue.SlowLane().Add(key)
|
c.workQueue.SlowLane().Add(key)
|
||||||
c.logger.With(zap.Object(logkey.Key, logging.NamespacedName(key))).
|
c.logger.With(zap.Object(logkey.Key, logging.NamespacedName(key))).
|
||||||
Debug("Adding to the slow queue %s (depth(total/slow): %d/%d)",
|
Debugf("Adding to the slow queue %s (depth(total/slow): %d/%d)",
|
||||||
safeKey(key), c.workQueue.Len(), c.workQueue.SlowLane().Len())
|
safeKey(key), c.workQueue.Len(), c.workQueue.SlowLane().Len())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue