Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for AddObject (0.11 sec)

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