controlplane

Documentation

Index

• func ApplyTerraform(ctx context.Context, terraformDir, tfExecPath string, ...) error
• func GetASGByName(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, ...) (*asgTypes.AutoScalingGroup, error)
• func GetClusterStatus(kopsCluster *kopsapi.Cluster, cloud fi.Cloud) (*kopsapi.ClusterStatus, error)
• func PopulateClusterSpec(kopsCluster *kopsapi.Cluster, kopsClientset simple.Clientset, cloud fi.Cloud) (*kopsapi.Cluster, error)
• func PrepareKopsCloudResources(ctx context.Context, kopsClientset simple.Clientset, ...) error
• func RegionBySubnet(kopsControlPlane *controlplanev1alpha1.KopsControlPlane) (string, error)
• type KopsControlPlaneReconciler
  • func (r *KopsControlPlaneReconciler) PrepareCustomCloudResources(ctx context.Context, kopsCluster *kopsapi.Cluster, ...) error
  • func (r *KopsControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KopsControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, workerCount int) error
• type KopsControlPlaneReconciliation
  • func (r *KopsControlPlaneReconciliation) ReconcileKopsSecrets(ctx context.Context, kopsClientset simple.Clientset, ...) error

Functions

func ApplyTerraform

func ApplyTerraform(ctx context.Context, terraformDir, tfExecPath string, credentials aws.Credentials) error

func GetASGByName

func GetASGByName(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, kopsControlPlane *controlplanev1alpha1.KopsControlPlane, creds *aws.Credentials) (*asgTypes.AutoScalingGroup, error)

GetASGByName returns the existing ASG or nothing if it doesn't exist.

func GetClusterStatus

func GetClusterStatus(kopsCluster *kopsapi.Cluster, cloud fi.Cloud) (*kopsapi.ClusterStatus, error)

func PopulateClusterSpec

func PopulateClusterSpec(kopsCluster *kopsapi.Cluster, kopsClientset simple.Clientset, cloud fi.Cloud) (*kopsapi.Cluster, error)

PopulateClusterSpec populates the full cluster spec with some values it fetchs from provider

func PrepareKopsCloudResources

func PrepareKopsCloudResources(ctx context.Context, kopsClientset simple.Clientset, kopsCluster *kopsapi.Cluster, terraformOutputDir string, cloud fi.Cloud) error

PrepareCloudResources renders the terraform files and effectively apply them in the cloud provider

func RegionBySubnet

func RegionBySubnet(kopsControlPlane *controlplanev1alpha1.KopsControlPlane) (string, error)

Types

type KopsControlPlaneReconciler

type KopsControlPlaneReconciler struct {
	client.Client
	Scheme                           *runtime.Scheme
	Mux                              *sync.Mutex
	Recorder                         record.EventRecorder
	TfExecPath                       string
	GetKopsClientSetFactory          func(configBase string) (simple.Clientset, error)
	BuildCloudFactory                func(*kopsapi.Cluster) (fi.Cloud, error)
	PopulateClusterSpecFactory       func(kopsCluster *kopsapi.Cluster, kopsClientset simple.Clientset, cloud fi.Cloud) (*kopsapi.Cluster, error)
	PrepareKopsCloudResourcesFactory func(ctx context.Context, kopsClientset simple.Clientset, kopsCluster *kopsapi.Cluster, terraformOutputDir string, cloud fi.Cloud) error
	ApplyTerraformFactory            func(ctx context.Context, terraformDir, tfExecPath string, credentials aws.Credentials) error
	ValidateKopsClusterFactory       func(kubeConfig *rest.Config, kopsCluster *kopsapi.Cluster, cloud fi.Cloud, igs *kopsapi.InstanceGroupList) (*validation.ValidationCluster, error)
	GetClusterStatusFactory          func(kopsCluster *kopsapi.Cluster, cloud fi.Cloud) (*kopsapi.ClusterStatus, error)
	GetASGByNameFactory              func(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, kopsControlPlane *controlplanev1alpha1.KopsControlPlane, credentials *aws.Credentials) (*asgTypes.AutoScalingGroup, error)
}

KopsControlPlaneReconciler reconciles a KopsControlPlane object

func (*KopsControlPlaneReconciler) PrepareCustomCloudResources

func (r *KopsControlPlaneReconciler) PrepareCustomCloudResources(ctx context.Context, kopsCluster *kopsapi.Cluster, kopsControlPlane *controlplanev1alpha1.KopsControlPlane, kmps []infrastructurev1alpha1.KopsMachinePool, shouldEnableKarpenter bool, configBase, terraformOutputDir string, shouldIgnoreSG bool) error

func (*KopsControlPlaneReconciler) Reconcile

func (r *KopsControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KopsControlPlaneReconciler) SetupWithManager

func (r *KopsControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, workerCount int) error

SetupWithManager sets up the controller with the Manager.

type KopsControlPlaneReconciliation

type KopsControlPlaneReconciliation struct {
	KopsControlPlaneReconciler
	// contains filtered or unexported fields
}

func (*KopsControlPlaneReconciliation) ReconcileKopsSecrets

func (r *KopsControlPlaneReconciliation) ReconcileKopsSecrets(ctx context.Context, kopsClientset simple.Clientset, kopsCluster *kopsapi.Cluster) error

this needs to be better named