crds

Documentation

Index

• type CNINodeReconciler
  • func NewCNINodeReconciler(client client.Client, scheme *runtime.Scheme, ctx context.Context, ...) *CNINodeReconciler
  • func (r *CNINodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CNINodeReconciler) SetupWithManager(mgr ctrl.Manager, maxNodeConcurrentReconciles int) error

Types

type CNINodeReconciler

type CNINodeReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

CNINodeReconciler reconciles a CNINode object

func NewCNINodeReconciler

func NewCNINodeReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	ctx context.Context,
	logger logr.Logger,
	ec2Wrapper ec2API.EC2Wrapper,
	k8sWrapper k8s.K8sWrapper,
	clusterName string,
	vpcId string,
	finalizerManager k8s.FinalizerManager,
	maxConcurrentWorkers int,
	newResourceCleaner func(nodeID string, eC2Wrapper ec2API.EC2Wrapper, vpcID string, log logr.Logger) cleanup.ResourceCleaner,
) *CNINodeReconciler

func (*CNINodeReconciler) Reconcile

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

Reconcile handles CNINode create/update/delete events Reconciler will add the finalizer and cluster name tag if it does not exist and finalize on CNINode on deletion to clean up leaked resource on node

func (*CNINodeReconciler) SetupWithManager

func (r *CNINodeReconciler) SetupWithManager(mgr ctrl.Manager, maxNodeConcurrentReconciles int) error

SetupWithManager sets up the controller with the Manager.