[dbnode] AggregateTiles RPC - minimal E2E flow (#2466)

m3db · Aug 19, 2020 · 0dbbff1 · 0dbbff1
1 parent 81ce0ed
commit 0dbbff1
Show file tree

Hide file tree

Showing 19 changed files with 1,966 additions and 155 deletions.
diff --git a/src/dbnode/generated/thrift/rpc.thrift b/src/dbnode/generated/thrift/rpc.thrift
@@ -64,6 +64,8 @@ service Node {
 	void repair() throws (1: Error err)
 	TruncateResult truncate(1: TruncateRequest req) throws (1: Error err)
 
+    AggregateTilesResult aggregateTiles(1: AggregateTilesRequest req) throws (1: Error err)
+
 	// Management endpoints
 	NodeHealthResult health() throws (1: Error err)
 	// NB: bootstrapped is for use with cluster management tools like k8s.
@@ -491,6 +493,20 @@ struct Query {
   7: optional FieldQuery       field
 }
 
+struct AggregateTilesRequest {
+	1: required string sourceNameSpace
+	2: required string targetNameSpace
+	3: required i64 rangeStart
+	4: required i64 rangeEnd
+	5: required string step
+	6: bool removeResets
+	7: optional TimeType rangeType = TimeType.UNIX_SECONDS
+}
+
+struct AggregateTilesResult {
+    1: required i64 processedBlockCount
+}
+
 struct DebugProfileStartRequest {
 	1: required string name
 	2: required string filePathTemplate