Skip to content

Commit

Permalink
init
Browse files Browse the repository at this point in the history
  • Loading branch information
ian-lss committed Mar 12, 2024
1 parent 23c39e9 commit 856024b
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 0 deletions.
5 changes: 5 additions & 0 deletions pkg/controllers/component_condition.go
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,12 @@ var HasTerminatingPodByListOpts = func(ctx context.Context, cli client.Client, m
if err := cli.List(ctx, podList, opts); err != nil {
return false, err
}
// Done : add logger
logger := ctrl.LoggerFrom(ctx)
logger.Info("pod lists", "pods count", len(podList.Items))

for _, pod := range podList.Items {
logger.Info("pod lists", "pod info.", pod)
if pod.DeletionTimestamp != nil {
return true, nil
}
Expand Down
4 changes: 4 additions & 0 deletions pkg/controllers/deployments.go
Original file line number Diff line number Diff line change
Expand Up @@ -120,6 +120,8 @@ func (r *MilvusReconciler) ReconcileComponentDeployment(
}

if IsEqual(old, cur) {
// Done: nothing diff
r.logger.Info("nothing diff context", "name", cur.Name, "namespace", cur.Namespace)
return nil
}

Expand Down Expand Up @@ -212,6 +214,8 @@ func (r *MilvusReconciler) ReconcileDeployments(ctx context.Context, mc v1beta1.
return err
}
for _, component := range GetComponentsBySpec(mc.Spec) {
// Done:
r.logger.Info("Reconcile Component", "name", mc.Name, "component", component.Name, "mode", mc.Spec.Mode)
if mc.Spec.Mode != v1beta1.MilvusModeStandalone &&
component == QueryNode {
g.Go(WarppedReconcileComponentFunc(r.qnController.Reconcile, gtx, mc, component))
Expand Down

0 comments on commit 856024b

Please sign in to comment.