- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for filterFuncs (0.59 sec)
-
src/go/doc/filter.go
} else { // type name doesn't match, but we may have matching consts, vars, factories or methods td.Consts = filterValues(td.Consts, f) td.Vars = filterValues(td.Vars, f) td.Funcs = filterFuncs(td.Funcs, f) td.Methods = filterFuncs(td.Methods, f) n += len(td.Consts) + len(td.Vars) + len(td.Funcs) + len(td.Methods) } if n > 0 { a[w] = td w++ } } return a[0:w] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 01 18:18:07 UTC 2022 - 2.2K bytes - Viewed (0) -
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)