- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for RemoveEventHandler (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
return res, err } func (t *testInformer) RemoveEventHandler(registration cache.ResourceEventHandlerRegistration) error { func() { t.lock.Lock() defer t.lock.Unlock() if _, ok := t.registrations[registration]; !ok { panic("removing unknown event handler?") } delete(t.registrations, registration) }() return t.SharedIndexInformer.RemoveEventHandler(registration) } var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
go c.cmInformer.Run(stop) // create Status Writer t := c.clock.Tick(c.UpdateInterval) for { select { case <-stop: _ = c.cmInformer.RemoveEventHandler(c.cmHandle) return case <-t: staleReporters := c.writeAllStatus() if len(staleReporters) > 0 { c.removeStaleReporters(staleReporters) } } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
} defer func() { if err := s.policyInformer.RemoveEventHandler(handle); err != nil { utilruntime.HandleError(fmt.Errorf("failed to remove policy event handler: %w", err)) } }() bindingHandle, err := s.bindingInformer.AddEventHandler(notifyFuncs) if err != nil { return err } defer func() { if err := s.bindingInformer.RemoveEventHandler(bindingHandle); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
c.notificationsDelivered.Store(func() bool { return false }) // Remove event handler and Handle Error here. Error should only be raised // for improper usage of event handler API. if err := c.informer.RemoveEventHandler(registration); err != nil { utilruntime.HandleError(err) } }() // Wait for initial cache list to complete before beginning to reconcile // objects.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/kclient/client.go
} func (n *informerClient[T]) ShutdownHandlers() { n.handlerMu.Lock() defer n.handlerMu.Unlock() for _, c := range n.registeredHandlers { _ = n.informer.RemoveEventHandler(c.registration) } } func (n *informerClient[T]) AddEventHandler(h cache.ResourceEventHandler) { fh := cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0)