- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for updateTransport (0.22 sec)
-
pkg/kubelet/certificate/transport.go
// to continue checking the manager. func UpdateTransport(stopCh <-chan struct{}, clientConfig *restclient.Config, clientCertificateManager certificate.Manager, exitAfter time.Duration) (func(), error) { return updateTransport(stopCh, 10*time.Second, clientConfig, clientCertificateManager, exitAfter) } // updateTransport is an internal method that exposes how often this method checks that the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 13:57:45 UTC 2022 - 6.5K bytes - Viewed (0) -
pkg/kubelet/certificate/transport_test.go
NegotiatedSerializer: serializer.NegotiatedSerializerWrapper(runtime.SerializerInfo{}), }, } // Check for a new cert every 10 milliseconds if _, err := updateTransport(stop, 10*time.Millisecond, c, m, 0); err != nil { t.Fatal(err) } client, err := rest.UnversionedRESTClientFor(c) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 18 08:52:58 UTC 2020 - 7.8K bytes - Viewed (0) -
cmd/update.go
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,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
cmd/kubelet/app/server.go
// or the bootstrapping credentials to potentially lay down new initial config. closeAllConns, err := kubeletcertificate.UpdateTransport(wait.NeverStop, transportConfig, clientCertificateManager, 5*time.Minute) if err != nil { return nil, nil, err } var onHeartbeatFailure func()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0)