Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 28 for RoundTripper (0.16 seconds)

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