feat(dashboard): show cluster version (#19388)

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Nov 14, 2024 · df07ffb · df07ffb
1 parent c920694
commit df07ffb
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 2 deletions.
diff --git a/dashboard/lib/api/cluster.ts b/dashboard/lib/api/cluster.ts
@@ -35,3 +35,8 @@ export async function getClusterInfoComputeNode() {
   )
   return res
 }
+
+export async function getClusterVersion() {
+  const res = await api.get("/version")
+  return res
+}
diff --git a/dashboard/pages/cluster.tsx b/dashboard/pages/cluster.tsx
@@ -36,6 +36,7 @@ import {
   getClusterInfoComputeNode,
   getClusterInfoFrontend,
   getClusterMetrics,
+  getClusterVersion,
 } from "../lib/api/cluster"
 import { WorkerNode } from "../proto/gen/common"
 
@@ -142,13 +143,15 @@ export default function Cluster() {
   const [frontendList, setFrontendList] = useState<WorkerNode[]>([])
   const [computeNodeList, setComputeNodeList] = useState<WorkerNode[]>([])
   const [metrics, setMetrics] = useState<ClusterNodeMetrics>()
+  const [version, setVersion] = useState<string>()
   const toast = useErrorToast()
 
   useEffect(() => {
     async function doFetch() {
       try {
         setFrontendList(await getClusterInfoFrontend())
         setComputeNodeList(await getClusterInfoComputeNode())
+        setVersion(await getClusterVersion())
       } catch (e: any) {
         toast(e)
       }
@@ -182,6 +185,9 @@ export default function Cluster() {
   const retVal = (
     <Box p={3}>
       <Title>Cluster Overview</Title>
+      <Text textColor="gray.500" m={0}>
+        Version: {version}
+      </Text>
       <Grid my={3} templateColumns="repeat(3, 1fr)" gap={6} width="full">
         {frontendList.map((frontend) => (
           <GridItem

diff --git a/src/meta/src/dashboard/mod.rs b/src/meta/src/dashboard/mod.rs
@@ -493,6 +493,10 @@ pub(super) mod handlers {
 
         Ok(all.into())
     }
+
+    pub async fn get_version(Extension(_srv): Extension<Service>) -> Result<Json<String>> {
+        Ok(Json(risingwave_common::current_cluster_version()))
+    }
 }
 
 impl DashboardService {
@@ -505,6 +509,7 @@ impl DashboardService {
             .allow_methods(vec![Method::GET]);
 
         let api_router = Router::new()
+            .route("/version", get(get_version))
             .route("/clusters/:ty", get(list_clusters))
             .route("/streaming_jobs", get(list_streaming_jobs))
             .route("/fragments/job_id/:job_id", get(list_fragments_by_job_id))

diff --git a/src/meta/src/manager/diagnose.rs b/src/meta/src/manager/diagnose.rs
@@ -70,8 +70,9 @@ impl DiagnoseCommand {
         let mut report = String::new();
         let _ = writeln!(
             report,
-            "report created at: {}",
-            chrono::DateTime::<chrono::offset::Utc>::from(std::time::SystemTime::now())
+            "report created at: {}\nversion: {}",
+            chrono::DateTime::<chrono::offset::Utc>::from(std::time::SystemTime::now()),
+            risingwave_common::current_cluster_version(),
         );
         let _ = writeln!(report);
         self.write_catalog(&mut report).await;