- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 38 for vlogf (0.46 sec)
-
pkg/kubelet/pluginmanager/plugin_manager_test.go
100*time.Millisecond, func() (bool, error) { fakePluginHandler.Lock() defer fakePluginHandler.Unlock() if reflect.DeepEqual(fakePluginHandler.events, expected) { return true, nil } t.Logf("expected %#v, got %#v, will retry", expected, fakePluginHandler.events) return false, nil }, ) if err != nil { t.Fatalf("Timed out waiting for plugin to be added to actual state of world cache.") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
query := buildQuery(localSrc, localDst) stc.Logf("prometheus query: %#v", query) err := retry.Until(func() bool { stc.Logf("sending call from %q to %q", deployName(localSrc), localDst.Config().Service) localSrc.CallOrFail(stc, opt) reqs, err := prom.QuerySum(localSrc.Config().Cluster, query) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
continue } found++ VerifyFilterChain(t, have, want) } if found == 0 { t.Fatalf("No matching chain found for %+v", want) } if found > 1 { t.Logf("warning: multiple matching chains found for %+v", want) } } } } } func VerifyFilterChain(t test.Failer, have *listener.FilterChain, want FilterChainTest) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet_test.go
c3 := m.Current() if c3 == nil { return false, fmt.Errorf("expected valid certificate regardless of file changes, but got nil") } if bytes.Equal(c.Certificate[0], c3.Certificate[0]) { t.Logf("loaded certificate is not updated") return false, nil } return true, nil }) if err != nil { t.Errorf("failed to provide the updated certificate after file changes: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:40 UTC 2024 - 7.4K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(err) var n int stream.Requests <- []byte(strconv.Itoa(n)) for resp := range stream.responses { errFatal(resp.Err) t.Logf("got resp: %+v", string(resp.Msg)) if string(resp.Msg) != testPayload+strconv.Itoa(n) { t.Errorf("want %q, got %q", testPayload+strconv.Itoa(n), string(resp.Msg)) } if n == 10 { close(stream.Requests)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/func.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/simulation/traffic.go
t.Errorf("want cluster matched %q got %q", want.ClusterMatched, r.ClusterMatched) } else { want.ClusterMatched = r.ClusterMatched } if t.Failed() { t.Logf("Diff: %+v", diff) t.Logf("Full Diff: %+v", cmp.Diff(want, r, cmpopts.IgnoreUnexported(Result{}), cmpopts.EquateErrors())) } else if want.Skip != "" { t.Skipf("Known bug: %v", r.Skip) } } type Simulation struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0) -
src/net/http/transport.go
} } // tLogKey is a context WithValue key for test debugging contexts containing // a t.Logf func. See export_test.go's Request.WithT method. type tLogKey struct{} func (tr *transportRequest) logf(format string, args ...any) { if logf, ok := tr.Request.Context().Value(tLogKey{}).(func(string, ...any)); ok { logf(time.Now().Format(time.RFC3339Nano)+": "+format, args...) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/net/http/server.go
func (w *response) WriteHeader(code int) { if w.conn.hijacked() { caller := relevantCaller() w.conn.server.logf("http: response.WriteHeader on hijacked connection from %s (%s:%d)", caller.Function, path.Base(caller.File), caller.Line) return } if w.wroteHeader { caller := relevantCaller() w.conn.server.logf("http: superfluous response.WriteHeader call from %s (%s:%d)", caller.Function, path.Base(caller.File), caller.Line)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
for _, cl := range t.Clusters() { if !cl.IsPrimary() && d.requirePrimary { // Skip verification of dashboards that won't be present on non primary(remote) clusters. continue } t.Logf("Verifying %s for cluster %s", d.name, cl.Name()) cm, err := cl.Kube().CoreV1().ConfigMaps(ist.Settings().TelemetryNamespace).Get( context.TODO(), d.configmap, metav1.GetOptions{}) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0)