Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for syncNamespace (0.18 sec)

  1. pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go

    // If terminating, this will be skipped
    func (nc *NamespaceController) namespaceChange(ns *v1.Namespace) {
    	if ns.Status.Phase != v1.NamespaceTerminating {
    		nc.syncNamespace(ns.Name)
    	}
    }
    
    func (nc *NamespaceController) syncNamespace(ns string) {
    	// skip special kubernetes system namespaces
    	if nc.ignoredNamespaces.Contains(ns) {
    		return
    	}
    	nc.queue.Add(types.NamespacedName{Name: ns})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. pkg/controller/certificates/rootcacertpublisher/publisher.go

    	nsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    e.namespaceAdded,
    		UpdateFunc: e.namespaceUpdated,
    	})
    	e.nsListerSynced = nsInformer.Informer().HasSynced
    
    	e.syncHandler = e.syncNamespace
    
    	return e, nil
    
    }
    
    // Publisher manages certificate ConfigMap objects inside Namespaces
    type Publisher struct {
    	client clientset.Interface
    	rootCA []byte
    
    	// To allow injection for testing.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. pkg/controller/certificates/rootcacertpublisher/publisher_test.go

    			if err != nil {
    				t.Fatalf("error creating ServiceAccounts controller: %v", err)
    			}
    
    			cmStore := cmInformer.Informer().GetStore()
    
    			controller.syncHandler = controller.syncNamespace
    
    			for _, s := range tc.ExistingConfigMaps {
    				cmStore.Add(s)
    			}
    
    			if tc.AddedNamespace != nil {
    				controller.namespaceAdded(tc.AddedNamespace)
    			}
    			if tc.UpdatedNamespace != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:16 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. pkg/controller/serviceaccount/serviceaccounts_controller.go

    		AddFunc:    e.namespaceAdded,
    		UpdateFunc: e.namespaceUpdated,
    	}, options.NamespaceResync)
    	e.nsLister = nsInformer.Lister()
    	e.nsListerSynced = nsHandler.HasSynced
    
    	e.syncHandler = e.syncNamespace
    
    	return e, nil
    }
    
    // ServiceAccountsController manages ServiceAccount objects inside Namespaces
    type ServiceAccountsController struct {
    	client                  clientset.Interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. pkg/controller/serviceaccount/serviceaccounts_controller_test.go

    		nsStore := nsInformer.Informer().GetStore()
    
    		syncCalls := make(chan struct{}, 1)
    		controller.syncHandler = func(ctx context.Context, key string) error {
    			err := controller.syncNamespace(ctx, key)
    			if err != nil {
    				t.Logf("%s: %v", k, err)
    			}
    
    			syncCalls <- struct{}{}
    			return err
    		}
    		stopCh := make(chan struct{})
    		defer close(stopCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 03 00:46:06 UTC 2021
    - 7.6K bytes
    - Viewed (0)
  6. pkg/controller/namespace/deletion/namespaced_resources_deleter.go

    		if errors.IsNotFound(err) {
    			return nil
    		}
    		return err
    	}
    	if namespace.DeletionTimestamp == nil {
    		return nil
    	}
    
    	klog.FromContext(ctx).V(5).Info("Namespace controller - syncNamespace", "namespace", namespace.Name, "finalizerToken", d.finalizerToken)
    
    	// ensure that the status is up to date on the namespace
    	// if we get a not found error, we assume the namespace is truly gone
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 20 07:34:23 UTC 2023
    - 25.2K bytes
    - Viewed (0)
Back to top