- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 21 for RoundTripper (0.32 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)