Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 53 for testServer (8.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top