We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 508a4f7 commit 23be958Copy full SHA for 23be958
pkg/controller/disruption/disruption.go
@@ -119,7 +119,7 @@ func NewDisruptionController(
119
dc := &DisruptionController{
120
kubeClient: kubeClient,
121
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "disruption"),
122
- recheckQueue: workqueue.NewNamedDelayingQueue("disruption-recheck"),
+ recheckQueue: workqueue.NewNamedDelayingQueue("disruption_recheck"),
123
broadcaster: record.NewBroadcaster(),
124
}
125
dc.recorder = dc.broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "controllermanager"})
0 commit comments