This pull request makes several significant enhancements to the AutoMQ status reconciliation process, including improving the handling of pod statuses and adding utility functions to streamline the code. The most important changes include updating the AutoMQ phase handling, adding a function to get the number of running pods, and importing necessary packages.
Enhancements to AutoMQ status reconciliation:
internal/controller/automq_status_controller.go: Added logic to update the AutoMQ status phase to InProcess and calculate the number of ready pods. If all required pods are running, the status phase is updated to Ready.
This pull request makes several significant enhancements to the
AutoMQstatus reconciliation process, including improving the handling of pod statuses and adding utility functions to streamline the code. The most important changes include updating theAutoMQphase handling, adding a function to get the number of running pods, and importing necessary packages.Enhancements to
AutoMQstatus reconciliation:internal/controller/automq_status_controller.go: Added logic to update theAutoMQstatus phase toInProcessand calculate the number of ready pods. If all required pods are running, the status phase is updated toReady.Utility functions:
internal/controller/automq_status_controller.go: Added a new functiongetPodRunningNumto count the number of running pods based on their status and conditions.Imports:
internal/controller/automq_status_controller.go: Imported additional packagesfmt,k8s.io/api/core/v1, andk8s.io/apimachinery/pkg/labelsto support the new functionality.Minor changes:
api/v1beta1/automq_types.go: Removed the unused constantAutoMQDefaultMessage.