- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for RoundTripper (0.19 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
type SpdyRoundTripper struct { //tlsConfig holds the TLS configuration settings to use when connecting //to the remote server. tlsConfig *tls.Config /* TODO according to http://golang.org/pkg/net/http/#RoundTripper, a RoundTripper must be safe for use by multiple concurrent goroutines. If this is absolutely necessary, we could keep a map from http.Request to net.Conn. In practice,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0) -
src/net/http/filetransport.go
package http import ( "fmt" "io" "io/fs" ) // fileTransport implements RoundTripper for the 'file' protocol. type fileTransport struct { fh fileHandler } // NewFileTransport returns a new [RoundTripper], serving the provided // [FileSystem]. The returned RoundTripper ignores the URL host in its // incoming requests, as well as most other properties of the // request. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/handlers/forwarder.go
"strings" "sync" "time" ) const defaultFlushInterval = time.Duration(100) * time.Millisecond // Forwarder forwards all incoming HTTP requests to configured transport. type Forwarder struct { RoundTripper http.RoundTripper PassHost bool Logger func(error) ErrorHandler func(http.ResponseWriter, *http.Request, error) // internal variables rewriter *headerRewriter }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
src/net/http/roundtrip.go
//go:linkname badRoundTrip net/http.(*Transport).RoundTrip func badRoundTrip(*Transport, *Request) (*Response, error) // RoundTrip implements the [RoundTripper] interface. // // For higher-level HTTP client support (such as handling of cookies // and redirects), see [Get], [Post], and the [Client] type. // // Like the RoundTripper interface, the error types returned // by RoundTrip are unspecified. func (t *Transport) RoundTrip(req *Request) (*Response, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 988 bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/command_headers.go
} } // CancelRequest is propagated to the Delegate RoundTripper within // if the wrapped RoundTripper implements this function. func (c *CommandHeaderRoundTripper) CancelRequest(req *http.Request) { type canceler interface { CancelRequest(*http.Request) } // If possible, call "CancelRequest" on the wrapped Delegate RoundTripper. if cr, ok := c.Delegate.(canceler); ok { cr.CancelRequest(req) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 3.2K bytes - Viewed (0) -
pkg/kubelet/client/kubelet_client.go
return makeTransport(config, false) } // MakeInsecureTransport creates an insecure RoundTripper for HTTP Transport. func MakeInsecureTransport(config *KubeletClientConfig) (http.RoundTripper, error) { return makeTransport(config, true) } // makeTransport creates a RoundTripper for HTTP Transport. func makeTransport(config *KubeletClientConfig, insecureSkipTLSVerify bool) (http.RoundTripper, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 01:34:49 UTC 2023 - 7.4K bytes - Viewed (0) -
test/typeparam/issue50561.dir/diameter.go
hopID uint32 endID uint32 } type roundTripper struct { promise map[transactionID]Promise[*ByteBuffer] host string realm string } func (r *roundTripper) OriginHost() string { return r.host } func (r *roundTripper) OriginRealm() string { return r.realm } func NewInboundHandler(host string, realm string, productName string) InboundHandler {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 22:58:24 UTC 2022 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/x509metrics/server_cert_deprecations.go
// This indicates that this binary run with the GODEBUG=x509sha1=1 in env func NewDeprecatedCertificateRoundTripperWrapperConstructor(missingSAN, sha1 *metrics.Counter) func(rt http.RoundTripper) http.RoundTripper { return func(rt http.RoundTripper) http.RoundTripper { return &x509DeprecatedCertificateMetricsRTWrapper{ rt: rt, checkers: []deprecatedCertificateAttributeChecker{ NewSANDeprecatedChecker(missingSAN),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/http.go
} func newHTTP3TransportGetter(cfg *Config) (httpTransportGetter, func()) { newConn := func() *http3.RoundTripper { return &http3.RoundTripper{ TLSClientConfig: cfg.tlsConfig, QUICConfig: &quic.Config{}, } } closeFn := func(conn *http3.RoundTripper) func() { return func() { _ = conn.Close() } } noCloseFn := func() {} if cfg.newConnectionPerRequest {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
type upgradeRequestRoundTripper struct { http.RoundTripper upgrader http.RoundTripper } var ( _ UpgradeRequestRoundTripper = &upgradeRequestRoundTripper{} _ utilnet.RoundTripperWrapper = &upgradeRequestRoundTripper{} ) // WrappedRoundTripper returns the round tripper that a caller would use. func (rt *upgradeRequestRoundTripper) WrappedRoundTripper() http.RoundTripper { return rt.RoundTripper }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0)