Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for Transport (0.2 sec)

  1. internal/config/subnet/config.go

    	cfg.Proxy = proxy
    
    	if transport == nil {
    		// when transport is nil, it means we are just validating the
    		// inputs not performing any network calls.
    		return cfg, nil
    	}
    
    	// Make sure to clone the transport before editing the ProxyURL
    	if proxyURL != nil {
    		ctransport := transport.(*http.Transport).Clone()
    		ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  2. internal/http/transports.go

    		ClientSessionCache: tls.NewLRUClientSessionCache(tlsClientSessionCacheSize),
    	}
    
    	// For more details about various values used here refer
    	// https://golang.org/pkg/net/http/#Transport documentation
    	tr := &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		DialContext:           dialContext,
    		MaxIdleConnsPerHost:   maxIdleConnsPerHost,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/event/target/webhook.go

    	target.httpClient = &http.Client{Transport: transport}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	if !yes {
    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewWebhookTarget - creates new Webhook target.
    func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  4. internal/config/identity/openid/providercfg.go

    	}
    
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    	if accessToken != "" {
    		req.Header.Set("Authorization", "Bearer "+accessToken)
    	}
    
    	client := &http.Client{
    		Transport: transport,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return nil, err
    	}
    
    	defer xhttp.DrainBody(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 29 01:27:09 GMT 2022
    - 4.6K bytes
    - Viewed (0)
  6. internal/config/policy/opa/config.go

    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    	client := &http.Client{Transport: a.Transport}
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer a.CloseRespFn(resp.Body)
    
    	return nil
    }
    
    // UnmarshalJSON - decodes JSON data.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  7. cmd/sts-handlers_test.go

    	minioClient, err := minio.New(s.endpoint, &minio.Options{
    		Creds:     cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken),
    		Secure:    s.secure,
    		Transport: s.TestSuiteCommon.client.Transport,
    	})
    	if err != nil {
    		c.Fatalf("Error initializing client: %v", err)
    	}
    
    	// Validate that the client from sts creds can access the bucket.
    	c.mustListObjects(ctx, minioClient, bucket)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  8. internal/config/identity/openid/jwt.go

    }
    
    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{
    		Transport: transport,
    	}
    	resp, err := clnt.Do(req)
    	if err != nil {
    		return d, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 8.3K bytes
    - Viewed (5)
  9. internal/config/identity/openid/openid.go

    	return cfg
    }
    
    // LookupConfig lookup jwks from config, override with any ENVs.
    func LookupConfig(s config.Config, transport http.RoundTripper, closeRespFn func(io.ReadCloser), serverRegion string) (c Config, err error) {
    	openIDClientTransport := http.DefaultTransport
    	if transport != nil {
    		openIDClientTransport = transport
    	}
    	c = Config{
    		Enabled:            false,
    		arnProviderCfgsMap: map[arn.ARN]*providerCfg{},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  10. internal/config/cache/cache.go

    		if err != nil {
    			return cfg, err
    		}
    		cfg.BlockSize = int64(objectSize)
    	}
    
    	cfg.Endpoint = env.Get(EnvEndpoint, kvs.GetWithDefault(Endpoint, DefaultKVS))
    	cfg.clnt = &http.Client{Transport: transport}
    
    	return cfg, nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top