- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 66 for transport (0.2 sec)
-
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) -
internal/handlers/forwarder.go
"net/http" "net/http/httputil" "net/url" "strings" "sync" "time" ) const defaultFlushInterval = time.Duration(100) * time.Millisecond // Forwarder forwards all incoming HTTP requests to configured transport. type Forwarder struct { RoundTripper http.RoundTripper PassHost bool Logger func(error) ErrorHandler func(http.ResponseWriter, *http.Request, error) // internal variables
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
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) -
cmd/handler-utils.go
// proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } f := handlers.NewForwarder(&handlers.Forwarder{ PassHost: true, RoundTripper: ep.Transport, ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) { success = false if err != nil && !errors.Is(err, context.Canceled) { replLogIf(GlobalContext, err) } }, })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
istioctl/pkg/kubeinject/kubeinject.go
if err != nil { return nil, err } } tlsClientConfig := &tls.Config{RootCAs: certPool, MinVersion: tls.VersionTLS12} client := http.Client{ Timeout: time.Second * 5, Transport: &http.Transport{ TLSClientConfig: tlsClientConfig, }, } if cc.Service != nil { svc, err := e.client.Kube().CoreV1().Services(cc.Service.Namespace).Get(context.Background(), cc.Service.Name, metav1.GetOptions{})
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
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) -
internal/config/browser/help.go
}, config.HelpKV{ Key: browserHSTSSeconds, Description: `set Strict-Transport-Security 'max-age' amount of seconds value` + defaultHelpPostfix(browserHSTSSeconds), Optional: true, Type: "number", }, config.HelpKV{ Key: browserHSTSIncludeSubdomains, Description: `turn 'on' to set Strict-Transport-Security 'includeSubDomains' directive` + defaultHelpPostfix(browserHSTSIncludeSubdomains),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 01 16:36:33 GMT 2024 - 2.1K bytes - Viewed (0) -
internal/config/notify/parse.go
func TestSubSysNotificationTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error { if err := checkValidNotificationKeysForSubSys(subSys, cfg[subSys]); err != nil { return err } targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return err } for _, target := range targetList { defer target.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
internal/config/identity/plugin/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 } type serviceRTTMinuteStats struct { statsTime time.Time
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
cmd/bucket-targets.go
creds := credentials.NewStaticV4(config.AccessKey, config.SecretKey, "") api, err := minio.New(tcfg.Endpoint, &minio.Options{ Creds: creds, Secure: tcfg.Secure, Region: tcfg.Region, Transport: globalRemoteTargetTransport, }) if err != nil { return nil, err } api.SetAppInfo("minio-replication-target", ReleaseTag+" "+tcfg.Arn) hcDuration := defaultHealthCheckDuration
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0)