- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for syncNamespace (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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)