- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for filterFuncs (0.28 sec)
-
cmd/kube-controller-manager/app/controllermanager.go
func filteredControllerDescriptors(controllerDescriptors map[string]*ControllerDescriptor, filterFunc leadermigration.FilterFunc, expected leadermigration.FilterResult) map[string]*ControllerDescriptor { resultControllers := make(map[string]*ControllerDescriptor) for name, controllerDesc := range controllerDescriptors { if filterFunc(name) == expected {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go
return err } if info.Object == nil { return info.Get() } return nil } type FilterFunc func(info *Info, err error) (bool, error) type FilteredVisitor struct { visitor Visitor filters []FilterFunc } func NewFilteredVisitor(v Visitor, fn ...FilterFunc) Visitor { if len(fn) == 0 { return v } return FilteredVisitor{v, fn} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 21.3K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
) // scheduled pod cache if handlerRegistration, err = informerFactory.Core().V1().Pods().Informer().AddEventHandler( cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { switch t := obj.(type) { case *v1.Pod: return assignedPod(t) case cache.DeletedFinalStateUnknown: if _, ok := t.Obj.(*v1.Pod); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
listOptions.FieldSelector = fields.OneTermEqualSelector("metadata.name", c.configmapName).String() }) c.configmapInformer.AddEventHandler(cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { if cast, ok := obj.(*corev1.ConfigMap); ok { return cast.Name == c.configmapName && cast.Namespace == c.configmapNamespace }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/kube/kclient/client.go
_ = n.informer.RemoveEventHandler(c.registration) } } func (n *informerClient[T]) AddEventHandler(h cache.ResourceEventHandler) { fh := cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { if n.filter == nil { return true } return n.filter(obj) }, Handler: h, } n.handlerMu.Lock() defer n.handlerMu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
kubeSystemConfigMapInformer: kubeSystemConfigMapInformer, } kubeSystemConfigMapInformer.AddEventHandler(cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { if cast, ok := obj.(*corev1.ConfigMap); ok { return cast.Namespace == configMapNamespace && cast.Name == configMapName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
e.secretSynced = secrets.Informer().HasSynced secrets.Informer().AddEventHandlerWithResyncPeriod( cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { switch t := obj.(type) { case *v1.Secret: return t.Type == v1.SecretTypeServiceAccountToken default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0)