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 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, 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 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, credentials *aws.Credentials) 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
	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)
	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, credentials *aws.Credentials) 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) 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