[dbnode] Query logging (#2888)

m3db · Nov 17, 2020 · f5eea1e · f5eea1e
1 parent 36430cc
commit f5eea1e
Show file tree

Hide file tree

Showing 32 changed files with 1,187 additions and 191 deletions.
diff --git a/src/dbnode/generated/thrift/rpc.thrift b/src/dbnode/generated/thrift/rpc.thrift
@@ -93,6 +93,7 @@ struct FetchRequest {
 	4: required string id
 	5: optional TimeType rangeType = TimeType.UNIX_SECONDS
 	6: optional TimeType resultTimeType = TimeType.UNIX_SECONDS
+	7: optional binary source
 }
 
 struct FetchResult {
@@ -125,12 +126,14 @@ struct FetchBatchRawRequest {
 	3: required binary nameSpace
 	4: required list<binary> ids
 	5: optional TimeType rangeTimeType = TimeType.UNIX_SECONDS
+	6: optional binary source
 }
 
 
 struct FetchBatchRawV2Request {
 	1: required list<binary> nameSpaces
 	2: required list<FetchBatchRawV2RequestElement> elements
+	3: optional binary source
 }
 
 struct FetchBatchRawV2RequestElement {
@@ -173,6 +176,7 @@ struct FetchTaggedRequest {
 	7: optional TimeType rangeTimeType = TimeType.UNIX_SECONDS
 	8: optional bool requireExhaustive = true
 	9: optional i64 docsLimit
+	10: optional binary source
 }
 
 struct FetchTaggedResult {
@@ -194,6 +198,7 @@ struct FetchBlocksRawRequest {
 	1: required binary nameSpace
 	2: required i32 shard
 	3: required list<FetchBlocksRawRequestElement> elements
+	4: optional binary source
 }
 
 struct FetchBlocksRawRequestElement {
@@ -391,6 +396,7 @@ struct AggregateQueryRawRequest {
 	6: optional list<binary> tagNameFilter
 	7: optional AggregateQueryType aggregateQueryType = AggregateQueryType.AGGREGATE_BY_TAG_NAME_VALUE
 	8: optional TimeType rangeType = TimeType.UNIX_SECONDS
+	9: optional binary source
 }
 
 struct AggregateQueryRawResult {
@@ -417,6 +423,7 @@ struct AggregateQueryRequest {
 	6: optional list<string> tagNameFilter
 	7: optional AggregateQueryType aggregateQueryType = AggregateQueryType.AGGREGATE_BY_TAG_NAME_VALUE
 	8: optional TimeType rangeType = TimeType.UNIX_SECONDS
+	9: optional binary source
 }
 
 struct AggregateQueryResult {
@@ -443,6 +450,7 @@ struct QueryRequest {
 	6: optional bool noData
 	7: optional TimeType rangeType = TimeType.UNIX_SECONDS
 	8: optional TimeType resultTimeType = TimeType.UNIX_SECONDS
+	9: optional binary source
 }
 
 struct QueryResult {