Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for add_func (0.15 sec)

  1. pkg/controller/daemon/daemon_controller.go

    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "daemonset",
    			},
    		),
    	}
    
    	daemonSetInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			dsc.addDaemonset(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dsc.updateDaemonset(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. tensorflow/compiler/mlir/lite/transforms/optimize_patterns.td

         $operand, $act_func),
        (BinaryOp $input, $operand, $act_func),
      [(OperandsBroadcastToOutputType $input, $operand, $result),
       (HasRankAtMost<4> $input),
       (HasRankAtMost<4> $operand)]>;
    
      def FuseTileBroadcastToBinaryOp2#BinaryOp : Pat<
        (BinaryOp:$result $operand,
          (TFL_TileOp $input, (Arith_ConstantOp $tile)), $act_func),
        (BinaryOp $operand, $input, $act_func),
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 16 20:31:41 UTC 2024
    - 66.4K bytes
    - Viewed (0)
  3. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    	nc.enterFullDisruptionFunc = nc.HealthyQPSFunc
    	nc.computeZoneStateFunc = nc.ComputeZoneState
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			pod := obj.(*v1.Pod)
    			nc.podUpdated(nil, pod)
    		},
    		UpdateFunc: func(prev, obj interface{}) {
    			prevPod := prev.(*v1.Pod)
    			newPod := obj.(*v1.Pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller.go

    		clock:                 clock,
    		podBackoffStore:       newBackoffStore(),
    	}
    
    	if _, err := jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			jm.addJob(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    		minRequestTimeout:       minRequestTimeout,
    		staticOpenAPISpec:       staticOpenAPISpec,
    		maxRequestBodyBytes:     maxRequestBodyBytes,
    	}
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    ret.createCustomResourceDefinition,
    		UpdateFunc: ret.updateCustomResourceDefinition,
    		DeleteFunc: func(obj interface{}) {
    			ret.removeDeadStorage()
    		},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  6. pkg/controller/podautoscaler/horizontal.go

    		scaleDownEventsLock: sync.RWMutex{},
    		hpaSelectors:        selectors.NewBiMultimap(),
    	}
    
    	hpaInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    hpaController.enqueueHPA,
    			UpdateFunc: hpaController.updateHPA,
    			DeleteFunc: hpaController.deleteHPA,
    		},
    		resyncPeriod,
    	)
    	hpaController.hpaLister = hpaInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
Back to top