- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 129 for DELETING (0.12 sec)
-
pkg/controller/certificates/certificate_controller.go
csr, ok = tombstone.Obj.(*certificates.CertificateSigningRequest) if !ok { logger.V(2).Info("Tombstone contained object that is not a CSR", "object", obj) return } } logger.V(4).Info("Deleting certificate request", "csr", csr.Name) cc.enqueueCertificateRequest(obj) }, }) cc.csrLister = csrInformer.Lister() cc.csrsSynced = csrInformer.Informer().HasSynced return cc }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
eventRecorder record.EventRecorder podControl controller.PodControlInterface crControl controller.ControllerRevisionControlInterface // An dsc is temporarily suspended after creating/deleting these many replicas. // It resumes normal action after observing the watch events for them. burstReplicas int // To allow injection of syncDaemonSet for testing. syncHandler func(ctx context.Context, dsKey string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
cmd/metacache-bucket.go
} // cleanup removes redundant and outdated entries. func (b *bucketMetacache) cleanup() { // Entries to remove. remove := make(map[string]struct{}) // Test on a copy // cleanup is the only one deleting caches. caches, _ := b.cloneCaches() for id, cache := range caches { if !cache.worthKeeping() { b.debugf("cache %s not worth keeping", id) remove[id] = struct{}{} continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
schema.GroupVersionKind kubeClient clientset.Interface podControl controller.PodControlInterface eventBroadcaster record.EventBroadcaster // A ReplicaSet is temporarily suspended after creating/deleting these many replicas. // It resumes normal action after observing the watch events for them. burstReplicas int // To allow injection of syncReplicaSet for testing. syncHandler func(ctx context.Context, rsKey string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/passes/lift_hashtable_ops_as_args.cc
op.getResult(0).replaceAllUsesWith( block.addArgument(resource_type, op.getLoc())); AddEntryFunctionInput( absl::StrCat("hash_table_", it.first->getValue(), ":0"), target_func); // Avoid deleting the op here, clone it to the caller function first. lifted_op_and_arg_idx.emplace_back(&op, it.first->getValue()); } else { op.getResult(0).replaceAllUsesWith(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 17:58:54 UTC 2024 - 8.2K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/gradle-properties/service_injection.adoc
5. <<workerexecutor,`WorkerExecutor`>> - Allows a task to run work in parallel. 6. <<filesystemoperations,`FileSystemOperations`>> - Allows a task to run operations on the filesystem such as deleting files, copying files or syncing directories. 7. <<archiveoperations,`ArchiveOperations`>> - Allows a task to run operations on archive files such as ZIP or TAR files.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 24 04:19:09 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
// Note: we do not need to account for unsubscribed resources as these are handled by parent removal; // See https://www.envoyproxy.io/docs/envoy/latest/api-docs/xds_protocol#deleting-resources. // This means if there are only removals, we will not respond. var logFiltered string if !req.Delta.IsEmpty() && !con.proxy.IsProxylessGrpc() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
} castObj, ok = tombstone.Obj.(*apiextensionsv1.CustomResourceDefinition) if !ok { klog.Errorf("Tombstone contained object that is not expected %#v", obj) return } } klog.V(4).Infof("Deleting customresourcedefinition %q", castObj.Name) c.enqueue(castObj) } func (c *Controller) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { c.queue.Add(obj.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
return func(ctx context.Context, fireAt time.Time, args *WorkArgs) error { ns := args.NamespacedName.Namespace name := args.NamespacedName.Name klog.FromContext(ctx).Info("Deleting pod", "controller", controllerName, "pod", args.NamespacedName) if emitEventFunc != nil { emitEventFunc(args.NamespacedName) } var err error for i := 0; i < retries; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.cc
done(done_status); ref.Unref(); // If a stream is in a bad state, it gets deleted when it's returned to // the stream pool, i.e. when it leaves this scope. However, a stream // deleting itself in a host callback on itself can cause bad behaviors // on some platforms. Releasing it in another stream to avoid that. if (!device_allows_sync_on_completion &&
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 00:36:08 UTC 2024 - 12.7K bytes - Viewed (0)