- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for reportCmd (0.33 sec)
-
pkg/kubelet/kubelet.go
// status to master. It is only used when node lease feature is enabled. nodeStatusReportFrequency time.Duration // lastStatusReportTime is the time when node status was last reported. lastStatusReportTime time.Time // syncNodeStatusMux is a lock on updating the node status, because this path is not thread-safe.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go
if err := wait.PollUntilContextTimeout(ctx, time.Second, time.Minute, true, func(context.Context) (bool, error) { healthErr := a.HealthCheck() if healthErr == nil { return false, fmt.Errorf("authenticator reported healthy when it should not") } if strings.HasPrefix(healthErr.Error(), c.wantHealthErrPrefix) { return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 97.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
existingNode *v1.Node // existing node object expectedNode *v1.Node // new node object after patch expectedReportedInUse []v1.UniqueVolumeName // expected volumes reported in use in volumeManager }{ { desc: "no volumes and no update",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
testSecureStreamingPost(TransferKind.FIXED_LENGTH) } @Test fun secureChunkedStreaming() { testSecureStreamingPost(TransferKind.CHUNKED) } /** * Users have reported problems using HTTPS with streaming request bodies. * http://code.google.com/p/android/issues/detail?id=12860 */ private fun testSecureStreamingPost(streamingMode: TransferKind) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
APIVersion: "v1", Name: "pod", }, Namespace: "ns1", }, }, } err := gc.orphanDependents(logger, objectReference{}, dependents) expected := `the server reported a conflict` if err == nil || !strings.Contains(err.Error(), expected) { if err != nil { t.Errorf("expected error contains text %q, got %q", expected, err.Error()) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
src/net/http/serve_test.go
get := func() string { return get(t, c, ts.URL) } a1, a2 := get(), get() if a1 == a2 { t.Logf("made two requests from a single conn %q (as expected)", a1) } else { t.Errorf("server reported requests from %q and %q; expected same connection", a1, a2) } // The two requests should have used the same connection, // and there should not have been a second connection that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
if diff := cmp.Diff(wantBindings, bindings); diff != "" { t.Errorf("pods were scheduled incorrectly (-want, +got):\n%s", diff) } if diff := cmp.Diff(wantControllers, controllers); diff != "" { t.Errorf("events were reported with wrong controllers (-want, +got):\n%s", diff) } } // TestSchedulerGuaranteeNonNilNodeInSchedulingCycle is for detecting potential panic on nil Node when iterating Nodes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
List<String> results = getDone(compound); assertThat(results).containsExactly(DATA1, DATA2, DATA3).inOrder(); } /** A single non-error failure is not logged because it is reported via the output future. */ public void testAllAsList_logging_exception() throws Exception { try { getDone(allAsList(immediateFailedFuture(new MyException()))); fail();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
List<String> results = getDone(compound); assertThat(results).containsExactly(DATA1, DATA2, DATA3).inOrder(); } /** A single non-error failure is not logged because it is reported via the output future. */ public void testAllAsList_logging_exception() throws Exception { try { getDone(allAsList(immediateFailedFuture(new MyException()))); fail();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
cmd/bucket-replication.go
// only at bucket level instead. VersionSuspended: globalBucketVersioningSys.Suspended(bucket), }) if err != nil && !isErrVersionNotFound(err) { // VersionNotFound would be reported by pool that object version is missing on. sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{ Bucket: bucket, Name: dobj.ObjectName, VersionID: versionID,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)