- Sort Score
- Result 10 results
- Languages All
Results 101 - 105 of 105 for add_func (0.12 sec)
-
pilot/pkg/serviceregistry/kube/controller/controller.go
updates := k8sEvents.With(typeTag.Value(otype), eventTag.Value("update")) deletes := k8sEvents.With(typeTag.Value(otype), eventTag.Value("delete")) informer.AddEventHandler( controllers.EventHandler[T]{ AddFunc: func(obj T) { adds.Increment() c.queue.Push(func() error { return wrappedHandler(ptr.Empty[T](), obj, model.EventAdd) }) }, UpdateFunc: func(old, cur T) { if filter != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
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) -
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) -
tensorflow/compiler/mlir/tensorflow/tests/tf-ops.mlir
// expected-error @+1 {{'host_mlir_module' does not contain 'host_func' function}} "tf._XlaHostComputeMlir"(%arg0) {send_key="", recv_key="", host_mlir_module="module {\0A func.func @bad_func(%arg0: tensor<*xf32>) -> tensor<*xf32> {\0A %0 = \22tf.Identity\22(%arg0) {_xla_outside_compilation = \22cluster1\22} : (tensor<*xf32>) -> tensor<*xf32> \0A func.return %0 : tensor<*xf32> \0A } \0A} \0A"} : (tensor<2xf32>) -> ()
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Oct 23 14:40:35 UTC 2023 - 236.4K bytes - Viewed (0) -
pkg/apis/core/validation/validation.go
) func getMaskNodeSelectorLabelChangeEqualities() conversion.Equalities { initMaskNodeSelectorLabelChangeEqualities.Do(func() { var eqs = apiequality.Semantic.Copy() err := eqs.AddFunc( func(newReq, oldReq core.NodeSelectorRequirement) bool { // allow newReq to change to a GA key if oldReq.Key != newReq.Key && betaToGALabel[oldReq.Key] == newReq.Key {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 349.5K bytes - Viewed (1)