- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for roundTrip (0.16 sec)
-
pkg/apis/core/v1/defaults_test.go
obj := roundTrip(t, runtime.Object(in)) out := obj.(*v1.Service) if out.Spec.Ports[0].TargetPort != intstr.FromInt32(1234) { t.Errorf("Expected TargetPort to be defaulted, got %v", out.Spec.Ports[0].TargetPort) } in = &v1.Service{Spec: v1.ServiceSpec{Ports: []v1.ServicePort{{Port: 1234, TargetPort: intstr.FromInt32(5678)}}}} obj = roundTrip(t, runtime.Object(in)) out = obj.(*v1.Service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
src/net/http/transport.go
} // Transport request context. // // If RoundTrip returns an error, it cancels this context before returning. // // If RoundTrip returns no error: // - For an HTTP/1 request, persistConn.readLoop cancels this context // after reading the request body. // - For an HTTP/2 request, RoundTrip cancels this context after the HTTP/2 // RoundTripper returns.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/net/url/url_test.go
t.Errorf("QueryEscape(%q) = %q, want %q", tt.in, actual, tt.out) } // for bonus points, verify that escape:unescape is an identity. roundtrip, err := QueryUnescape(actual) if roundtrip != tt.in || err != nil { t.Errorf("QueryUnescape(%q) = %q, %s; want %q, %s", actual, roundtrip, err, tt.in, "[no error]") } } } var pathEscapeTests = []EscapeTest{ { "", "", nil, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:52:38 UTC 2024 - 52.1K bytes - Viewed (0) -
src/net/http/client_test.go
} } type roundTripperWithoutCloseIdle struct{} func (roundTripperWithoutCloseIdle) RoundTrip(*Request) (*Response, error) { panic("unused") } type roundTripperWithCloseIdle func() // underlying func is CloseIdleConnections func func (roundTripperWithCloseIdle) RoundTrip(*Request) (*Response, error) { panic("unused") } func (f roundTripperWithCloseIdle) CloseIdleConnections() { f() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
} resp.Body.Close() } } type failingRoundTripper struct{} func (failingRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return nil, errors.New("some error") } type staticResponseRoundTripper struct{ res *http.Response } func (rt staticResponseRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return rt.res, nil } func TestReverseProxyErrorHandler(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/encoding/json/decode_test.go
} // Check round trip also decodes correctly. if tt.err == nil { enc, err := Marshal(v.Interface()) if err != nil { t.Fatalf("%s: Marshal error after roundtrip: %v", tt.Where, err) } if tt.golden && !bytes.Equal(enc, in) { t.Errorf("%s: Marshal:\n\tgot: %s\n\twant: %s", tt.Where, enc, in) } vv := reflect.New(reflect.TypeOf(tt.ptr).Elem())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 16:40:14 UTC 2024 - 67.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
defer close(firstReqRoundTripDoneCh) t.Logf("At %s, Sending request: %q", time.Now().Format(timeFmt), firstRequestTimesOutPath) resp, err := requestGetter(firstRequestTimesOutPath) t.Logf("At %s, RoundTrip of request: %q has completed", time.Now().Format(timeFmt), firstRequestTimesOutPath) firstReqResultCh <- result{err: err, response: resp} }() go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/net/http/request.go
// [Request.Body] is set to body and will be closed (possibly // asynchronously) by the Client methods Do, Post, and PostForm, // and [Transport.RoundTrip]. // // NewRequestWithContext returns a Request suitable for use with // [Client.Do] or [Transport.RoundTrip]. To create a request for use with // testing a Server Handler, either use the [NewRequest] function in the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
pkg/apis/flowcontrol/validation/validation_test.go
field.Invalid(field.NewPath("spec").Child("limited").Child("limitResponse").Child("queuing").Child("handSize"), int32(8), "should not be greater than queues (7)"), }, }, { name: "the roundtrip annotation is forbidden", priorityLevelConfiguration: &flowcontrol.PriorityLevelConfiguration{ ObjectMeta: metav1.ObjectMeta{ Name: "with-forbidden-annotation", Annotations: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 54.7K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
t.Errorf("expected pod ip:%v does not match actual %v", tc.expectedIP, podIP) } }) } } type fakeTransport struct { val string } func (f fakeTransport) RoundTrip(*http.Request) (*http.Response, error) { return nil, nil } var ( fakeSecureRoundTripper = fakeTransport{val: "secure"} fakeInsecureRoundTripper = fakeTransport{val: "insecure"} )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0)