- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 63 for get4 (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
return watcher, nil } // Get implements storage.Interface. func (c *Cacher) Get(ctx context.Context, key string, opts storage.GetOptions, objPtr runtime.Object) error { if opts.ResourceVersion == "" { // If resourceVersion is not specified, serve it from underlying // storage (for backward compatibility). return c.storage.Get(ctx, key, opts, objPtr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
if err == nil || !errors.IsNotFound(err) { t.Errorf("unexpected error: %v", err) } } // This test the fast-fail path. We test that the precondition gets verified // again before deleting the object in tests of pkg/storage/etcd. func (t *Tester) testDeleteWithUID(obj runtime.Object, createFn CreateFunc, getFn GetFunc, isNotFoundFn IsErrorFunc, opts metav1.DeleteOptions) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* {@code function} is invoked on each call to {@link Future#get() get()} on the returned future. * * <p>The returned {@code Future} reflects the input's cancellation state directly, and any * attempt to cancel the returned Future is likewise passed through to the input Future. * * <p>Note that calls to {@linkplain Future#get(long, TimeUnit) timed get} only apply the timeout
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
src/runtime/mgcpacer.go
c.setMaxIdleMarkWorkers(0) } else { // TODO(mknyszek): The fundamental reason why we need this is because // we can't count on the fractional mark worker to get scheduled. // Fix that by ensuring it gets scheduled according to its quota even // if the rest of the application is idle. c.setMaxIdleMarkWorkers(1) } } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
* {@code function} is invoked on each call to {@link Future#get() get()} on the returned future. * * <p>The returned {@code Future} reflects the input's cancellation state directly, and any * attempt to cancel the returned Future is likewise passed through to the input Future. * * <p>Note that calls to {@linkplain Future#get(long, TimeUnit) timed get} only apply the timeout
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// (entry value is clusterEvent) together with in-flight pods (entry // value is *v1.Pod). Entries get added at the end while the mutex is // locked, so they get serialized. // // The pod entries are added in Pop and used to track which events // occurred after the pod scheduling attempt for that pod started. // They get removed when the scheduling attempt is done, at which
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
$timeout = 10 $stopped = (Get-service $service).Status -eq 'Stopped' for ($i = 0; $i -lt $timeout -and !($stopped); $i++) { Start-Sleep 1 $stopped = (Get-service $service).Status -eq 'Stopped' } if ((Get-service $service).Status -ne 'Stopped') { # Force kill the processes. Stop-Process -Force -PassThru -Id (Get-WmiObject win32_process |
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/passes/quantize_composite_functions.cc
Value& zero_point) { TensorType scale_type = RankedTensorType::get({}, rewriter.getF32Type()); TensorType zero_point_type = scale_type.clone(rewriter.getI32Type()); scale = rewriter.create<TF::ConstOp>( loc, scale_type, DenseFPElementsAttr::get(scale_type, {static_cast<float>(qtype.getScale())})); zero_point = rewriter.create<TF::ConstOp>(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 54.5K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
func extendFQDN(host string) string { if host[0] == '*' { return host } if strings.HasSuffix(host, k8sSuffix) { return host } return host + k8sSuffix } // getDestRuleSubsets gets names of subsets that match any pod labels (also, ones that don't match). func getDestRuleSubsets(subsets []*v1alpha3.Subset, podsLabels []klabels.Set) ([]string, []string) { matchingSubsets := make([]string, 0, len(subsets))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// The nft docs say "dynamic" is only // needed for sets containing stateful // objects (eg counters), but (at least on // RHEL8) if we create the set without // "dynamic", it later gets mutated to // have it, and then the next attempt to // tx.Add() it here fails because it looks // like we're trying to change the flags. knftables.DynamicFlag, knftables.TimeoutFlag,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0)