Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for CurrentCertKeyContent (0.83 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top