- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for TestHandler (0.17 sec)
-
pkg/kube/multicluster/secretcontroller_test.go
return slices.Map(component.All(), func(e testHandler) result { return result{e.ID, e.Iter} }) }, step.want) }) } } type testHandler struct { ID cluster.ID Iter int Closed *atomic.Bool Synced *atomic.Bool } func (h testHandler) Close() { h.Closed.Store(true) } func (h testHandler) HasSynced() bool { return h.Synced.Load()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
t.Errorf("expected 3 open ports, got %d\n%s", len(listener.openPorts), dump.Pretty(listener.openPorts)) } // test the handlers testHandler(hcs, nsn1, http.StatusServiceUnavailable, 0, t) testHandler(hcs, nsn2, http.StatusServiceUnavailable, 0, t) testHandler(hcs, nsn3, http.StatusServiceUnavailable, 0, t) // sync endpoints hcs.SyncEndpoints(map[types.NamespacedName]int{ nsn1: 9, nsn2: 3,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
internal/grid/grid_test.go
t.Log("client after", time.Since(clientEnd)) } // local to remote, unbuffered t.Run("unbuffered", func(t *testing.T) { testHandler(t, handlerTest, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, false) }) t.Run("buffered", func(t *testing.T) { testHandler(t, handlerTest2, true) }) } // testStreamDeadline will test if server
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
} } func TestWarningWithRequestTimeout(t *testing.T) { type result struct { err interface{} stackTrace string } clientDoneCh, resultCh := make(chan struct{}), make(chan result, 1) testHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // this will catch recoverable panic like 'Header called after Handler finished'. // go runtime crashes the program if it detects a program-ending
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
src/expvar/expvar_test.go
t.Errorf(`f.Value() = %q, want %q`, v, x) } x = 17 if s, exp := f.String(), `17`; s != exp { t.Errorf(`f.String() = %q, want %q`, s, exp) } } func TestHandler(t *testing.T) { RemoveAll() m := NewMap("map1") m.Add("a", 1) m.Add("z", 2) m2 := NewMap("map2") for i := 0; i < 9; i++ { m2.Add(strconv.Itoa(i), int64(i)) } rr := httptest.NewRecorder()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:46:19 UTC 2024 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
// LoopbackClientConfig is a config for a privileged loopback connection to the API server LoopbackClientConfig *restclient.Config // minRequestTimeout is how short the request timeout can be. This is used to build the RESTHandler minRequestTimeout time.Duration // ShutdownTimeout is the timeout used for server shutdown. This specifies the timeout before server // gracefully shutdown returns. ShutdownTimeout time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0)