release: Add functions and interfaces related to health checks (robustmq#1785)

* dev

Signed-off-by: socutes <socutes@gmail.com>

* dev

Signed-off-by: socutes <socutes@gmail.com>

* dev

Signed-off-by: socutes <socutes@gmail.com>

---------

Signed-off-by: socutes <socutes@gmail.com>
Co-authored-by: socutes <socutes@gmail.com>

Author: socutes

Cargo.lock

@@ -53,7 +53,7 @@ members = [
 resolver = "2"
 
 [workspace.package]
-version = "0.3.2"
+version = "0.3.3"
 edition = "2021"
 license = "Apache-2.0"
 

Cargo.toml

@@ -46,6 +46,7 @@ bytes.workspace = true
 validator.workspace = true
 rocksdb-engine.workspace = true
 connector.workspace = true
+common-healthy.workspace = true
 
 [dev-dependencies]
 mockall.workspace = true

src/admin-server/Cargo.toml

@@ -12,7 +12,9 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+use axum::http::StatusCode;
 use common_base::http_response::success_response;
+use common_healthy::ready::healthy_ready_check;
 use serde::{Deserialize, Serialize};
 
 #[derive(Serialize, Deserialize, Debug)]
@@ -30,16 +32,26 @@ fn build_placeholder_resp(check_type: &str) -> String {
     })
 }
 
-pub async fn health_live() -> String {
-    build_placeholder_resp("live")
-}
-
-pub async fn health_ready() -> String {
-    build_placeholder_resp("ready")
-}
-
-pub async fn health_startup() -> String {
-    build_placeholder_resp("startup")
+pub async fn health_ready() -> (StatusCode, String) {
+    if healthy_ready_check() {
+        (
+            StatusCode::OK,
+            success_response(HealthCheckResp {
+                status: "ok".to_string(),
+                check_type: "ready".to_string(),
+                message: "all configured ports are ready".to_string(),
+            }),
+        )
+    } else {
+        (
+            StatusCode::SERVICE_UNAVAILABLE,
+            success_response(HealthCheckResp {
+                status: "not_ready".to_string(),
+                check_type: "ready".to_string(),
+                message: "one or more configured ports are not ready".to_string(),
+            }),
+        )
+    }
 }
 
 pub async fn health_node() -> String {