Function TestFilterPanicPrintStackRate

proxy/proxy_test.go:1117–1149

(t *testing.T)

}

func TestFilterPanicPrintStackRate(t *testing.T) {
	testLog := NewTestLog()
	defer testLog.Close()

	fr := make(filters.Registry)
	fr.Register(new(nilFilterSpec))

	tp, err := newTestProxyWithFilters(fr, `* -> nilFilter() -> <shunt>`, FlagsNone)
	require.NoError(t, err)
	defer tp.close()

	const (
		panicsCaused  = 10
		stacksPrinted = 3 // see Proxy.onPanicSometimes
	)

	for i := 0; i < panicsCaused; i++ {
		r := httptest.NewRequest("GET", "/", nil)
		w := httptest.NewRecorder()

		tp.proxy.ServeHTTP(w, r)
	}

	const errorMsg = "error while proxying"
	if err = testLog.WaitForN(errorMsg, 10, 100*time.Millisecond); err != nil {
		t.Errorf(`expected "%s" to be logged exactly %d times`, errorMsg, panicsCaused)
	}

	const stackMsg = "github.com/zalando/skipper/proxy.TestFilterPanicPrintStackRate"
	if err = testLog.WaitForN(stackMsg, 3, 100*time.Millisecond); err != nil {
		t.Errorf(`expected "%s" to be logged exactly %d times`, stackMsg, stacksPrinted)
	}
}

func TestProcessesRequestWithShuntBackend(t *testing.T) {
	u, _ := url.ParseRequestURI("https://www.example.org/hello")