- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 131 for UpdateFunc (0.17 sec)
-
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
crdinformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { cast := obj.(*apiextensionsv1.CustomResourceDefinition) c.enqueueCRD(cast) }, UpdateFunc: func(oldObj, newObj interface{}) { // Enqueue both old and new object to make sure we remove and add appropriate API services. // The working queue will resolve any duplicates and only changes will stay in the queue.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
tensorflow/c/kernels_experimental.cc
TF_Tensor* source, TF_Tensor* dest), void (*updateFunc)(TF_OpKernelContext* ctx, TF_Tensor* tensor, TF_Tensor* value, int Op), TF_Status* tf_status) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 23 06:12:29 UTC 2024 - 30.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
), specsByName: map[string]*specCache{}, } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } // Run sets openAPIAggregationManager and starts workers
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
}) // use the default resync period from the informer storageVersionInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onAddStorageVersion(logger, obj) }, UpdateFunc: func(old, newObj interface{}) { c.onUpdateStorageVersion(logger, old, newObj) }, }) return c } // Run starts one worker. func (c *Controller) Run(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
), } logger := klog.FromContext(ctx) nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { ttlc.addNode(logger, obj) }, UpdateFunc: func(old, newObj interface{}) { ttlc.updateNode(logger, old, newObj) }, DeleteFunc: ttlc.deleteNode, }) ttlc.nodeStore = listers.NewNodeLister(nodeInformer.Informer().GetIndexer())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
tensorflow/c/kernels_experimental.h
TF_OpKernelContext* ctx, int input_index, int value_index, int Op, int isVariantType, void (*copyFunc)(TF_OpKernelContext* ctx, TF_Tensor* source, TF_Tensor* dest), void (*updateFunc)(TF_OpKernelContext* ctx, TF_Tensor* tensor, TF_Tensor* value, int Op), TF_Status* status); // Expose higher level temporary variable operator for Pluggable vendors to
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Aug 07 14:44:39 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
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{}) { dsc.deleteDaemonset(logger, obj) }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
t.testCreateValidatesNames(valid.DeepCopyObject(), opts) } // Test updating an object. func (t *Tester) TestUpdate(valid runtime.Object, createFn CreateFunc, getFn GetFunc, updateFn UpdateFunc, invalidUpdateFn ...UpdateFunc) { dryRunOpts := metav1.UpdateOptions{DryRun: []string{metav1.DryRunAll}} opts := metav1.UpdateOptions{} t.testUpdateEquals(valid.DeepCopyObject(), createFn, getFn, updateFn)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
KubeClient: client, Recorder: dc.eventRecorder, } dInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dc.addDeployment(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dc.updateDeployment(logger, oldObj, newObj) }, // This will enter the sync loop and no-op, because the deployment has been deleted from the store.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
), } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *DiscoveryController) sync(version schema.GroupVersion) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0)