kube

Documentation

Index

• Constants
• func ExtractCertInfo(scrt *v1.Secret) (certInfo *credentials.CertInfo, err error)
• type AggregateController
  • func (a *AggregateController) AddEventHandler(f func(name string, namespace string))
  • func (a *AggregateController) Authorize(serviceAccount, namespace string) error
  • func (a *AggregateController) GetCaCert(name, namespace string) (certInfo *credentials.CertInfo, err error)
  • func (a *AggregateController) GetCertInfo(name, namespace string) (certInfo *credentials.CertInfo, err error)
  • func (a *AggregateController) GetDockerCredential(name, namespace string) ([]byte, error)
• type CredentialsController
  • func NewCredentialsController(kc kube.Client, handlers []func(name string, namespace string)) *CredentialsController
  • func (s *CredentialsController) Authorize(serviceAccount, namespace string) error
  • func (s *CredentialsController) Close()
  • func (s *CredentialsController) GetCaCert(name, namespace string) (certInfo *credentials.CertInfo, err error)
  • func (s *CredentialsController) GetCertInfo(name, namespace string) (certInfo *credentials.CertInfo, err error)
  • func (s *CredentialsController) GetDockerCredential(name, namespace string) ([]byte, error)
  • func (s *CredentialsController) HasSynced() bool
• type Multicluster
  • func NewMulticluster(configCluster cluster.ID, controller multicluster.ComponentBuilder) *Multicluster
  • func (m *Multicluster) AddSecretHandler(h func(name string, namespace string))
  • func (m *Multicluster) ForCluster(clusterID cluster.ID) (credentials.Controller, error)

Constants

const (
	// The ID/name for the certificate chain in kubernetes generic secret.
	GenericScrtCert = "cert"
	// The ID/name for the private key in kubernetes generic secret.
	GenericScrtKey = "key"
	// The ID/name for the CA certificate in kubernetes generic secret.
	GenericScrtCaCert = "cacert"
	// The ID/name for the CRL in kubernetes generic secret.
	GenericScrtCRL = "crl"

	// The ID/name for the certificate chain in kubernetes tls secret.
	TLSSecretCert = "tls.crt"
	// The ID/name for the k8sKey in kubernetes tls secret.
	TLSSecretKey = "tls.key"
	// The ID/name for the certificate OCSP staple in kubernetes tls secret
	TLSSecretOcspStaple = "tls.ocsp-staple"
	// The ID/name for the CA certificate in kubernetes tls secret
	TLSSecretCaCert = "ca.crt"
	// The ID/name for the CRL in kubernetes tls secret.
	TLSSecretCrl = "ca.crl"
)

Functions

func ExtractCertInfo

func ExtractCertInfo(scrt *v1.Secret) (certInfo *credentials.CertInfo, err error)

ExtractCertInfo extracts server key, certificate, and OCSP staple

Types

type AggregateController

type AggregateController struct {
	// contains filtered or unexported fields
}

func (*AggregateController) AddEventHandler

func (a *AggregateController) AddEventHandler(f func(name string, namespace string))

func (*AggregateController) Authorize

func (a *AggregateController) Authorize(serviceAccount, namespace string) error

func (*AggregateController) GetCaCert

func (a *AggregateController) GetCaCert(name, namespace string) (certInfo *credentials.CertInfo, err error)

func (*AggregateController) GetCertInfo

func (a *AggregateController) GetCertInfo(name, namespace string) (certInfo *credentials.CertInfo, err error)

func (*AggregateController) GetDockerCredential

func (a *AggregateController) GetDockerCredential(name, namespace string) ([]byte, error)

type CredentialsController

type CredentialsController struct {
	// contains filtered or unexported fields
}

func NewCredentialsController

func NewCredentialsController(kc kube.Client, handlers []func(name string, namespace string)) *CredentialsController

func (*CredentialsController) Authorize

func (s *CredentialsController) Authorize(serviceAccount, namespace string) error

func (*CredentialsController) Close

func (s *CredentialsController) Close()

func (*CredentialsController) GetCaCert

func (s *CredentialsController) GetCaCert(name, namespace string) (certInfo *credentials.CertInfo, err error)

func (*CredentialsController) GetCertInfo

func (s *CredentialsController) GetCertInfo(name, namespace string) (certInfo *credentials.CertInfo, err error)

func (*CredentialsController) GetDockerCredential

func (s *CredentialsController) GetDockerCredential(name, namespace string) ([]byte, error)

func (*CredentialsController) HasSynced

func (s *CredentialsController) HasSynced() bool

type Multicluster

type Multicluster struct {
	// contains filtered or unexported fields
}

Multicluster structure holds the remote kube Controllers and multicluster specific attributes.

func NewMulticluster

func NewMulticluster(configCluster cluster.ID, controller multicluster.ComponentBuilder) *Multicluster

func (*Multicluster) AddSecretHandler

func (m *Multicluster) AddSecretHandler(h func(name string, namespace string))

func (*Multicluster) ForCluster

func (m *Multicluster) ForCluster(clusterID cluster.ID) (credentials.Controller, error)