- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newWebhookPatcherQueue (0.3 sec)
-
pkg/webhooks/webhookpatch.go
webhookName: webhookName, CABundleWatcher: caBundleWatcher, } p.queue = newWebhookPatcherQueue(p.webhookPatchTask) p.webhooks = kclient.New[*v1.MutatingWebhookConfiguration](client) p.webhooks.AddEventHandler(controllers.ObjectHandler(p.queue.AddObject)) return p, nil } func newWebhookPatcherQueue(reconciler controllers.ReconcilerFn) controllers.Queue { return controllers.NewQueue("webhook patcher",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 28 00:36:38 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/webhooks/webhookpatch_test.go
} } } } }) } } func TestWebhookPatchingQueue(t *testing.T) { success := atomic.NewInt32(0) retries := atomic.NewInt32(0) queue := newWebhookPatcherQueue(func(key types.NamespacedName) error { if key.Name == "conflict-for-ever" { retries.Inc() return errors.New("conflict error") } if key.Name == "conflict-success" { retries.Inc()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 02 09:53:38 UTC 2023 - 8.6K bytes - Viewed (0)