Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newWebhookPatcherQueue (0.3 sec)

  1. 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)
  2. 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)
Back to top