configurator

Documentation

Index

• Constants
• func ClientConfig(kubeConfig string, context string) (clientcmd.ClientConfig, *rest.Config, error)
• func IsSecretNotPopulatedError(err error) bool
• func NewKubeClientFromKubeConfig(kubeConfigFile, context string) (kubernetes.Interface, error)
• func NewShipperClientFromKubeConfig(kubeConfigFile, context string) (shipperclientset.Interface, error)
• type Cluster
  • func NewClusterConfigurator(restConfig *rest.Config) (*Cluster, error)
  • func NewClusterConfiguratorFromKubeConfig(kubeConfigFile, context string) (*Cluster, error)
  • func (c *Cluster) ApproveShipperCSR() error
  • func (c *Cluster) CopySecret(cluster *shipper.Cluster, newNamespace string, secret *corev1.Secret) error
  • func (c *Cluster) CreateApplicationClusterRole(name, domain string) error
  • func (c *Cluster) CreateCertificateSigningRequest(csr []byte) error
  • func (c *Cluster) CreateClusterRoleBinding(...) error
  • func (c *Cluster) CreateManagementClusterRole(name, domain string) error
  • func (c *Cluster) CreateNamespace(namespace string) error
  • func (c *Cluster) CreateOrUpdateCRD(crd *apiextensionv1beta1.CustomResourceDefinition) error
  • func (c *Cluster) CreateOrUpdateCluster(cluster *shipper.Cluster) error
  • func (c *Cluster) CreateOrUpdateValidatingWebhookConfiguration(caBundle []byte, namespace string, setToIgnore bool) error
  • func (c *Cluster) CreateOrUpdateValidatingWebhookService(namespace string) error
  • func (c *Cluster) CreateServiceAccount(domain, namespace string, name string) error
  • func (c *Cluster) CreateValidatingWebhookSecret(privateKey, certificate []byte, namespace string) error
  • func (c *Cluster) FetchCertificateFromCSR() ([]byte, error)
  • func (c *Cluster) FetchCluster(clusterName string) (*shipper.Cluster, error)
  • func (c *Cluster) FetchKubernetesCABundle() ([]byte, error)
  • func (c *Cluster) FetchSecretForServiceAccount(name, namespace string) (*corev1.Secret, error)
  • func (c *Cluster) ShouldCopySecret(name, namespace string) (bool, error)
  • func (c *Cluster) UpdateValidatingWebhookConfigurationFailurePolicyToFail() error
  • func (c *Cluster) ValidatingWebhookSecretExists(namespace string) (bool, error)
• type SecretNotPopulatedError
  • func NewSecretNotPopulatedError(serviceAccount *corev1.ServiceAccount) *SecretNotPopulatedError
  • func (s SecretNotPopulatedError) Error() string

Constants

const (
	MaximumRetries = 20
	AgentName      = "configurator"
)

Functions

func ClientConfig

func ClientConfig(kubeConfig string, context string) (clientcmd.ClientConfig, *rest.Config, error)

func IsSecretNotPopulatedError

func IsSecretNotPopulatedError(err error) bool

func NewKubeClientFromKubeConfig

func NewKubeClientFromKubeConfig(kubeConfigFile, context string) (kubernetes.Interface, error)

func NewShipperClientFromKubeConfig

func NewShipperClientFromKubeConfig(kubeConfigFile, context string) (shipperclientset.Interface, error)

Types

type Cluster

type Cluster struct {
	KubeClient         kubernetes.Interface
	ShipperClient      shipperclientset.Interface
	ApiExtensionClient apiextensionclientset.Interface
	Host               string
}

func NewClusterConfigurator

func NewClusterConfigurator(restConfig *rest.Config) (*Cluster, error)

func NewClusterConfiguratorFromKubeConfig

func NewClusterConfiguratorFromKubeConfig(kubeConfigFile, context string) (*Cluster, error)

func (*Cluster) ApproveShipperCSR

func (c *Cluster) ApproveShipperCSR() error

func (*Cluster) CopySecret

func (c *Cluster) CopySecret(cluster *shipper.Cluster, newNamespace string, secret *corev1.Secret) error

func (*Cluster) CreateApplicationClusterRole

func (c *Cluster) CreateApplicationClusterRole(name, domain string) error

func (*Cluster) CreateCertificateSigningRequest

func (c *Cluster) CreateCertificateSigningRequest(csr []byte) error

func (*Cluster) CreateClusterRoleBinding

func (c *Cluster) CreateClusterRoleBinding(domain, clusterRoleBindingName, clusterRoleName, subjectName, subjectNamespace string) error

func (*Cluster) CreateManagementClusterRole

func (c *Cluster) CreateManagementClusterRole(name, domain string) error

func (*Cluster) CreateNamespace

func (c *Cluster) CreateNamespace(namespace string) error

func (*Cluster) CreateOrUpdateCRD

func (c *Cluster) CreateOrUpdateCRD(crd *apiextensionv1beta1.CustomResourceDefinition) error

func (*Cluster) CreateOrUpdateCluster

func (c *Cluster) CreateOrUpdateCluster(cluster *shipper.Cluster) error

func (*Cluster) CreateOrUpdateValidatingWebhookConfiguration

func (c *Cluster) CreateOrUpdateValidatingWebhookConfiguration(caBundle []byte, namespace string, setToIgnore bool) error

func (*Cluster) CreateOrUpdateValidatingWebhookService

func (c *Cluster) CreateOrUpdateValidatingWebhookService(namespace string) error

func (*Cluster) CreateServiceAccount

func (c *Cluster) CreateServiceAccount(domain, namespace string, name string) error

func (*Cluster) CreateValidatingWebhookSecret

func (c *Cluster) CreateValidatingWebhookSecret(privateKey, certificate []byte, namespace string) error

func (*Cluster) FetchCertificateFromCSR

func (c *Cluster) FetchCertificateFromCSR() ([]byte, error)

FetchCertificateFromCSR continually fetches the Shipper CSR until it is populated with a certificate and then returns the PEM-encoded certificate from the Status. This is a blocking function.

Note that the returned certificate is already PEM-encoded.

func (*Cluster) FetchCluster

func (c *Cluster) FetchCluster(clusterName string) (*shipper.Cluster, error)

func (*Cluster) FetchKubernetesCABundle

func (c *Cluster) FetchKubernetesCABundle() ([]byte, error)

func (*Cluster) FetchSecretForServiceAccount

func (c *Cluster) FetchSecretForServiceAccount(name, namespace string) (*corev1.Secret, error)

FetchSecretForServiceAccount polls the server 10 times with a 1 second delay between each. If there is still no secret, it returns a SecretNotPopulated error.

func (*Cluster) ShouldCopySecret

func (c *Cluster) ShouldCopySecret(name, namespace string) (bool, error)

func (*Cluster) UpdateValidatingWebhookConfigurationFailurePolicyToFail

func (c *Cluster) UpdateValidatingWebhookConfigurationFailurePolicyToFail() error

func (*Cluster) ValidatingWebhookSecretExists

func (c *Cluster) ValidatingWebhookSecretExists(namespace string) (bool, error)

type SecretNotPopulatedError

type SecretNotPopulatedError struct {
	ServiceAccount *corev1.ServiceAccount
}

func NewSecretNotPopulatedError

func NewSecretNotPopulatedError(serviceAccount *corev1.ServiceAccount) *SecretNotPopulatedError

func (SecretNotPopulatedError) Error

func (s SecretNotPopulatedError) Error() string