- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 132 for testserver (0.14 sec)
-
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) -
tests/test_tutorial/test_advanced_middleware/test_tutorial001.py
def test_middleware(): client = TestClient(app, base_url="https://testserver") response = client.get("/") assert response.status_code == 200, response.text client = TestClient(app) response = client.get("/", follow_redirects=False) assert response.status_code == 307, response.text
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Nov 13 14:26:09 UTC 2022 - 474 bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
} } func TestSyncEndpointsItemsPreserveNoSelector(t *testing.T) { ns := metav1.NamespaceDefault testServer, endpointsHandler := makeTestServer(t, ns) defer testServer.Close() tCtx := ktesting.Init(t) endpoints := newController(tCtx, testServer.URL, 0*time.Second) endpoints.endpointsStore.Add(&v1.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Name: "foo",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/ready/probe_test.go
g.Expect(probe.atleastOnceReady).Should(BeFalse()) server.Close() server = testserver.CreateAndStartServer(liveServerStats) probe.AdminPort = uint16(server.Listener.Addr().(*net.TCPAddr).Port) err = probe.Check() g.Expect(err).NotTo(HaveOccurred()) g.Expect(probe.atleastOnceReady).Should(BeTrue()) server.Close() server = testserver.CreateAndStartServer(noServerStats)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact_test.go
package etcd3 import ( "context" "testing" etcdrpc "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" clientv3 "go.etcd.io/etcd/client/v3" "k8s.io/apiserver/pkg/storage/etcd3/testserver" ) func TestCompact(t *testing.T) { client := testserver.RunEtcd(t, nil) ctx := context.Background() putResp, err := client.Put(ctx, "/somekey", "data") if err != nil { t.Fatalf("Put failed: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 23 14:22:57 UTC 2021 - 2.5K 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) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/server.go
} func startDefaultServer(t servertesting.Logger, flags ...string) (func(), servertesting.TestServer, error) { // create kubeconfig which will not actually be used. But authz/authn needs it to startup. fakeKubeConfig, err := os.CreateTemp("", "kubeconfig") if err != nil { return nil, servertesting.TestServer{}, err } fakeKubeConfig.WriteString(` apiVersion: v1 kind: Config clusters: - cluster:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/test-utils_test.go
testServer.Obj = objLayer testServer.rawDiskPaths = disks testServer.Disks = mustGetPoolEndpoints(0, disks...) testServer.AccessKey = credentials.AccessKey testServer.SecretKey = credentials.SecretKey httpHandler, err := configureServerHandler(testServer.Disks) if err != nil { t.Fatalf("Failed to configure one of the RPC services <ERROR> %s", err) } // Run TestServer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K 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) -
src/test/java/jcifs/tests/BaseCIFSTest.java
Assume.assumeNotNull(testDomain); return testDomain; } protected String getTestServer () { String testServer = getProperties().get(TestProperties.TEST_SERVER); Assume.assumeNotNull(testServer); return testServer; } protected String getTestUserDomain () { return getProperties().get(TestProperties.TEST_USER_DOMAIN); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.1K bytes - Viewed (0)