- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for CurrentCertKeyContent (0.83 sec)
-
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/server_test.go
}() time.Sleep(1 * time.Second) expectedDefaultCertBytes, _ := defaultCertProvider.CurrentCertKeyContent() expectedServiceCertBytes, _ := sniCerts[0].CurrentCertKeyContent() expectedLocalhostCertBytes, _ := sniCerts[1].CurrentCertKeyContent() expectedServiceV6CertBytes, _ := sniCerts[2].CurrentCertKeyContent() tests := []struct { name string serverName string expected []byte }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/static_content.go
} // Name is just an identifier func (c *staticCertKeyContent) Name() string { return c.name } func (c *staticCertKeyContent) AddListener(Listener) {} // CurrentCertKeyContent provides cert and key content func (c *staticCertKeyContent) CurrentCertKeyContent() ([]byte, []byte) { return c.cert, c.key } type staticSNICertKeyContent struct { staticCertKeyContent sniNames []string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/interfaces.go
// CertKeyContentProvider provides a certificate and matching private key. type CertKeyContentProvider interface { Notifier // Name is just an identifier. Name() string // CurrentCertKeyContent provides cert and key byte content. CurrentCertKeyContent() ([]byte, []byte) } // SNICertKeyContentProvider provides a certificate and matching private key as // well as optional explicit names. type SNICertKeyContentProvider interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 2K bytes - Viewed (0) -
pkg/controller/certificates/signer/ca_provider.go
caValue atomic.Value caLoader *dynamiccertificates.DynamicCertKeyPairContent } // setCA unconditionally stores the current cert/key content func (p *caProvider) setCA() error { certPEM, keyPEM := p.caLoader.CurrentCertKeyContent() certs, err := cert.ParseCertsPEM(certPEM) if err != nil { return fmt.Errorf("error reading CA cert file %q: %v", p.caLoader.Name(), err) } if len(certs) != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 16 18:33:22 UTC 2021 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
return true } // Name is just an identifier func (c *DynamicCertKeyPairContent) Name() string { return c.name } // CurrentCertKeyContent provides cert and key byte content func (c *DynamicCertKeyPairContent) CurrentCertKeyContent() ([]byte, []byte) { certKeyContent := c.certKeyPair.Load().(*certKeyContent) return certKeyContent.cert, certKeyContent.key
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
newContent.clientCA = caBundleContent{caBundle: currClientCABundle} } if c.servingCert != nil { currServingCert, currServingKey := c.servingCert.CurrentCertKeyContent() if len(currServingCert) == 0 || len(currServingKey) == 0 { return nil, fmt.Errorf("not loading an empty serving certificate from %q", c.servingCert.Name()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/named_certificates_test.go
return base64.StdEncoding.EncodeToString(cert.Signature) } func certSignature(certProvider CertKeyContentProvider) (string, error) { currentCert, currentKey := certProvider.CurrentCertKeyContent() tlsCert, err := tls.X509KeyPair(currentCert, currentKey) if err != nil { return "", err } x509Certs, err := x509.ParseCertificates(tlsCert.Certificate[0]) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 20 08:42:09 UTC 2021 - 8K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
} // Enqueue implements the functions to be notified when the serving cert content changes. func (m *kubeletServerCertificateDynamicFileManager) Enqueue() { certContent, keyContent := m.dynamicCertificateContent.CurrentCertKeyContent() cert, err := tls.X509KeyPair(certContent, keyContent) if err != nil { klog.ErrorS(err, "invalid certificate and key pair from file", "certFile", m.certFile, "keyFile", m.keyFile) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0)