Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 81 for RoundTripper (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top