- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 28 for RoundTripper (0.09 seconds)
-
internal/config/subnet/config.go
APIKey string `json:"apiKey"` // The HTTP(S) proxy URL to use for connecting to SUBNET Proxy string `json:"proxy"` // Transport configured with proxy_url if set optionally. transport http.RoundTripper // The subnet base URL BaseURL string } var configLock sync.RWMutex // Registered indicates if cluster is registered or not func (c *Config) Registered() bool { configLock.RLock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.9K bytes - Click Count (0) -
cmd/server-main.go
globalProxyEndpoints = GetProxyEndpoints(globalEndpoints, globalRemoteTargetTransport) globalForwarder = handlers.NewForwarder(&handlers.Forwarder{ PassHost: true, RoundTripper: globalRemoteTargetTransport, Logger: func(err error) { if err != nil && !errors.Is(err, context.Canceled) { proxyLogIf(GlobalContext, err) } }, })
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:18:36 GMT 2025 - 35.9K bytes - Click Count (4) -
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) -
cmd/globals.go
globalMRFState = newMRFState() // If writes to FS backend should be O_SYNC. globalFSOSync bool globalProxyEndpoints []ProxyEndpoint globalInternodeTransport http.RoundTripper globalRemoteTargetTransport http.RoundTripper globalDNSCache = &dnscache.Resolver{ Timeout: 5 * time.Second, } globalForwarder *handlers.Forwarder globalTierConfigMgr *TierConfigMgr
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 03 18:23:41 GMT 2024 - 16.2K bytes - Click Count (1) -
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/opa/config.go
}, } ) // Args opa 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.3K bytes - Click Count (0) -
internal/config/identity/openid/openid.go
// map of config names to providerCfg's ProviderCfgs map[string]*providerCfg pubKeys publicKeys roleArnPolicyMap map[arn.ARN]string transport http.RoundTripper closeRespFn func(io.ReadCloser) } // Clone returns a cloned copy of OpenID config. func (r *Config) Clone() Config { if r == nil { return Config{} } cfg := Config{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 17.3K 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)