Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for TestServer (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apiserver/pkg/apis/example"
    	examplev1 "k8s.io/apiserver/pkg/apis/example/v1"
    	"k8s.io/apiserver/pkg/storage"
    	"k8s.io/apiserver/pkg/storage/etcd3/testserver"
    	storagetesting "k8s.io/apiserver/pkg/storage/testing"
    	"k8s.io/apiserver/pkg/storage/value"
    )
    
    var scheme = runtime.NewScheme()
    var codecs = serializer.NewCodecFactory(scheme)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  2. pkg/controller/controller_utils_test.go

    			fakeHandler := utiltesting.FakeHandler{
    				StatusCode:   200,
    				ResponseBody: string(body),
    			}
    			testServer := httptest.NewServer(&fakeHandler)
    			defer testServer.Close()
    			clientset := clientset.NewForConfigOrDie(&restclient.Config{Host: testServer.URL, ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}})
    
    			podControl := RealPodControl{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K 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. 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)
  5. 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)
  6. 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)
Back to top