- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 51 for rootTask (0.17 sec)
-
cmd/update.go
DialContext: xhttp.NewInternodeDialContext(timeout, globalTCPOptions), IdleConnTimeout: timeout, TLSHandshakeTimeout: timeout, ExpectContinueTimeout: timeout, TLSClientConfig: &tls.Config{ RootCAs: globalRootCAs, ClientSessionCache: tls.NewLRUClientSessionCache(tlsClientSessionCacheSize), }, DisableCompression: true, } return updateTransport }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
src/crypto/tls/handshake_client.go
c.sendAlert(alertBadCertificate) return err } } else { opts := x509.VerifyOptions{ Roots: c.config.RootCAs, CurrentTime: c.config.time(), DNSName: c.serverName, Intermediates: x509.NewCertPool(), } for _, cert := range certs[1:] { opts.Intermediates.AddCert(cert) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 38.6K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
certPool.AppendCertsFromPEM(cc.CABundle) } else { var err error certPool, err = x509.SystemCertPool() 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 21.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc.go
} // Copied from http.DefaultTransport. tr := net.SetTransportDefaults(&http.Transport{ // According to golang's doc, if RootCAs is nil, // TLS uses the host's root CA set. TLSClientConfig: &tls.Config{RootCAs: roots}, }) client = &http.Client{Transport: tr, Timeout: 30 * time.Second} } // If the discovery URL is set in authentication configuration, we set up a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 37.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)) } // client clientCACertPool := x509.NewCertPool() clientCACertPool.AppendCertsFromPEM(tsCrt) clientTLSConfig := &tls.Config{ RootCAs: clientCACertPool, NextProtos: []string{http2.NextProtoTLS}, } tr := &panicOnNonReuseTransport{} client := &http.Client{} tr.Transport = &http2.Transport{ TLSClientConfig: clientTLSConfig, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
DisableKeepAlives: true, TLSClientConfig: &tls.Config{ // nolint: gosec // user explicitly opted into insecure InsecureSkipVerify: features.JwksResolverInsecureSkipVerify, RootCAs: caCertPool, MinVersion: tls.VersionTLS12, }, }, } } atomic.StoreUint64(&ret.refreshJobKeyChangedCount, 0) atomic.StoreUint64(&ret.refreshJobFetchFailedCount, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/model/context.go
if e != nil { e.PushContext().AddMetric(metric, key, proxyID, msg) } } func (e *Environment) Version() string { if x := e.GetLedger(); x != nil { return x.RootHash() } return "" } // Init initializes the Environment for use. func (e *Environment) Init() { // Use a default DomainSuffix, if none was provided. if len(e.DomainSuffix) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pkg/adsc/adsc.go
} // nolint: gosec // it's insecure only when a user explicitly enable insecure mode. return &tls.Config{ GetClientCertificate: getClientCertificate, Certificates: clientCerts, RootCAs: serverCAs, ServerName: shost, InsecureSkipVerify: config.InsecureSkipVerify, }, nil } // Close the stream. func (a *ADSC) Close() { a.mutex.Lock() _ = a.conn.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
} } } func newClient(useNewConnection bool) *http.Client { clientCACertPool := x509.NewCertPool() clientCACertPool.AppendCertsFromPEM(backendCrt) tlsConfig := &tls.Config{ RootCAs: clientCACertPool, NextProtos: []string{http2.NextProtoTLS}, } tr := &http.Transport{ TLSClientConfig: tlsConfig, DisableKeepAlives: useNewConnection, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
cmd/erasure-sets.go
} format, err := loadFormatErasure(disk, false) if err != nil { if errors.Is(err, errUnformattedDisk) { info, derr := disk.DiskInfo(context.TODO(), DiskInfoOptions{}) if derr != nil && info.RootDisk { disk.Close() return nil, nil, fmt.Errorf("Drive: %s is a root drive", disk) } } disk.Close() return nil, nil, fmt.Errorf("Drive: %s returned %w", disk, err) // make sure to '%w' to wrap the error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0)