Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for filterFuncs (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top