- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 54 for vlogf (0.04 sec)
-
pkg/apis/core/v1/defaults_test.go
if !reflect.DeepEqual(expectedDefaults, defaults) { t.Errorf("Defaults for PodTemplateSpec changed. This can cause spurious rollouts of workloads on API server upgrade.") t.Logf(cmp.Diff(expectedDefaults, defaults)) } }) t.Run("hostnet PodTemplateSpec with ports", func(t *testing.T) { rc := &v1.ReplicationController{ Spec: v1.ReplicationControllerSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
src/net/http/fs_test.go
t.Fatalf("ReadAll %s: %v", suffix, err) } res.Body.Close() return string(b) } if s := get("/bar/"); !strings.Contains(s, ">foo.txt<") { t.Logf("expected a directory listing with foo.txt, got %q", s) } if s := get("/bar/foo.txt"); s != "Hello world" { t.Logf("expected %q, got %q", "Hello world", s) } } func TestDirJoin(t *testing.T) { if runtime.GOOS == "windows" { t.Skip("skipping test on windows")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
specVolumeName: "test.spec.1", path: filepath.Join(tmpDir, fmt.Sprintf("pods/%s/volumes/kubernetes.io~csi/%s/%s", testPodUID, "test.spec.1", "/mount")), }, } for _, tc := range testCases { t.Logf("test case: %s", tc.name) registerFakePlugin(testDriver, "endpoint", []string{"1.0.0"}, t) pv := makeTestPV(tc.specVolumeName, 10, testDriver, testVol)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
pod2 := pod1 pod2.Labels = labelMap2 pod2.ResourceVersion = "2" manager.updatePod(logger, &pod1, &pod2) expected := sets.NewString(testRSSpec1.Name) for _, name := range expected.List() { t.Logf("Expecting update for %+v", name) select { case got := <-received: if !expected.Has(got) { t.Errorf("Expected keys %#v got %v", expected, got) } case <-time.After(wait.ForeverTestTimeout):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
recordingConn, childProcess, err = test.connFromCommand() if err != nil { t.Fatalf("Failed to start subcommand: %s", err) } serverConn = recordingConn defer func() { if t.Failed() { t.Logf("OpenSSL output:\n\n%s", childProcess.Stdout) } }() } else { clientConn, serverConn = localPipe(t) } config := test.config if config == nil { config = testConfig }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
// Dial: we triggered the timeout at the point where we wanted it! t.Logf("Listener accepted a connection from %s", lconn.RemoteAddr()) lconn.Close() } // Close any spurious extra connections from the listener. (This is // possible if there are, for example, stray Dial calls from other tests.) for extraConn := range acceptc { t.Logf("spurious extra connection from %s", extraConn.RemoteAddr()) extraConn.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
} time.Sleep(tc.finalDelay) assert.Len(t, client.Actions(), tc.wantRequestCount) // In case of error, make debugging easier. for _, action := range client.Actions() { t.Logf("action: %v %v", action.GetVerb(), action.GetResource()) } }) } } // TestPodUpdatesBatching verifies that endpoint updates caused by pod updates are batched together.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
actualEvents := make([]watch.Event, len(events)) for idx := range events { select { case event := <-w.ResultChan(): actualEvents[idx] = event case <-time.After(wait.ForeverTestTimeout): t.Logf("(called from line %d)", line) t.Errorf("Timed out waiting for an event") } } validateEvents := func(expected, actual watch.Event) (bool, []string) { errors := []string{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
// evictions into account, or re-queue the PDB for another sync (by returning // an error) if err := dc.sync(ctx, pdbKey); err != nil { t.Logf("sync() returned with error: %v", err) } else { t.Logf("sync() returned with no error") } // (C) Whether or not sync() returned an error, the PDB status should reflect // the evictions that took place.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go
fuzzer.Fuzz(q) b, err := json.Marshal(q) if err != nil { t.Errorf("error encoding %v: %v", q, err) continue } q2 := &Quantity{} err = json.Unmarshal(b, q2) if err != nil { t.Logf("%d: %s", i, string(b)) t.Errorf("%v: error decoding %v: %v", q, string(b), err) } if q2.Cmp(*q) != 0 { t.Errorf("Expected equal: %v, %v (json was '%v')", q, q2, string(b)) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 49.4K bytes - Viewed (0)