1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
syntax = "proto3";
package svc.query.v1;
import "google/protobuf/duration.proto";
import "google/protobuf/timestamp.proto";
import "types/v1/cursor.proto";
import "types/v1/logevent.proto";
import "types/v1/logquery.proto";
import "types/v1/query.proto";
import "types/v1/session.proto";
import "types/v1/symbol.proto";
import "types/v1/types.proto";
option go_package = "svc/query/v1;queryv1";
service QueryService {
rpc SummarizeEvents(SummarizeEventsRequest) returns (SummarizeEventsResponse);
rpc WatchQuery(WatchQueryRequest) returns (stream WatchQueryResponse);
// rpc CreateWatch(CreateWatchRequest) returns (CreateWatchResponse);
// rpc GetWatch(GetWatchRequest) returns (GetWatchResponse);
// rpc UpdateWatch(UpdateWatchRequest) returns (UpdateWatchResponse);
// rpc ListWatch(ListWatchRequest) returns (ListWatchResponse);
// rpc DeleteWatch(DeleteWatchRequest) returns (GetWatchResponse);
rpc Parse(ParseRequest) returns (ParseResponse);
rpc Query(QueryRequest) returns (QueryResponse);
rpc ListSymbols(ListSymbolsRequest) returns (ListSymbolsResponse);
}
message SummarizeEventsRequest {
int64 environment_id = 1;
optional google.protobuf.Timestamp from = 2;
optional google.protobuf.Timestamp to = 3;
uint32 bucket_count = 4;
}
message SummarizeEventsResponse {
google.protobuf.Duration bucket_width = 1;
repeated Bucket buckets = 2;
message Bucket {
google.protobuf.Timestamp ts = 1;
uint64 event_count = 2;
}
}
message WatchQueryRequest {
int64 environment_id = 1;
message UnstablePlaintext {
google.protobuf.Timestamp from = 1;
google.protobuf.Timestamp to = 2;
string query = 3;
}
types.v1.LogQuery query = 2;
UnstablePlaintext plaintext_query = 201;
}
message WatchQueryResponse {
repeated types.v1.LogEventGroup events = 1;
}
message ParseRequest {
string query = 1;
}
message ParseResponse {
types.v1.LogQuery query = 1;
types.v1.DataStreamType data_type = 2;
}
message QueryRequest {
int64 environment_id = 101;
types.v1.Cursor cursor = 102;
int32 limit = 103;
types.v1.LogQuery query = 2;
}
message QueryResponse {
types.v1.Cursor next = 100;
types.v1.Data data = 200;
}
message ListSymbolsRequest {
int64 environment_id = 101;
types.v1.Cursor cursor = 102;
int32 limit = 103;
}
message ListSymbolsResponse {
message ListItem {
types.v1.Symbol symbol = 2;
}
types.v1.Cursor next = 100;
repeated ListItem items = 200;
}
|
