- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 132 for testserver (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testserver/test_server.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package testserver import ( "fmt" "net" "net/url" "os" "strconv" "testing" "time" clientv3 "go.etcd.io/etcd/client/v3" "go.etcd.io/etcd/server/v3/embed" "go.uber.org/zap/zapcore"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 06 11:40:40 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/watch" "k8s.io/apiserver/pkg/apis/example" "k8s.io/apiserver/pkg/features" "k8s.io/apiserver/pkg/storage" "k8s.io/apiserver/pkg/storage/etcd3/testserver" storagetesting "k8s.io/apiserver/pkg/storage/testing" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/utils/ptr" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
src/net/rpc/jsonrpc/all_test.go
var resp ArithAddResp if err := dec.Decode(&resp); err != nil { t.Fatalf("Decode after empty: %s", err) } if resp.Error == nil { t.Fatalf("Expected error, got nil") } } func TestServer(t *testing.T) { cli, srv := net.Pipe() defer cli.Close() go ServeConn(srv) dec := json.NewDecoder(cli) // Send hand-coded requests to server, parse responses. for i := 0; i < 10; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:09:53 UTC 2022 - 7.8K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
} return eventC } testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { cniAddServerCalled = true if serverErr { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte("server not happy")) return } res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) return testServer.URL, func() bool { testServer.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0) -
cmd/server_test.go
s.testServer.cancel() s.testServer.Server.Close() s.testServer.Obj.Shutdown(context.Background()) // Restart. ctx, cancel := context.WithCancel(context.Background()) s.testServer.cancel = cancel s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths) if s.secure { s.testServer.Server.StartTLS() } else { s.testServer.Server.Start() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
probes: []ready.Prober{rp, urp}, err: errors.New("not ready"), }, } testServer := testserver.CreateAndStartServer(liveServerStats) defer testServer.Close() for _, tc := range testCases { server, err := NewServer(Options{ Probes: tc.probes, AdminPort: uint16(testServer.Listener.Addr().(*net.TCPAddr).Port), }) if err != nil { t.Errorf("failed to construct server")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
name string responses []string } var authTests = []authTest{ {PlainAuth("", "user", "pass", "testserver"), []string{}, "PLAIN", []string{"\x00user\x00pass"}}, {PlainAuth("foo", "bar", "baz", "testserver"), []string{}, "PLAIN", []string{"foo\x00bar\x00baz"}}, {CRAMMD5Auth("user", "pass"), []string{"<123456.1322876914@testserver>"}, "CRAM-MD5", []string{"", "user 287eb355114cf5c471c26a875f1ca4ae"}}, } func TestAuth(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
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) -
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) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/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: Fri Mar 18 00:47:42 UTC 2022 - 19.1K bytes - Viewed (0)