Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for newTestServer (0.31 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/main/main.go

    limitations under the License.
    */
    
    package main
    
    import (
    	"fmt"
    
    	webhooktesting "k8s.io/apiserver/pkg/admission/plugin/webhook/testing"
    )
    
    func main() {
    	server := webhooktesting.NewTestServer(nil)
    	server.StartTLS()
    	fmt.Println("serving on", server.URL)
    	select {}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Aug 25 00:00:45 UTC 2019
    - 807 bytes
    - Viewed (0)
  2. 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)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/mod/sumdb/test.go

    	"sync"
    
    	"golang.org/x/mod/module"
    	"golang.org/x/mod/sumdb/note"
    	"golang.org/x/mod/sumdb/tlog"
    )
    
    // NewTestServer constructs a new [TestServer]
    // that will sign its tree with the given signer key
    // (see [golang.org/x/mod/sumdb/note])
    // and fetch new records as needed by calling gosum.
    func NewTestServer(signer string, gosum func(path, vers string) ([]byte, error)) *TestServer {
    	return &TestServer{signer: signer, gosum: gosum}
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jul 12 20:38:21 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  4. plugin/pkg/admission/imagepolicy/admission_test.go

    			}
    		})
    	}
    }
    
    // Service mocks a remote service.
    type Service interface {
    	Review(*v1alpha1.ImageReview)
    	HTTPStatusCode() int
    }
    
    // NewTestServer wraps a Service as an httptest.Server.
    func NewTestServer(s Service, cert, key, caCert []byte) (*httptest.Server, error) {
    	var tlsConfig *tls.Config
    	if cert != nil {
    		cert, err := tls.X509KeyPair(cert, key)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 06:05:06 UTC 2023
    - 32.9K bytes
    - Viewed (0)
  5. 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)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/webhook_server.go

    		Certificates: []tls.Certificate{sCert},
    		ClientCAs:    rootCAs,
    		ClientAuth:   tls.RequireAndVerifyClientCert,
    	}
    	return testServer
    }
    
    // NewTestServer returns a webhook test HTTPS server with fixed webhook test certs.
    func NewTestServer(t testing.TB) *httptest.Server {
    	return NewTestServerWithHandler(t, webhookHandler)
    }
    
    func webhookHandler(w http.ResponseWriter, r *http.Request) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 15 11:11:25 UTC 2021
    - 6.3K bytes
    - Viewed (0)
  7. pilot/cmd/pilot-agent/status/server_test.go

    		}
    		// error case, error string should match.
    		if !strings.Contains(err.Error(), tc.err) {
    			t.Errorf("test case failed [%v], expect error %v, got %v", tc.probe, tc.err, err)
    		}
    	}
    }
    
    func NewTestServer(t test.Failer, o Options) *Server {
    	if o.PrometheusRegistry == nil {
    		o.PrometheusRegistry = TestingRegistry(t)
    	}
    	server, err := NewServer(o)
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go

    	}
    
    	lastSHA1SigCounter := 0
    	for _, tt := range tests {
    		// Use a closure so defer statements trigger between loop iterations.
    		func() {
    			// Create and start a simple HTTPS server
    			server, err := newTestServer(tt.serverCert, tt.serverKey, tt.serverCA, nil)
    			if err != nil {
    				t.Errorf("%s: failed to create server: %v", tt.test, err)
    				return
    			}
    
    			serverURL, err := url.Parse(server.URL)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  9. src/cmd/go/proxy_test.go

    	testSumDBSignerKey   = "PRIVATE+KEY+localhost.localdev/sumdb+00000c67+AXu6+oaVaOYuQOFrf1V59JK1owcFlJcHwwXHDfDGxSPk"
    )
    
    var (
    	sumdbOps    = sumdb.NewTestServer(testSumDBSignerKey, proxyGoSum)
    	sumdbServer = sumdb.NewServer(sumdbOps)
    
    	sumdbWrongOps    = sumdb.NewTestServer(testSumDBSignerKey, proxyGoSumWrong)
    	sumdbWrongServer = sumdb.NewServer(sumdbWrongOps)
    )
    
    // proxyHandler serves the Go module proxy protocol.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 03 09:56:24 UTC 2023
    - 12K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    		Serializer:             codecs,
    	}
    
    	if _, _, err := (&group).InstallREST(container); err != nil {
    		panic(fmt.Sprintf("unable to install container %s: %v", group.GroupVersion, err))
    	}
    
    	server := newTestServer(defaultAPIServer{mux, container})
    	defer server.Close()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:15:22 UTC 2023
    - 158.7K bytes
    - Viewed (0)
Back to top