- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for testserver (0.22 sec)
-
cmd/kube-apiserver/app/testing/testserver.go
// an apiserver version skew scenario where all apiservers use the same proxyCA to verify client connections. ProxyCA *ProxyCA } // TestServer return values supplied by kube-test-ApiServer type TestServer struct { ClientConfig *restclient.Config // Rest client config ServerOpts *options.ServerRunOptions // ServerOpts
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go
b.Log("to run a standalone server, run:") b.Log("go run k8s.io/apiserver/pkg/admission/plugin/webhook/testing/main/main.go") testServer := webhooktesting.NewTestServer(b) testServer.StartTLS() defer testServer.Close() testServerURL = testServer.URL } serverURL, err := url.ParseRequestURI(testServerURL) if err != nil { b.Fatalf("this should never happen? %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go
b.Log("to run a standalone server, run:") b.Log("go run k8s.io/apiserver/pkg/admission/plugin/webhook/testing/main/main.go") testServer := webhooktesting.NewTestServer(b) testServer.StartTLS() defer testServer.Close() testServerURL = testServer.URL } objectInterfaces := webhooktesting.NewObjectInterfacesForTest() serverURL, err := url.ParseRequestURI(testServerURL) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/config/http_test.go
} fakeHandler := utiltesting.FakeHandler{ StatusCode: http.StatusOK, ResponseBody: string(data), } testServer := httptest.NewServer(&fakeHandler) defer testServer.Close() ch := make(chan interface{}, 1) c := sourceURL{testServer.URL, http.Header{}, "localhost", ch, nil, 0, http.DefaultClient} if err := c.extractFromURL(); err == nil { t.Errorf("%s: Expected error", testCase.desc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory_test.go
return clientv3.OpResponse{}, nil } func (mockKV) Txn(ctx context.Context) clientv3.Txn { return nil } func TestCreateHealthcheck(t *testing.T) { etcdConfig := testserver.NewTestConfig(t) client := testserver.RunEtcd(t, etcdConfig) newETCD3ClientFn := newETCD3Client defer func() { newETCD3Client = newETCD3ClientFn }() tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 12.1K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice_test.go
}, } usefakePrivateKeyProviderConf = false ) type TestServer struct { t *testing.T server *Server udsPath string store *ca2.DirectSecretManager } func (s *TestServer) Connect() *xds.AdsTest { conn, err := setupConnection(s.udsPath) if err != nil { s.t.Fatal(err) } return xds.NewSdsTest(s.t, conn) } func (s *TestServer) UpdateSecret(name string, secret *ca2.SecretItem) { s.t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 17 20:12:58 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/x509metrics/server_cert_deprecations_test.go
RootCAs: rootCAs, } tlsServer := httptest.NewUnstartedServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { w.WriteHeader(200) w.Write([]byte("ok")) })) tlsServer.TLS = tlsConfig tlsServer.StartTLS() serverURL, err := url.Parse(tlsServer.URL) if err != nil { tlsServer.Close() t.Fatalf("failed to parse the testserver URL: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 25.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/watch" "k8s.io/apiserver/pkg/apis/example" "k8s.io/apiserver/pkg/features" "k8s.io/apiserver/pkg/storage" "k8s.io/apiserver/pkg/storage/etcd3/testserver" storagetesting "k8s.io/apiserver/pkg/storage/testing" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/utils/ptr" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
} return eventC } testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { cniAddServerCalled = true if serverErr { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte("server not happy")) return } res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) return testServer.URL, func() bool { testServer.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
probes: []ready.Prober{rp, urp}, err: errors.New("not ready"), }, } testServer := testserver.CreateAndStartServer(liveServerStats) defer testServer.Close() for _, tc := range testCases { server, err := NewServer(Options{ Probes: tc.probes, AdminPort: uint16(testServer.Listener.Addr().(*net.TCPAddr).Port), }) if err != nil { t.Errorf("failed to construct server")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0)