controlplane

Documentation

Index

• func ApplyTerraform(ctx context.Context, terraformDir, tfExecPath string) 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 PrepareCloudResources(kopsClientset simple.Clientset, kubeClient client.Client, ctx context.Context, ...) error
• type KopsControlPlaneReconciler
  • func (r *KopsControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, rerr error)
  • func (r *KopsControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

Functions

func ApplyTerraform

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

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 PrepareCloudResources

func PrepareCloudResources(kopsClientset simple.Clientset, kubeClient client.Client, ctx context.Context, kopsCluster *kopsapi.Cluster, kopsControlPlane *controlplanev1alpha1.KopsControlPlane, configBase, terraformOutputDir string, cloud fi.Cloud, shouldIgnoreSG bool) error

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

Types

type KopsControlPlaneReconciler

type KopsControlPlaneReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	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)
	PrepareCloudResourcesFactory func(kopsClientset simple.Clientset, kubeClient client.Client, ctx context.Context, kopsCluster *kopsapi.Cluster, kopsControlPlane *controlplanev1alpha1.KopsControlPlane, configBase, terraformOutputDir string, cloud fi.Cloud, shouldIgnoreSG bool) error
	ApplyTerraformFactory        func(ctx context.Context, terraformDir, tfExecPath string) error
	ValidateKopsClusterFactory   func(kopsClientset simple.Clientset, kopsCluster *kopsapi.Cluster, igs *kopsapi.InstanceGroupList) (*validation.ValidationCluster, error)
	GetClusterStatusFactory      func(kopsCluster *kopsapi.Cluster, cloud fi.Cloud) (*kopsapi.ClusterStatus, error)
	// contains filtered or unexported fields
}

KopsControlPlaneReconciler reconciles a KopsControlPlane object

func (*KopsControlPlaneReconciler) Reconcile

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

func (*KopsControlPlaneReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.