feat(query): add arguments SideloadConf to /v1/query

everpcpc · everpcpc · commit 76a228c9fff9 · 2022-12-14T19:44:27.000+08:00
diff --git a/src/query/service/src/servers/http/v1/query/http_query.rs b/src/query/service/src/servers/http/v1/query/http_query.rs
@@ -59,6 +59,7 @@ pub struct HttpQueryRequest {
     pub pagination: PaginationConf,
     #[serde(default = "default_as_true")]
     pub string_fields: bool,
+    pub sideload: Option<SideloadConf>,
 }
 
 const DEFAULT_MAX_ROWS_IN_BUFFER: usize = 5 * 1000 * 1000;
@@ -141,6 +142,12 @@ impl HttpSessionConf {
     }
 }
 
+#[derive(Deserialize, Debug, Clone)]
+pub struct SideloadConf {
+    pub(crate) stage: Option<String>,
+    pub(crate) url: Option<String>,
+}
+
 #[derive(Debug, Clone)]
 pub struct ResponseState {
     pub running_time_ms: f64,

Original file line number	Diff line number	Diff line change
`@@ -59,6 +59,7 @@ pub struct HttpQueryRequest {`
`59`	`59`	`pub pagination: PaginationConf,`
`60`	`60`	`#[serde(default = "default_as_true")]`
`61`	`61`	`pub string_fields: bool,`
	`62`	`+ pub sideload: Option<SideloadConf>,`
`62`	`63`	`}`
`63`	`64`
`64`	`65`	`const DEFAULT_MAX_ROWS_IN_BUFFER: usize = 5 * 1000 * 1000;`
`@@ -141,6 +142,12 @@ impl HttpSessionConf {`
`141`	`142`	`}`
`142`	`143`	`}`
`143`	`144`
	`145`	`+#[derive(Deserialize, Debug, Clone)]`
	`146`	`+pub struct SideloadConf {`
	`147`	`+ pub(crate) stage: Option<String>,`
	`148`	`+ pub(crate) url: Option<String>,`
	`149`	`+}`
	`150`	`+`
`144`	`151`	`#[derive(Debug, Clone)]`
`145`	`152`	`pub struct ResponseState {`
`146`	`153`	`pub running_time_ms: f64,`