- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 53 for testServer (8.41 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook_v1beta1_test.go
HTTPStatusCode() int } // NewV1beta1TestServer wraps a V1beta1Service as an httptest.Server. func NewV1beta1TestServer(s V1beta1Service, cert, key, caCert []byte) (*httptest.Server, error) { const webhookPath = "/testserver" var tlsConfig *tls.Config if cert != nil { cert, err := tls.X509KeyPair(cert, key) if err != nil { return nil, err } tlsConfig = &tls.Config{Certificates: []tls.Certificate{cert}} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 00:47:42 UTC 2022 - 19.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1beta1_test.go
HTTPStatusCode() int } // NewV1beta1TestServer wraps a V1beta1Service as an httptest.Server. func NewV1beta1TestServer(s V1beta1Service, cert, key, caCert []byte) (*httptest.Server, error) { const webhookPath = "/testserver" var tlsConfig *tls.Config if cert != nil { cert, err := tls.X509KeyPair(cert, key) if err != nil { return nil, err } tlsConfig = &tls.Config{Certificates: []tls.Certificate{cert}} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
StatusCode: 200, ResponseBody: "{}", SkipRequestFn: skipListerFunc, T: t, } testServer := httptest.NewServer(&fakeHandler) defer testServer.Close() client := clientset.NewForConfigOrDie(&restclient.Config{Host: testServer.URL, ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}}) fakePodControl := controller.FakePodControl{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
if err != nil { t.Errorf("%s: failed to create server: %v", tt.test, err) return } serverURL, err := url.Parse(server.URL) if err != nil { t.Errorf("%s: failed to parse the testserver URL: %v", tt.test, err) return } serverURL.Host = net.JoinHostPort("localhost", serverURL.Port()) defer server.Close() // Create a Kubernetes client configuration file
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
CurrentTime string NodeHealthy bool } type fakeProxierHealthChecker struct { healthy bool } func (fake fakeProxierHealthChecker) IsHealthy() bool { return fake.healthy } func TestServer(t *testing.T) { listener := newFakeListener() httpFactory := newFakeHTTPServerFactory() nodePortAddresses := proxyutil.NewNodePortAddresses(v1.IPv4Protocol, []string{}) proxyChecker := &fakeProxierHealthChecker{true}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1_test.go
HTTPStatusCode() int } // NewV1TestServer wraps a V1Service as an httptest.Server. func NewV1TestServer(s V1Service, cert, key, caCert []byte) (*httptest.Server, error) { const webhookPath = "/testserver" var tlsConfig *tls.Config if cert != nil { cert, err := tls.X509KeyPair(cert, key) if err != nil { return nil, err } tlsConfig = &tls.Config{Certificates: []tls.Certificate{cert}} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.2K bytes - Viewed (0) -
src/net/http/client_test.go
// The race detector doesn't know that we're waiting for a timeout // and thinks that the waitgroup inside httptest.Server is added to concurrently // with us closing it. If we timed out immediately, we could close the testserver // before we entered the handler. We're not timing out immediately and there's // no way we would be done before we entered the handler, but the race detector // doesn't know this, so synchronize explicitly.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
src/test/java/jcifs/tests/TestProperties.java
static final String TEST_USER_PASSWORD = "test.user.password"; static final String TEST_USER_DOMAIN = "test.user.domain"; static final String TEST_USER_DOMAIN_SHORT = "test.user.sdomain"; static final String TEST_SERVER = "test.server"; static final String TEST_DOMAIN = "test.domain"; static final String TEST_DOMAIN_SHORT = "test.domain.netbios"; static final String TEST_DOMAIN_SID = "test.domain.sid";
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sat Feb 29 16:38:58 UTC 2020 - 2.3K bytes - Viewed (0) -
pkg/registry/core/componentstatus/rest_test.go
result: resp.result, body: resp.data, err: resp.err, } return &REST{ GetServersToValidate: func() map[string]Server { return map[string]Server{ "test1": &HttpServer{Addr: "testserver1", Port: 8000, Path: "/healthz", Prober: prober}, } }, } } func createTestStatus(name string, status api.ConditionStatus, msg string, err string) *api.ComponentStatus { retVal := &api.ComponentStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/webhooks/validation/server/server_test.go
Operation: admissionv1.Create, }, } reviewJSON, err := json.Marshal(review) if err != nil { t.Fatalf("Failed to create AdmissionReview: %v", err) } return reviewJSON } func TestServe(t *testing.T) { _ = createTestWebhook(t) stop := make(chan struct{}) defer func() { close(stop) }() validReview := makeTestReview(t, true, "v1beta1")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 9.6K bytes - Viewed (0)