- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ResetForTest (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
// compared the random data sent on STDIN to ensure they are the same. func TestStreamTranslator_LoopbackStdinToStdout(t *testing.T) { metrics.Register() metrics.ResetForTest() t.Cleanup(metrics.ResetForTest) // Create upstream fake SPDY server which copies STDIN back onto STDOUT stream. spdyServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/metrics/metrics.go
StabilityLevel: metrics.ALPHA, }, []string{statuscode}, ) ) func Register() { registerMetricsOnce.Do(func() { legacyregistry.MustRegister(streamTranslatorRequestsTotal) }) } func ResetForTest() { streamTranslatorRequestsTotal.Reset() } // IncStreamTranslatorRequest increments the # of requests handled by the StreamTranslatorProxy. func IncStreamTranslatorRequest(ctx context.Context, status string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 1.7K bytes - Viewed (0)