configurator

Documentation

Index

• Constants
• func IsSecretNotPopulatedError(err error) bool
• type Cluster
  • func NewClusterConfigurator(clusterConfiguration *config.ClusterConfiguration, kubeConfigFile string) (*Cluster, error)
  • func (c *Cluster) ApproveShipperCSR() error
  • func (c *Cluster) CopySecret(cluster *shipper.Cluster, newNamespace string, secret *corev1.Secret) error
  • func (c *Cluster) CreateCertificateSigningRequest(csr []byte) error
  • func (c *Cluster) CreateClusterFromConfig(configuration *config.ClusterConfiguration) error
  • func (c *Cluster) CreateClusterRole(domain, name string) error
  • func (c *Cluster) CreateClusterRoleBinding(...) error
  • func (c *Cluster) CreateCrd(crd *apiextensionv1beta1.CustomResourceDefinition) error
  • func (c *Cluster) CreateNamespace(namespace string) error
  • func (c *Cluster) CreateOrUpdateCRD(crd *apiextensionv1beta1.CustomResourceDefinition) error
  • func (c *Cluster) CreateOrUpdateClusterWithConfig(configuration *config.ClusterConfiguration) error
  • func (c *Cluster) CreateOrUpdateValidatingWebhookConfiguration(caBundle []byte, namespace string) 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) 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 IsSecretNotPopulatedError

func IsSecretNotPopulatedError(err error) bool

Types

type Cluster

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

func NewClusterConfigurator

func NewClusterConfigurator(clusterConfiguration *config.ClusterConfiguration, kubeConfigFile 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) CreateCertificateSigningRequest

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

func (*Cluster) CreateClusterFromConfig

func (c *Cluster) CreateClusterFromConfig(configuration *config.ClusterConfiguration) error

func (*Cluster) CreateClusterRole

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

func (*Cluster) CreateClusterRoleBinding

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

func (*Cluster) CreateCrd

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

func (*Cluster) CreateNamespace

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

func (*Cluster) CreateOrUpdateCRD

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

func (*Cluster) CreateOrUpdateClusterWithConfig

func (c *Cluster) CreateOrUpdateClusterWithConfig(configuration *config.ClusterConfiguration) error

func (*Cluster) CreateOrUpdateValidatingWebhookConfiguration

func (c *Cluster) CreateOrUpdateValidatingWebhookConfiguration(caBundle []byte, namespace string) 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) 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