- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for INITIALIZING (0.13 sec)
-
cmd/sts-handlers_test.go
Creds: cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken), Secure: s.secure, Transport: s.TestSuiteCommon.client.Transport, }) if err != nil { c.Fatalf("Error initializing client: %v", err) } // Validate that the client from sts creds can access the bucket. c.mustListObjects(ctx, minioClient, bucket) // Create an madmin client with user creds
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 18:45:50 UTC 2024 - 90K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission_test.go
limitRange := validLimitRangeNoDefaults() mockClient := newMockClientForTest([]corev1.LimitRange{limitRange}) handler, informerFactory, err := newHandlerForTest(mockClient) if err != nil { t.Errorf("unexpected error initializing handler: %v", err) } informerFactory.Start(wait.NeverStop) testPod := validPod("testPod", 1, api.ResourceRequirements{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 51.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
var ok bool readyGeneration, ok = c.ready.checkAndReadGeneration() if !ok { return nil, errors.NewTooManyRequests("storage is (re)initializing", 1) } } else { readyGeneration, err = c.ready.waitAndReadGeneration(ctx) if err != nil { return nil, errors.NewServiceUnavailable(err.Error()) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
"k8s.io/kubernetes/pkg/util/slice" ) const ( // Specifies the maximum timeout a permit plugin can return. maxTimeout = 15 * time.Minute ) // frameworkImpl is the component responsible for initializing and running scheduler // plugins. type frameworkImpl struct { registry Registry snapshotSharedLister framework.SharedLister waitingPods *waitingPodsMap scorePluginWeight map[string]int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
} this.sessionKey = signingKey; } else { log.trace("Not yet initializing signing"); } response = new SmbComSessionSetupAndXResponse(getContext().getConfig(), null); response.setExtendedSecurity(true);
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Nov 14 17:41:04 UTC 2021 - 49K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
scheduler.NewRateLimitedTimedQueue( flowcontrol.NewTokenBucketRateLimiter(nc.evictionLimiterQPS, scheduler.EvictionRateLimiterBurst)) // Init the metric for the new zone. logger.Info("Initializing eviction metric for zone", "zone", zone) evictionsTotal.WithLabelValues(zone).Add(0) } } func (nc *Controller) markNodeForTainting(node *v1.Node, status v1.ConditionStatus) bool { nc.evictorLock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
healthzServer *healthcheck.ProxierHealthServer, healthzBindAddress string, config config.KubeProxyWinkernelConfiguration, ) (*Proxier, error) { if nodeIP == nil { klog.InfoS("Invalid nodeIP, initializing kube-proxy with 127.0.0.1 as nodeIP") nodeIP = netutils.ParseIPSloppy("127.0.0.1") } // windows listens to all node addresses nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc
op, input.getType(), input, expanded_item, start_position); return success(); } bool enable_dynamic_update_slice; }; // Rewrites op of the template type initializing a TensorList with a list of ops // to generate an equivalent raw tensor. Derived classes are required to // override GetNumElements method. template <typename OpT>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 70.7K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
* New: MockWebServer's `RecordedRequest` exposes the requested `HttpUrl` with `getRequestUrl()`. ## Version 3.6.0 _2017-01-29_ * Fix: Don't crash with a "cache is closed" error when there is an error initializing the cache. * Fix: Calling `disconnect()` on a connecting `HttpUrlConnection` could cause it to retry in an infinite loop! This regression was introduced in OkHttp 2.7.0.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
t.Errorf("Unexpected error: %#v", err) } } else { if err == nil || err.Error() != apierrors.NewTooManyRequests("storage is (re)initializing", 1).Error() { t.Errorf("Unexpected error: %#v", err) } } } func TestWatcherNotGoingBackInTime(t *testing.T) { backingStorage := &dummyStorage{} cacher, v, err := newTestCacher(backingStorage)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)