- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for filterFunc (0.21 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
limitations under the License. */ package watch import ( "sync" ) // FilterFunc should take an event, possibly modify it in some way, and return // the modified event. If the event should be ignored, then return keep=false. type FilterFunc func(in Event) (out Event, keep bool) // Filter passes all events through f before allowing them to pass on.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K bytes - Viewed (0) -
operator/pkg/helm/helm.go
} vals, err := chartutil.ToRenderValues(chrt, valuesMap, options, &caps) if err != nil { return "", err } if filterFunc != nil { filteredTemplates := []*chart.File{} for _, t := range chrt.Templates { // Always include required templates that do not produce any output if filterFunc(t.Name) || strings.HasSuffix(t.Name, ".tpl") || t.Name == "templates/zzz_profile.yaml" { filteredTemplates = append(filteredTemplates, t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
workqueue.TypedRateLimitingQueueConfig[string]{ Name: "bootstrap_signer_queue", }, ), } configMaps.Informer().AddEventHandlerWithResyncPeriod( cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { switch t := obj.(type) { case *v1.ConfigMap: return t.Name == options.ConfigMapName && t.Namespace == options.ConfigMapNamespace default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
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/controller/bootstrap/tokencleaner.go
workqueue.TypedRateLimitingQueueConfig[string]{ Name: "token_cleaner", }, ), } secrets.Informer().AddEventHandlerWithResyncPeriod( cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { switch t := obj.(type) { case *v1.Secret: return t.Type == bootstrapapi.SecretTypeBootstrapToken && t.Namespace == e.tokenSecretNamespace default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
), preRunCaches: []cache.InformerSynced{uncastConfigmapInformer.HasSynced}, } uncastConfigmapInformer.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 - 8.9K 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)