Koordinator-NodeSLO

Reconcile()

• 获取node和nodeSLO，设置nodeExist和nodeSLOExist
• node和nodeSLO都不存在，直接返回
• 若!nodeExist
  • 删除对应nodeSLO
• 若!nodeSLOExist
  • 初始化nodeSLO
  • 创建nodeSLO
• 若nodeExist和nodeSLOExist都存在
  • 获取nodeSLOSpec，若nodeSLOSpec改变了，则更新nodeSLO。

func (r *NodeSLOReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {// reconcile for 2 things://   1. ensuring the NodeSLO exists iff the Node exists//   2. update NodeSLO Spec_ = log.FromContext(ctx, "node-slo-reconciler", req.NamespacedName)// if cache unavailable, requeue the reqif !r.sloCfgCache.IsCfgAvailable() {// all nodes would be enqueued once the config is available, so here we just drop the reqklog.Warningf("slo config is not available, drop the req %v until a valid config is set",req.NamespacedName)return ctrl.Result{}, nil}// get the nodenodeExist := truenodeName := req.Namenode := &corev1.Node{}err := r.Client.Get(context.TODO(), req.NamespacedName, node)if err != nil {if !errors.IsNotFound(err) {metrics.RecordNodeSLOReconcileCount(false, "reconcileNodeGetError")klog.Errorf("failed to find node %v, error: %v", nodeName, err)return ctrl.Result{Requeue: true}, err}nodeExist = false}// get the nodeSLOnodeSLOExist := truenodeSLOName := req.NamenodeSLO := &slov1alpha1.NodeSLO{}err = r.Client.Get(context.TODO(), req.NamespacedName, nodeSLO)if err != nil {if !errors.IsNotFound(err) {metrics.RecordNodeSLOReconcileCount(false, "reconcileNodeSLOGetError")klog.Errorf("failed to find nodeSLO %v, error: %v", nodeName, err)return ctrl.Result{Requeue: true}, err}nodeSLOExist = false}// NodeSLO lifecycle managementif !nodeExist && !nodeSLOExist {// do nothing if both does not existreturn ctrl.Result{}, nil} else if !nodeExist {// delete CR if only the nodeSLO existserr = r.Client.Delete(context.TODO(), nodeSLO)if err != nil {if errors.IsNotFound(err) {klog.V(4).Infof("failed to delete nodeSLO %v because error: %v", nodeSLOName, err)return ctrl.Result{}, nil}metrics.RecordNodeSLOReconcileCount(false, "deleteNodeSLO")klog.Errorf("failed to delete nodeSLO %v, error: %v", nodeSLOName, err)return reconcile.Result{Requeue: true}, err}metrics.RecordNodeSLOReconcileCount(true, "deleteNodeSLO")return ctrl.Result{}, nil} else if !nodeSLOExist {// create and initialize CR if only the node existsif err = r.initNodeSLO(node, nodeSLO); err != nil {klog.Errorf("failed to init nodeSLO instance %v: %v", nodeSLOName, err)return ctrl.Result{Requeue: true}, err}err = r.Client.Create(context.TODO(), nodeSLO)if err != nil {metrics.RecordNodeSLOReconcileCount(false, "createNodeSLO")klog.Errorf("failed to create nodeSLO instance %v: %v", nodeSLOName, err)return ctrl.Result{Requeue: true}, err}metrics.RecordNodeSLOReconcileCount(true, "createNodeSLO")} else {// update nodeSLO spec if both existsnodeSLOSpec, err := r.getNodeSLOSpec(node, &nodeSLO.Spec)if err != nil {klog.Errorf("failed to get nodeSLO %v, spec: %v", nodeSLOName, err)return ctrl.Result{Requeue: true}, err}if !reflect.DeepEqual(nodeSLOSpec, &nodeSLO.Spec) {nodeSLO.Spec = *nodeSLOSpecerr = r.Client.Update(context.TODO(), nodeSLO)if err != nil {metrics.RecordNodeSLOReconcileCount(false, "updateNodeSLO")klog.Errorf("failed to update nodeSLO %v, error: %v", nodeSLOName, err)return ctrl.Result{Requeue: true}, err}metrics.RecordNodeSLOReconcileCount(true, "updateNodeSLO")}}klog.V(6).Infof("nodeslo-controller succeeded to update nodeSLO %v", nodeSLOName)return ctrl.Result{}, nil
}