Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 21 for RoundTripper (0.32 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/update.go

    	releaseInfo = fields[1]
    
    	releaseTime, err = releaseInfoToReleaseTime(releaseInfo)
    	return sha256Sum, releaseTime, releaseInfo, err
    }
    
    func getUpdateTransport(timeout time.Duration) http.RoundTripper {
    	var updateTransport http.RoundTripper = &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		DialContext:           xhttp.NewInternodeDialContext(timeout, globalTCPOptions),
    		IdleConnTimeout:       timeout,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  2. internal/config/identity/openid/provider/keycloak.go

    }
    
    // Option is a function type that accepts a pointer Target
    type Option func(*KeycloakProvider)
    
    // WithTransport provide custom transport
    func WithTransport(transport http.RoundTripper) Option {
    	return func(p *KeycloakProvider) {
    		p.client = http.Client{
    			Transport: transport,
    		}
    	}
    }
    
    // WithOpenIDConfig provide OpenID Endpoint configuration discovery document
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jul 14 18:12:07 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  3. cmd/sftp-server-driver.go

    		remoteIP:    remoteIP,
    	}
    	return sftp.Handlers{
    		FileGet:  handler,
    		FilePut:  handler,
    		FileCmd:  handler,
    		FileList: handler,
    	}
    }
    
    type forwardForTransport struct {
    	tr  http.RoundTripper
    	fwd string
    }
    
    func (f forwardForTransport) RoundTrip(r *http.Request) (*http.Response, error) {
    	r.Header.Set("X-Forwarded-For", f.fwd)
    	return f.tr.RoundTrip(r)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 10 16:35:49 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  4. internal/config/policy/plugin/config.go

    		},
    	}
    )
    
    // Args for general purpose policy engine configuration.
    type Args struct {
    	URL         *xnet.URL             `json:"url"`
    	AuthToken   string                `json:"authToken"`
    	Transport   http.RoundTripper     `json:"-"`
    	CloseRespFn func(r io.ReadCloser) `json:"-"`
    }
    
    // Validate - validate opa configuration params.
    func (a *Args) Validate() error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  5. cmd/object-handlers.go

    }
    
    // getRemoteInstanceTransport contains a roundtripper for external (not peers) servers
    var remoteInstanceTransport atomic.Value
    
    func setRemoteInstanceTransport(tr http.RoundTripper) {
    	remoteInstanceTransport.Store(tr)
    }
    
    func getRemoteInstanceTransport() http.RoundTripper {
    	rt, ok := remoteInstanceTransport.Load().(http.RoundTripper)
    	if ok {
    		return rt
    	}
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  6. internal/config/identity/openid/jwt.go

    	CodeChallengeMethodsSupported    []string `json:"code_challenge_methods_supported,omitempty"`
    }
    
    func parseDiscoveryDoc(u *xnet.URL, transport http.RoundTripper, closeRespFn func(io.ReadCloser)) (DiscoveryDoc, error) {
    	d := DiscoveryDoc{}
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return d, err
    	}
    	clnt := http.Client{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  7. internal/config/identity/plugin/config.go

    var validRoleIDRegex = regexp.MustCompile(`^[A-Za-z0-9_-]+$`)
    
    // Args for authentication plugin.
    type Args struct {
    	URL         *xnet.URL
    	AuthToken   string
    	Transport   http.RoundTripper
    	CloseRespFn func(r io.ReadCloser)
    
    	RolePolicy string
    	RoleARN    arn.ARN
    }
    
    // Validate - validate configuration params.
    func (a *Args) Validate() error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  8. cmd/utils.go

    		TCPOptions:  globalTCPOptions,
    	}
    }
    
    // NewInternodeHTTPTransport returns a transport for internode MinIO
    // connections.
    func NewInternodeHTTPTransport(maxIdleConnsPerHost int) func() http.RoundTripper {
    	return xhttp.ConnSettings{
    		LookupHost:       globalDNSCache.LookupHost,
    		DialTimeout:      rest.DefaultTimeout,
    		RootCAs:          globalRootCAs,
    		CipherSuites:     crypto.TLSCiphers(),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  9. cmd/endpoint.go

    	URLEndpointType
    )
    
    // ProxyEndpoint - endpoint used for proxy redirects
    // See proxyRequest() for details.
    type ProxyEndpoint struct {
    	Endpoint
    	Transport http.RoundTripper
    }
    
    // Node holds information about a node in this cluster
    type Node struct {
    	*url.URL
    	Pools    []int
    	IsLocal  bool
    	GridHost string
    }
    
    // Endpoint - any type of endpoint.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  10. internal/logger/target/http/http.go

    	QueueDir    string            `json:"queueDir"`
    	MaxRetry    int               `json:"maxRetry"`
    	RetryIntvl  time.Duration     `json:"retryInterval"`
    	Proxy       string            `json:"string"`
    	Transport   http.RoundTripper `json:"-"`
    	HTTPTimeout time.Duration     `json:"httpTimeout"`
    
    	// Custom logger
    	LogOnceIf func(ctx context.Context, err error, id string, errKind ...any) `json:"-"`
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top