clusterapi

Documentation

Index

• func CapiChangeDiff(currentSpec, newSpec *cluster.Spec, provider providers.Provider) *types.ChangeDiff
• type CAPIChangeDiff
• type CAPIClient
• type Client
• type ClusterResourceSet
  • func NewClusterResourceSet(clusterName string) *ClusterResourceSet
  • func (c ClusterResourceSet) AddResource(name string, content []byte)
  • func (c ClusterResourceSet) ToYaml() ([]byte, error)
• type ExtraArgs
  • func AwsIamAuthExtraArgs(awsiam *v1alpha1.AWSIamConfig) ExtraArgs
  • func ControlPlaneNodeLabelsExtraArgs(cpc v1alpha1.ControlPlaneConfiguration) ExtraArgs
  • func OIDCToExtraArgs(oidc *v1alpha1.OIDCConfig) ExtraArgs
  • func PodIAMAuthExtraArgs(podIAMConfig *v1alpha1.PodIAMConfig) ExtraArgs
  • func ResolvConfExtraArgs(resolvConf *v1alpha1.ResolvConf) ExtraArgs
  • func SecureEtcdTlsCipherSuitesExtraArgs() ExtraArgs
  • func SecureTlsCipherSuitesExtraArgs() ExtraArgs
  • func WorkerNodeLabelsExtraArgs(wnc v1alpha1.WorkerNodeGroupConfiguration) ExtraArgs
  • func (e ExtraArgs) AddIfNotEmpty(k, v string)
  • func (e ExtraArgs) Append(args ExtraArgs) ExtraArgs
  • func (e ExtraArgs) ToPartialYaml() templater.PartialYaml
• type Installer
  • func NewInstaller(capiClient CAPIClient, kubectlClient KubectlClient) *Installer
  • func (i *Installer) EnsureEtcdProvidersInstallation(ctx context.Context, managementCluster *types.Cluster, ...) error
• type KubectlClient
• type Manager
  • func NewManager(capiClient CAPIClient, kubectlClient KubectlClient) *Manager
• type ResourceSetManager
  • func NewResourceSetManager(client Client) *ResourceSetManager
  • func (r *ResourceSetManager) ForceUpdate(ctx context.Context, name, namespace string, ...) error
• type Upgrader
  • func NewUpgrader(capiClient CAPIClient, kubectlClient KubectlClient) *Upgrader
  • func (u *Upgrader) Upgrade(ctx context.Context, managementCluster *types.Cluster, ...) (*types.ChangeDiff, error)

Functions

func CapiChangeDiff

func CapiChangeDiff(currentSpec, newSpec *cluster.Spec, provider providers.Provider) *types.ChangeDiff

Types

type CAPIChangeDiff

type CAPIChangeDiff struct {
	CertManager            *types.ComponentChangeDiff
	Core                   *types.ComponentChangeDiff
	ControlPlane           *types.ComponentChangeDiff
	BootstrapProviders     []types.ComponentChangeDiff
	InfrastructureProvider *types.ComponentChangeDiff
}

type CAPIClient

type CAPIClient interface {
	Upgrade(ctx context.Context, managementCluster *types.Cluster, provider providers.Provider, newSpec *cluster.Spec, changeDiff *CAPIChangeDiff) error
	InstallEtcdadmProviders(ctx context.Context, clusterSpec *cluster.Spec, cluster *types.Cluster, provider providers.Provider, installProviders []string) error
}

type Client

type Client interface {
	GetClusterResourceSet(ctx context.Context, kubeconfigFile, name, namespace string) (*addons.ClusterResourceSet, error)
	GetConfigMap(ctx context.Context, kubeconfigFile, name, namespace string) (*corev1.ConfigMap, error)
	GetSecretFromNamespace(ctx context.Context, kubeconfigFile, name, namespace string) (*corev1.Secret, error)
	ApplyKubeSpecFromBytes(ctx context.Context, cluster *types.Cluster, data []byte) error
}

type ClusterResourceSet

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

func NewClusterResourceSet

func NewClusterResourceSet(clusterName string) *ClusterResourceSet

func (ClusterResourceSet) AddResource

func (c ClusterResourceSet) AddResource(name string, content []byte)

func (ClusterResourceSet) ToYaml

func (c ClusterResourceSet) ToYaml() ([]byte, error)

type ExtraArgs

type ExtraArgs map[string]string

func AwsIamAuthExtraArgs

func AwsIamAuthExtraArgs(awsiam *v1alpha1.AWSIamConfig) ExtraArgs

func ControlPlaneNodeLabelsExtraArgs

func ControlPlaneNodeLabelsExtraArgs(cpc v1alpha1.ControlPlaneConfiguration) ExtraArgs

func OIDCToExtraArgs

func OIDCToExtraArgs(oidc *v1alpha1.OIDCConfig) ExtraArgs

func PodIAMAuthExtraArgs

func PodIAMAuthExtraArgs(podIAMConfig *v1alpha1.PodIAMConfig) ExtraArgs

func ResolvConfExtraArgs

func ResolvConfExtraArgs(resolvConf *v1alpha1.ResolvConf) ExtraArgs

func SecureEtcdTlsCipherSuitesExtraArgs

func SecureEtcdTlsCipherSuitesExtraArgs() ExtraArgs

func SecureTlsCipherSuitesExtraArgs

func SecureTlsCipherSuitesExtraArgs() ExtraArgs

We don't need to add these once the Kubernetes components default to using the secure cipher suites

func WorkerNodeLabelsExtraArgs

func WorkerNodeLabelsExtraArgs(wnc v1alpha1.WorkerNodeGroupConfiguration) ExtraArgs

func (ExtraArgs) AddIfNotEmpty

func (e ExtraArgs) AddIfNotEmpty(k, v string)

func (ExtraArgs) Append

func (e ExtraArgs) Append(args ExtraArgs) ExtraArgs

func (ExtraArgs) ToPartialYaml

func (e ExtraArgs) ToPartialYaml() templater.PartialYaml

type Installer

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

func NewInstaller

func NewInstaller(capiClient CAPIClient, kubectlClient KubectlClient) *Installer

func (*Installer) EnsureEtcdProvidersInstallation

func (i *Installer) EnsureEtcdProvidersInstallation(ctx context.Context, managementCluster *types.Cluster, provider providers.Provider, currSpec *cluster.Spec) error

type KubectlClient

type KubectlClient interface {
	CheckProviderExists(ctx context.Context, kubeconfigFile, name, namespace string) (bool, error)
}

type Manager

type Manager struct {
	*Installer
	*Upgrader
}

func NewManager

func NewManager(capiClient CAPIClient, kubectlClient KubectlClient) *Manager

type ResourceSetManager

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

ResourceSetManager helps managing capi ClusterResourceSet's It doesn't implement the complete ClusterResourceSet specification so there might be some configurations that are not supported. JsonLists as content in resources are not supported

func NewResourceSetManager

func NewResourceSetManager(client Client) *ResourceSetManager

func (*ResourceSetManager) ForceUpdate

func (r *ResourceSetManager) ForceUpdate(ctx context.Context, name, namespace string, managementCluster, workloadCluster *types.Cluster) error

type Upgrader

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

func NewUpgrader

func NewUpgrader(capiClient CAPIClient, kubectlClient KubectlClient) *Upgrader

func (*Upgrader) Upgrade

func (u *Upgrader) Upgrade(ctx context.Context, managementCluster *types.Cluster, provider providers.Provider, currentSpec, newSpec *cluster.Spec) (*types.ChangeDiff, error)