- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for AddObject (0.13 sec)
-
pkg/kube/krt/bench_test.go
c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) c.services.AddEventHandler(controllers.FromEventHandler(func(e controllers.Event) { o := e.Latest() for _, pod := range c.pods.List(o.GetNamespace(), klabels.SelectorFromValidatedSet(o.(*v1.Service).Spec.Selector)) { c.queue.AddObject(pod) } })) c.handler = func(e krt.Event[Workload]) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
dc.queue.AddObject(gw) } })) gateways.AddEventHandler(controllers.ObjectHandler(dc.queue.AddObject)) gatewayClasses.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) { for _, g := range dc.gateways.List(metav1.NamespaceAll, klabels.Everything()) { if string(g.Spec.GatewayClassName) == o.GetName() { dc.queue.AddObject(g) } } }))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/kube/watcher/configmapwatcher/configmapwatcher.go
}) c.queue = controllers.NewQueue("configmap "+name, controllers.WithReconciler(c.processItem)) c.configmaps.AddEventHandler(controllers.FilteredObjectSpecHandler(c.queue.AddObject, func(o controllers.Object) bool { // Filter out other configmaps return o.GetName() == name && o.GetNamespace() == namespace })) return c } func (c *Controller) Run(stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 07:11:52 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, o.Revision), }) c.webhooks.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } func (c *Controller) Reconcile(key types.NamespacedName) error { name := key.Name whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/test/csrctrl/controllers/csr_controller.go
signers: signers, } c.queue = controllers.NewQueue("csr", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.csrs.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } func (s *Signer) Reconcile(key types.NamespacedName) error { csr := s.csrs.Get(key.Name, key.Namespace) if csr == nil { // CSR was deleted, no action needed return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 3.9K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller.go
services: services, } c.queue = controllers.NewQueue("ingress", controllers.WithReconciler(c.onEvent), controllers.WithMaxAttempts(5)) c.ingress.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) // We watch service changes to detect service port number change to trigger // re-convert ingress to new-vs. c.services.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
// lifecycle to the Service so that when the Service is deleted, // k8s automatically deletes the ServiceExport. c.services.AddEventHandler(controllers.EventHandler[controllers.Object]{AddFunc: c.queue.AddObject}) return c } func (c *autoServiceExportController) Run(stopCh <-chan struct{}) { kube.WaitForCacheSync("auto service export", stopCh, c.services.HasSynced) c.queue.Run(stopCh) c.services.ShutdownHandlers()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
architecture/networking/controllers.md
Often, these handlers are adding something to the queue like `client.AddEventHandler(controllers.ObjectHandler(queue.AddObject))`. Construction should NOT actually start running all of these things, do I/O, or block in anyway. Running the controller actually starts processing things. Normally, this just means running the queue.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/extensibility/ExtensibleDynamicObject.java
// .willBeRemovedInGradle9() // .withUpgradeGuideSection(8, "deprecated_access_to_conventions") // .nagUser(); return convention; } public void addObject(DynamicObject object, Location location) { switch (location) { case BeforeConvention: beforeConvention = object; break; case AfterConvention:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Nov 17 11:25:34 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) // Register a handler for pods. For each pod event, we will add it to the queue. c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } // Reconcile is the main work function for our controller. As input, we get a name of an object; with // this we should drive the rest of the state of the world.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0)