- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for AddObject (0.11 sec)
-
pkg/kube/kclient/crdwatcher.go
c.crds = NewMetadata(client, gvr.CustomResourceDefinition, Filter{ ObjectFilter: kubetypes.NewStaticObjectFilter(minimumVersionFilter), }) c.crds.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } var minimumCRDVersions = map[string]*semver.Version{ "grpcroutes.gateway.networking.k8s.io": semver.New(1, 1, 0, "", ""), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.go
readyCniNodes.Register(func(o krt.Event[v1.Node]) { if o.Event == controllers.EventDelete { return } if o.New != nil { log.Debugf("adding node to queue event: %s", o.New.Name) n.queue.AddObject(o.New) } }) } func (n *NodeUntainter) HasSynced() bool { return n.queue.HasSynced() } func (n *NodeUntainter) Run(stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
}) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
controller.queue = controllers.NewQueue("multicluster secret", controllers.WithReconciler(controller.processItem)) secrets.AddEventHandler(controllers.ObjectHandler(controller.queue.AddObject)) return controller } type ComponentBuilder interface { registerHandler(h handler) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/project/DefaultProject.java
if (parentInherited != null) { extensibleDynamicObject.setParent(parentInherited); } extensibleDynamicObject.addObject(taskContainer.getTasksAsDynamicObject(), ExtensibleDynamicObject.Location.AfterConvention); evaluationListener.add(gradle.getProjectEvaluationBroadcaster());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 50.2K bytes - Viewed (0) -
src/runtime/mgcmark.go
if ptr < frame.sp { // object hasn't been allocated in the frame yet. continue } if stackTraceDebug { println("stkobj at", hex(ptr), "of size", obj.size) } state.addObject(ptr, obj) } } } type gcDrainFlags int const ( gcDrainUntilPreempt gcDrainFlags = 1 << iota gcDrainFlushBgCredit gcDrainIdle gcDrainFractional )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0)