diff --git a/go/greptime/v1/prom.pb.go b/go/greptime/v1/prom.pb.go index 714d0c0..bd2d598 100644 --- a/go/greptime/v1/prom.pb.go +++ b/go/greptime/v1/prom.pb.go @@ -28,7 +28,7 @@ type PromqlRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Types that are assignable to Promql: // - // *PromqlRequest_Query + // *PromqlRequest_InstantQuery // *PromqlRequest_RangeQuery Promql isPromqlRequest_Promql `protobuf_oneof:"promql"` } @@ -79,11 +79,11 @@ func (m *PromqlRequest) GetPromql() isPromqlRequest_Promql { return nil } -func (x *PromqlRequest) GetQuery() string { - if x, ok := x.GetPromql().(*PromqlRequest_Query); ok { - return x.Query +func (x *PromqlRequest) GetInstantQuery() *PromInstantQuery { + if x, ok := x.GetPromql().(*PromqlRequest_InstantQuery); ok { + return x.InstantQuery } - return "" + return nil } func (x *PromqlRequest) GetRangeQuery() *PromRangeQuery { @@ -97,15 +97,15 @@ type isPromqlRequest_Promql interface { isPromqlRequest_Promql() } -type PromqlRequest_Query struct { - Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"` +type PromqlRequest_InstantQuery struct { + InstantQuery *PromInstantQuery `protobuf:"bytes,2,opt,name=instant_query,json=instantQuery,proto3,oneof"` } type PromqlRequest_RangeQuery struct { RangeQuery *PromRangeQuery `protobuf:"bytes,3,opt,name=range_query,json=rangeQuery,proto3,oneof"` } -func (*PromqlRequest_Query) isPromqlRequest_Promql() {} +func (*PromqlRequest_InstantQuery) isPromqlRequest_Promql() {} func (*PromqlRequest_RangeQuery) isPromqlRequest_Promql() {} @@ -164,6 +164,61 @@ func (x *PromqlResponse) GetBody() []byte { return nil } +type PromInstantQuery struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` + Time string `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` +} + +func (x *PromInstantQuery) Reset() { + *x = PromInstantQuery{} + if protoimpl.UnsafeEnabled { + mi := &file_greptime_v1_prom_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PromInstantQuery) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PromInstantQuery) ProtoMessage() {} + +func (x *PromInstantQuery) ProtoReflect() protoreflect.Message { + mi := &file_greptime_v1_prom_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PromInstantQuery.ProtoReflect.Descriptor instead. +func (*PromInstantQuery) Descriptor() ([]byte, []int) { + return file_greptime_v1_prom_proto_rawDescGZIP(), []int{2} +} + +func (x *PromInstantQuery) GetQuery() string { + if x != nil { + return x.Query + } + return "" +} + +func (x *PromInstantQuery) GetTime() string { + if x != nil { + return x.Time + } + return "" +} + type PromRangeQuery struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -178,7 +233,7 @@ type PromRangeQuery struct { func (x *PromRangeQuery) Reset() { *x = PromRangeQuery{} if protoimpl.UnsafeEnabled { - mi := &file_greptime_v1_prom_proto_msgTypes[2] + mi := &file_greptime_v1_prom_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -191,7 +246,7 @@ func (x *PromRangeQuery) String() string { func (*PromRangeQuery) ProtoMessage() {} func (x *PromRangeQuery) ProtoReflect() protoreflect.Message { - mi := &file_greptime_v1_prom_proto_msgTypes[2] + mi := &file_greptime_v1_prom_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -204,7 +259,7 @@ func (x *PromRangeQuery) ProtoReflect() protoreflect.Message { // Deprecated: Use PromRangeQuery.ProtoReflect.Descriptor instead. func (*PromRangeQuery) Descriptor() ([]byte, []int) { - return file_greptime_v1_prom_proto_rawDescGZIP(), []int{2} + return file_greptime_v1_prom_proto_rawDescGZIP(), []int{3} } func (x *PromRangeQuery) GetQuery() string { @@ -242,40 +297,47 @@ var file_greptime_v1_prom_proto_rawDesc = []byte{ 0x6f, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0b, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x18, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, - 0xa5, 0x01, 0x0a, 0x0d, 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0xd3, 0x01, 0x0a, 0x0d, 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x32, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, - 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x16, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02, - 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x3e, 0x0a, - 0x0b, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x03, 0x20, 0x01, - 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, - 0x2e, 0x50, 0x72, 0x6f, 0x6d, 0x52, 0x61, 0x6e, 0x67, 0x65, 0x51, 0x75, 0x65, 0x72, 0x79, 0x48, - 0x00, 0x52, 0x0a, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x51, 0x75, 0x65, 0x72, 0x79, 0x42, 0x08, 0x0a, - 0x06, 0x70, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x22, 0x59, 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x6d, 0x71, - 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x06, 0x68, 0x65, 0x61, - 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, - 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x12, - 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x62, 0x6f, - 0x64, 0x79, 0x22, 0x62, 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x6d, 0x52, 0x61, 0x6e, 0x67, 0x65, 0x51, + 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x44, 0x0a, 0x0d, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, + 0x5f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x6d, 0x49, + 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x51, 0x75, 0x65, 0x72, 0x79, 0x48, 0x00, 0x52, 0x0c, 0x69, + 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x51, 0x75, 0x65, 0x72, 0x79, 0x12, 0x3e, 0x0a, 0x0b, 0x72, + 0x61, 0x6e, 0x67, 0x65, 0x5f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, + 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, + 0x72, 0x6f, 0x6d, 0x52, 0x61, 0x6e, 0x67, 0x65, 0x51, 0x75, 0x65, 0x72, 0x79, 0x48, 0x00, 0x52, + 0x0a, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x51, 0x75, 0x65, 0x72, 0x79, 0x42, 0x08, 0x0a, 0x06, 0x70, + 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x22, 0x59, 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, + 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, + 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x12, 0x0a, 0x04, + 0x62, 0x6f, 0x64, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, + 0x22, 0x3c, 0x0a, 0x10, 0x50, 0x72, 0x6f, 0x6d, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x51, 0x75, 0x65, 0x72, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, - 0x61, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, 0x72, 0x74, - 0x12, 0x10, 0x0a, 0x03, 0x65, 0x6e, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x65, - 0x6e, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x73, 0x74, 0x65, 0x70, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x04, 0x73, 0x74, 0x65, 0x70, 0x32, 0x56, 0x0a, 0x11, 0x50, 0x72, 0x6f, 0x6d, 0x65, 0x74, - 0x68, 0x65, 0x75, 0x73, 0x47, 0x61, 0x74, 0x65, 0x77, 0x61, 0x79, 0x12, 0x41, 0x0a, 0x06, 0x48, - 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x1a, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, - 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x53, - 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, - 0x42, 0x0a, 0x50, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x5a, 0x35, 0x67, 0x69, - 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x01, 0x28, 0x09, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x69, + 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x22, 0x62, + 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x6d, 0x52, 0x61, 0x6e, 0x67, 0x65, 0x51, 0x75, 0x65, 0x72, 0x79, + 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x72, 0x74, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, 0x72, 0x74, 0x12, 0x10, 0x0a, 0x03, + 0x65, 0x6e, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x65, 0x6e, 0x64, 0x12, 0x12, + 0x0a, 0x04, 0x73, 0x74, 0x65, 0x70, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x73, 0x74, + 0x65, 0x70, 0x32, 0x56, 0x0a, 0x11, 0x50, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, + 0x47, 0x61, 0x74, 0x65, 0x77, 0x61, 0x79, 0x12, 0x41, 0x0a, 0x06, 0x48, 0x61, 0x6e, 0x64, 0x6c, + 0x65, 0x12, 0x1a, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x50, 0x72, 0x6f, 0x6d, 0x71, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x6d, + 0x71, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x53, 0x0a, 0x0e, 0x69, 0x6f, + 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x0a, 0x50, 0x72, + 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, + 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, + 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, + 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -290,25 +352,27 @@ func file_greptime_v1_prom_proto_rawDescGZIP() []byte { return file_greptime_v1_prom_proto_rawDescData } -var file_greptime_v1_prom_proto_msgTypes = make([]protoimpl.MessageInfo, 3) +var file_greptime_v1_prom_proto_msgTypes = make([]protoimpl.MessageInfo, 4) var file_greptime_v1_prom_proto_goTypes = []interface{}{ - (*PromqlRequest)(nil), // 0: greptime.v1.PromqlRequest - (*PromqlResponse)(nil), // 1: greptime.v1.PromqlResponse - (*PromRangeQuery)(nil), // 2: greptime.v1.PromRangeQuery - (*RequestHeader)(nil), // 3: greptime.v1.RequestHeader - (*ResponseHeader)(nil), // 4: greptime.v1.ResponseHeader + (*PromqlRequest)(nil), // 0: greptime.v1.PromqlRequest + (*PromqlResponse)(nil), // 1: greptime.v1.PromqlResponse + (*PromInstantQuery)(nil), // 2: greptime.v1.PromInstantQuery + (*PromRangeQuery)(nil), // 3: greptime.v1.PromRangeQuery + (*RequestHeader)(nil), // 4: greptime.v1.RequestHeader + (*ResponseHeader)(nil), // 5: greptime.v1.ResponseHeader } var file_greptime_v1_prom_proto_depIdxs = []int32{ - 3, // 0: greptime.v1.PromqlRequest.header:type_name -> greptime.v1.RequestHeader - 2, // 1: greptime.v1.PromqlRequest.range_query:type_name -> greptime.v1.PromRangeQuery - 4, // 2: greptime.v1.PromqlResponse.header:type_name -> greptime.v1.ResponseHeader - 0, // 3: greptime.v1.PrometheusGateway.Handle:input_type -> greptime.v1.PromqlRequest - 1, // 4: greptime.v1.PrometheusGateway.Handle:output_type -> greptime.v1.PromqlResponse - 4, // [4:5] is the sub-list for method output_type - 3, // [3:4] is the sub-list for method input_type - 3, // [3:3] is the sub-list for extension type_name - 3, // [3:3] is the sub-list for extension extendee - 0, // [0:3] is the sub-list for field type_name + 4, // 0: greptime.v1.PromqlRequest.header:type_name -> greptime.v1.RequestHeader + 2, // 1: greptime.v1.PromqlRequest.instant_query:type_name -> greptime.v1.PromInstantQuery + 3, // 2: greptime.v1.PromqlRequest.range_query:type_name -> greptime.v1.PromRangeQuery + 5, // 3: greptime.v1.PromqlResponse.header:type_name -> greptime.v1.ResponseHeader + 0, // 4: greptime.v1.PrometheusGateway.Handle:input_type -> greptime.v1.PromqlRequest + 1, // 5: greptime.v1.PrometheusGateway.Handle:output_type -> greptime.v1.PromqlResponse + 5, // [5:6] is the sub-list for method output_type + 4, // [4:5] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name } func init() { file_greptime_v1_prom_proto_init() } @@ -343,6 +407,18 @@ func file_greptime_v1_prom_proto_init() { } } file_greptime_v1_prom_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PromInstantQuery); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_greptime_v1_prom_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*PromRangeQuery); i { case 0: return &v.state @@ -356,7 +432,7 @@ func file_greptime_v1_prom_proto_init() { } } file_greptime_v1_prom_proto_msgTypes[0].OneofWrappers = []interface{}{ - (*PromqlRequest_Query)(nil), + (*PromqlRequest_InstantQuery)(nil), (*PromqlRequest_RangeQuery)(nil), } type x struct{} @@ -365,7 +441,7 @@ func file_greptime_v1_prom_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_greptime_v1_prom_proto_rawDesc, NumEnums: 0, - NumMessages: 3, + NumMessages: 4, NumExtensions: 0, NumServices: 1, }, diff --git a/proto/greptime/v1/prom.proto b/proto/greptime/v1/prom.proto index 8d10764..177fc91 100644 --- a/proto/greptime/v1/prom.proto +++ b/proto/greptime/v1/prom.proto @@ -16,7 +16,7 @@ service PrometheusGateway { message PromqlRequest { RequestHeader header = 1; oneof promql { - string query = 2; + PromInstantQuery instant_query = 2; PromRangeQuery range_query = 3; } } @@ -26,6 +26,11 @@ message PromqlResponse { bytes body = 2; // absolutely same format as Prometheus in JSON } +message PromInstantQuery { + string query = 1; + string time = 2; +} + message PromRangeQuery { string query = 1; string start = 2;