Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for transport (0.16 sec)

  1. 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)
  2. cmd/update.go

    	if runtime.GOOS == "windows" {
    		return MinioReleaseURL + "minio.exe"
    	}
    
    	return MinioReleaseURL + "minio"
    }
    
    func getUpdateReaderFromURL(u *url.URL, transport http.RoundTripper, mode string) (io.ReadCloser, error) {
    	clnt := &http.Client{
    		Transport: transport,
    	}
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return nil, AdminError{
    			Code:       AdminUpdateUnexpectedFailure,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  3. internal/config/api/api.go

    	apiRequestsDeadline        = "requests_deadline"
    	apiClusterDeadline         = "cluster_deadline"
    	apiCorsAllowOrigin         = "cors_allow_origin"
    	apiRemoteTransportDeadline = "remote_transport_deadline"
    	apiListQuorum              = "list_quorum"
    	apiReplicationPriority     = "replication_priority"
    	apiReplicationMaxWorkers   = "replication_max_workers"
    
    	apiTransitionWorkers           = "transition_workers"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 01:08:07 GMT 2024
    - 11.1K bytes
    - Viewed (1)
  4. internal/event/target/elasticsearch.go

    	URL        xnet.URL        `json:"url"`
    	Index      string          `json:"index"`
    	QueueDir   string          `json:"queueDir"`
    	QueueLimit uint64          `json:"queueLimit"`
    	Transport  *http.Transport `json:"-"`
    	Username   string          `json:"username"`
    	Password   string          `json:"password"`
    }
    
    // Validate ElasticsearchArgs fields
    func (a ElasticsearchArgs) Validate() error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  5. cmd/config-current.go

    		logger.Fatal(errors.New("no KMS configured"), "MINIO_KMS_AUTO_ENCRYPTION requires a valid KMS configuration")
    	}
    
    	transport := NewHTTPTransport()
    
    	bootstrapTraceMsg("initialize the event notification targets")
    	globalNotifyTargetList, err = notify.FetchEnabledTargets(GlobalContext, s, transport)
    	if err != nil {
    		configLogIf(ctx, fmt.Errorf("Unable to initialize notification target(s): %w", err))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  6. internal/rest/client.go

    	}
    	// The host's colon:port should be normalized. See Issue 14836.
    	u.Host = removeEmptyPort(u.Host)
    
    	// Transport is exactly same as Go default in https://golang.org/pkg/net/http/#RoundTripper
    	// except custom DialContext and TLSClientConfig.
    	clnt := &Client{
    		httpClient:               &http.Client{Transport: tr},
    		url:                      u,
    		newAuthToken:             newAuthToken,
    		connected:                connected,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    		// value is cached we should attempt to invalidate it if such calls
    		// were attempted. This can lead to false success under certain conditions
    		// - this change attempts to avoid stale information if the underlying
    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users_test.go

    		c.Fatalf("error creating admin client: %v", err)
    	}
    	// Set transport, so that TLS is handled correctly.
    	s.adm.SetCustomTransport(s.TestSuiteCommon.client.Transport)
    
    	s.client, err = minio.New(s.endpoint, &minio.Options{
    		Creds:     credentials.NewStaticV4(s.accessKey, s.secretKey, ""),
    		Secure:    s.secure,
    		Transport: s.TestSuiteCommon.client.Transport,
    	})
    	if err != nil {
    		c.Fatalf("error creating minio client: %v", err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  9. cmd/batch-expire.go

    	if err != nil {
    		return err
    	}
    
    	if r.NotificationCfg.Token != "" {
    		req.Header.Set("Authorization", r.NotificationCfg.Token)
    	}
    
    	clnt := http.Client{Transport: getRemoteInstanceTransport()}
    	resp, err := clnt.Do(req)
    	if err != nil {
    		return err
    	}
    
    	xhttp.DrainBody(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    		return errors.New(resp.Status)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  10. internal/logger/target/http/http.go

    	// If proxy available, set the same
    	if h.config.Proxy != "" {
    		proxyURL, _ := url.Parse(h.config.Proxy)
    		transport := h.config.Transport
    		ctransport := transport.(*http.Transport).Clone()
    		ctransport.Proxy = http.ProxyURL(proxyURL)
    		h.config.Transport = ctransport
    	}
    
    	h.client = &http.Client{Transport: h.config.Transport}
    
    	if h.config.QueueDir != "" {
    
    		queueStore := store.NewQueueStore[interface{}](
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
Back to top