- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for TestServer (0.38 sec)
-
cmd/kube-apiserver/app/testing/testserver.go
// an apiserver version skew scenario where all apiservers use the same proxyCA to verify client connections. ProxyCA *ProxyCA } // TestServer return values supplied by kube-test-ApiServer type TestServer struct { ClientConfig *restclient.Config // Rest client config ServerOpts *options.ServerRunOptions // ServerOpts
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
} // TearDownFunc is to be called to tear down a test server. type TearDownFunc func() // TestServerInstanceOptions Instance options the TestServer type TestServerInstanceOptions struct { } // TestServer return values supplied by kube-test-ApiServer type TestServer struct { ClientConfig *restclient.Config // Rest client config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
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) -
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) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K 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) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
"k8s.io/apiserver/pkg/apis/example" examplev1 "k8s.io/apiserver/pkg/apis/example/v1" "k8s.io/apiserver/pkg/storage/etcd3/testing/testingcert" "k8s.io/apiserver/pkg/storage/etcd3/testserver" "k8s.io/apiserver/pkg/storage/storagebackend" ) var scheme = runtime.NewScheme() var codecs = serializer.NewCodecFactory(scheme) func init() { metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonInitialCommunicationFailureIntegrationSpec.groovy
import static org.gradle.test.fixtures.ConcurrentTestUtil.poll @Requires(IntegTestPreconditions.CanKillProcess) class DaemonInitialCommunicationFailureIntegrationSpec extends DaemonIntegrationSpec { @Rule TestServer server = new TestServer() @Issue("GRADLE-2444") @Flaky(because = "https://github.com/gradle/gradle-private/issues/4202") def "behaves if the registry contains connectable port without daemon on the other end"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 07:46:29 UTC 2024 - 6.5K bytes - Viewed (0) -
src/net/http/httptest/server_test.go
ts.StartTLS() return ts }, } func TestServer(t *testing.T) { for _, name := range []string{"NewServer", "NewServerManual"} { t.Run(name, func(t *testing.T) { newServer := newServers[name] t.Run("Server", func(t *testing.T) { testServer(t, newServer) }) t.Run("GetAfterClose", func(t *testing.T) { testGetAfterClose(t, newServer) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:12 UTC 2024 - 7.4K bytes - Viewed (0)