Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ResetForTest (0.12 sec)

  1. 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)
  2. 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)
Back to top