add serde tag for compaction mode.

apache · Sep 24, 2024 · 1beaa16 · 1beaa16
1 parent bf3b67c
commit 1beaa16
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/docs/example-cluster-3.toml b/docs/example-cluster-3.toml
@@ -28,8 +28,9 @@ grpc_port = 8833
 mysql_port = 23307
 deploy_mode = "Cluster"
 
-[analytic]
-compaction_offload = true
+[analytic.compaction_mode]
+compaction_mode = "Offload"
+node_picker = "Remote"
 
 [analytic.storage]
 mem_cache_capacity = '1G'

diff --git a/src/analytic_engine/src/compaction/runner/node_picker.rs b/src/analytic_engine/src/compaction/runner/node_picker.rs
@@ -26,6 +26,7 @@ use serde::{Deserialize, Serialize};
 use snafu::{ResultExt, Snafu};
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
+#[serde(tag = "node_picker", content = "endpoint")]
 pub enum NodePicker {
     // Local node picker that specifies the local endpoint.
     // The endpoint in the form `addr:port`.

diff --git a/src/analytic_engine/src/lib.rs b/src/analytic_engine/src/lib.rs
@@ -62,6 +62,7 @@ pub use crate::{
 ///
 /// [CompactionMode::Local] means local compaction, no offloading.
 #[derive(Clone, Default, Debug, Deserialize, Serialize)]
+#[serde(tag = "compaction_mode")]
 pub enum CompactionMode {
     #[default]
     Local,