Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[query] Query attribution #2888

Merged
merged 1 commit into from
Nov 17, 2020
Merged

[query] Query attribution #2888

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions src/dbnode/generated/thrift/rpc.thrift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down Expand Up @@ -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 {
Expand Down Expand Up @@ -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 {
Expand All @@ -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 {
Expand Down Expand Up @@ -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 {
Expand All @@ -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 {
Expand All @@ -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 {
Expand Down
Loading