- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 105 for add_func (0.15 sec)
-
pkg/controller/endpoint/endpoints_controller.go
AddFunc: e.onServiceUpdate, UpdateFunc: func(old, cur interface{}) { e.onServiceUpdate(cur) }, DeleteFunc: e.onServiceDelete, }) e.serviceLister = serviceInformer.Lister() e.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: e.addPod, UpdateFunc: e.updatePod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
cl.client, gvr, kubetypes.StandardInformer, filter, ) } kind := s.Kind() kc.AddEventHandler(controllers.EventHandler[controllers.Object]{ AddFunc: func(obj controllers.Object) { incrementEvent(kind, "add") cl.queue.Push(func() error { cl.onEvent(resourceGVK, nil, obj, model.EventAdd) return nil }) },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
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) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
}, Handler: cache.ResourceEventHandlerFuncs{ // we have a filter, so any time we're called, we may as well queue. We only ever check one configmap // so we don't have to be choosy about our key. AddFunc: func(obj interface{}) { c.queue.Add(keyFn()) }, UpdateFunc: func(oldObj, newObj interface{}) { c.queue.Add(keyFn()) }, DeleteFunc: func(obj interface{}) { c.queue.Add(keyFn())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
expc.operationGenerator = operationexecutor.NewOperationGenerator( kubeClient, &expc.volumePluginMgr, expc.recorder, blkutil) pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: expc.enqueuePVC, UpdateFunc: func(old, new interface{}) { oldPVC, ok := old.(*v1.PersistentVolumeClaim) if !ok { return } oldReq := oldPVC.Spec.Resources.Requests[v1.ResourceStorage]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
} return err } s.ctx = ctx // Perform initial policy compilation after initial list has finished s.notify() s.refreshPolicies() notifyFuncs := cache.ResourceEventHandlerFuncs{ AddFunc: func(_ interface{}) { s.notify() }, UpdateFunc: func(_, _ interface{}) { s.notify() }, DeleteFunc: func(_ interface{}) { s.notify() }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
now: time.Now, } jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: jm.addJob, UpdateFunc: jm.updateJob, DeleteFunc: jm.deleteJob, }) cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.enqueueController(obj) }, UpdateFunc: func(oldObj, newObj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
dc.getUpdater = func() updater { return dc.writePdbStatus } podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dc.addPod(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dc.updatePod(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 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: queueName}, ), } rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rsc.addRS(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rsc.updateRS(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 - 33.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
options.FieldSelector = "nodeName=" + node.Name }) c.sliceStore = informer.GetStore() handler, err := informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj any) { slice, ok := obj.(*resourceapi.ResourceSlice) if !ok { return } logger.V(5).Info("ResourceSlice add", "slice", klog.KObj(slice)) c.queue.Add(slice.DriverName) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0)