// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.36.11 // protoc v3.21.12 // source: logtail.proto package logtailpb import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" unsafe "unsafe" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) // StatusOp is the comparison operator applied to http_response in a Filter. // Defaults to EQ (exact match) for backward compatibility. type StatusOp int32 const ( StatusOp_EQ StatusOp = 0 // == StatusOp_NE StatusOp = 1 // != StatusOp_GT StatusOp = 2 // > StatusOp_GE StatusOp = 3 // >= StatusOp_LT StatusOp = 4 // < StatusOp_LE StatusOp = 5 // <= ) // Enum value maps for StatusOp. var ( StatusOp_name = map[int32]string{ 0: "EQ", 1: "NE", 2: "GT", 3: "GE", 4: "LT", 5: "LE", } StatusOp_value = map[string]int32{ "EQ": 0, "NE": 1, "GT": 2, "GE": 3, "LT": 4, "LE": 5, } ) func (x StatusOp) Enum() *StatusOp { p := new(StatusOp) *p = x return p } func (x StatusOp) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (StatusOp) Descriptor() protoreflect.EnumDescriptor { return file_logtail_proto_enumTypes[0].Descriptor() } func (StatusOp) Type() protoreflect.EnumType { return &file_logtail_proto_enumTypes[0] } func (x StatusOp) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use StatusOp.Descriptor instead. func (StatusOp) EnumDescriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{0} } type GroupBy int32 const ( GroupBy_WEBSITE GroupBy = 0 GroupBy_CLIENT_PREFIX GroupBy = 1 GroupBy_REQUEST_URI GroupBy = 2 GroupBy_HTTP_RESPONSE GroupBy = 3 ) // Enum value maps for GroupBy. var ( GroupBy_name = map[int32]string{ 0: "WEBSITE", 1: "CLIENT_PREFIX", 2: "REQUEST_URI", 3: "HTTP_RESPONSE", } GroupBy_value = map[string]int32{ "WEBSITE": 0, "CLIENT_PREFIX": 1, "REQUEST_URI": 2, "HTTP_RESPONSE": 3, } ) func (x GroupBy) Enum() *GroupBy { p := new(GroupBy) *p = x return p } func (x GroupBy) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (GroupBy) Descriptor() protoreflect.EnumDescriptor { return file_logtail_proto_enumTypes[1].Descriptor() } func (GroupBy) Type() protoreflect.EnumType { return &file_logtail_proto_enumTypes[1] } func (x GroupBy) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use GroupBy.Descriptor instead. func (GroupBy) EnumDescriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{1} } type Window int32 const ( Window_W1M Window = 0 // last 1 minute Window_W5M Window = 1 // last 5 minutes Window_W15M Window = 2 // last 15 minutes Window_W60M Window = 3 // last 60 minutes Window_W6H Window = 4 // last 6 hours Window_W24H Window = 5 // last 24 hours ) // Enum value maps for Window. var ( Window_name = map[int32]string{ 0: "W1M", 1: "W5M", 2: "W15M", 3: "W60M", 4: "W6H", 5: "W24H", } Window_value = map[string]int32{ "W1M": 0, "W5M": 1, "W15M": 2, "W60M": 3, "W6H": 4, "W24H": 5, } ) func (x Window) Enum() *Window { p := new(Window) *p = x return p } func (x Window) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (Window) Descriptor() protoreflect.EnumDescriptor { return file_logtail_proto_enumTypes[2].Descriptor() } func (Window) Type() protoreflect.EnumType { return &file_logtail_proto_enumTypes[2] } func (x Window) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use Window.Descriptor instead. func (Window) EnumDescriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{2} } // Filter restricts results to entries matching all specified fields. // Unset fields match everything. Exact-match and regex fields are ANDed. type Filter struct { state protoimpl.MessageState `protogen:"open.v1"` Website *string `protobuf:"bytes,1,opt,name=website,proto3,oneof" json:"website,omitempty"` ClientPrefix *string `protobuf:"bytes,2,opt,name=client_prefix,json=clientPrefix,proto3,oneof" json:"client_prefix,omitempty"` HttpRequestUri *string `protobuf:"bytes,3,opt,name=http_request_uri,json=httpRequestUri,proto3,oneof" json:"http_request_uri,omitempty"` HttpResponse *int32 `protobuf:"varint,4,opt,name=http_response,json=httpResponse,proto3,oneof" json:"http_response,omitempty"` StatusOp StatusOp `protobuf:"varint,5,opt,name=status_op,json=statusOp,proto3,enum=logtail.StatusOp" json:"status_op,omitempty"` // operator for http_response; ignored when unset WebsiteRegex *string `protobuf:"bytes,6,opt,name=website_regex,json=websiteRegex,proto3,oneof" json:"website_regex,omitempty"` // RE2 regex matched against website UriRegex *string `protobuf:"bytes,7,opt,name=uri_regex,json=uriRegex,proto3,oneof" json:"uri_regex,omitempty"` // RE2 regex matched against http_request_uri unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *Filter) Reset() { *x = Filter{} mi := &file_logtail_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *Filter) String() string { return protoimpl.X.MessageStringOf(x) } func (*Filter) ProtoMessage() {} func (x *Filter) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[0] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Filter.ProtoReflect.Descriptor instead. func (*Filter) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{0} } func (x *Filter) GetWebsite() string { if x != nil && x.Website != nil { return *x.Website } return "" } func (x *Filter) GetClientPrefix() string { if x != nil && x.ClientPrefix != nil { return *x.ClientPrefix } return "" } func (x *Filter) GetHttpRequestUri() string { if x != nil && x.HttpRequestUri != nil { return *x.HttpRequestUri } return "" } func (x *Filter) GetHttpResponse() int32 { if x != nil && x.HttpResponse != nil { return *x.HttpResponse } return 0 } func (x *Filter) GetStatusOp() StatusOp { if x != nil { return x.StatusOp } return StatusOp_EQ } func (x *Filter) GetWebsiteRegex() string { if x != nil && x.WebsiteRegex != nil { return *x.WebsiteRegex } return "" } func (x *Filter) GetUriRegex() string { if x != nil && x.UriRegex != nil { return *x.UriRegex } return "" } type TopNRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` GroupBy GroupBy `protobuf:"varint,2,opt,name=group_by,json=groupBy,proto3,enum=logtail.GroupBy" json:"group_by,omitempty"` N int32 `protobuf:"varint,3,opt,name=n,proto3" json:"n,omitempty"` Window Window `protobuf:"varint,4,opt,name=window,proto3,enum=logtail.Window" json:"window,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TopNRequest) Reset() { *x = TopNRequest{} mi := &file_logtail_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TopNRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*TopNRequest) ProtoMessage() {} func (x *TopNRequest) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[1] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TopNRequest.ProtoReflect.Descriptor instead. func (*TopNRequest) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{1} } func (x *TopNRequest) GetFilter() *Filter { if x != nil { return x.Filter } return nil } func (x *TopNRequest) GetGroupBy() GroupBy { if x != nil { return x.GroupBy } return GroupBy_WEBSITE } func (x *TopNRequest) GetN() int32 { if x != nil { return x.N } return 0 } func (x *TopNRequest) GetWindow() Window { if x != nil { return x.Window } return Window_W1M } type TopNEntry struct { state protoimpl.MessageState `protogen:"open.v1"` Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TopNEntry) Reset() { *x = TopNEntry{} mi := &file_logtail_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TopNEntry) String() string { return protoimpl.X.MessageStringOf(x) } func (*TopNEntry) ProtoMessage() {} func (x *TopNEntry) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[2] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TopNEntry.ProtoReflect.Descriptor instead. func (*TopNEntry) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{2} } func (x *TopNEntry) GetLabel() string { if x != nil { return x.Label } return "" } func (x *TopNEntry) GetCount() int64 { if x != nil { return x.Count } return 0 } type TopNResponse struct { state protoimpl.MessageState `protogen:"open.v1"` Entries []*TopNEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // hostname of the responding node unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TopNResponse) Reset() { *x = TopNResponse{} mi := &file_logtail_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TopNResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*TopNResponse) ProtoMessage() {} func (x *TopNResponse) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[3] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TopNResponse.ProtoReflect.Descriptor instead. func (*TopNResponse) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{3} } func (x *TopNResponse) GetEntries() []*TopNEntry { if x != nil { return x.Entries } return nil } func (x *TopNResponse) GetSource() string { if x != nil { return x.Source } return "" } type TrendRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` Window Window `protobuf:"varint,2,opt,name=window,proto3,enum=logtail.Window" json:"window,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TrendRequest) Reset() { *x = TrendRequest{} mi := &file_logtail_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TrendRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*TrendRequest) ProtoMessage() {} func (x *TrendRequest) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[4] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TrendRequest.ProtoReflect.Descriptor instead. func (*TrendRequest) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{4} } func (x *TrendRequest) GetFilter() *Filter { if x != nil { return x.Filter } return nil } func (x *TrendRequest) GetWindow() Window { if x != nil { return x.Window } return Window_W1M } type TrendPoint struct { state protoimpl.MessageState `protogen:"open.v1"` TimestampUnix int64 `protobuf:"varint,1,opt,name=timestamp_unix,json=timestampUnix,proto3" json:"timestamp_unix,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TrendPoint) Reset() { *x = TrendPoint{} mi := &file_logtail_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TrendPoint) String() string { return protoimpl.X.MessageStringOf(x) } func (*TrendPoint) ProtoMessage() {} func (x *TrendPoint) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[5] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TrendPoint.ProtoReflect.Descriptor instead. func (*TrendPoint) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{5} } func (x *TrendPoint) GetTimestampUnix() int64 { if x != nil { return x.TimestampUnix } return 0 } func (x *TrendPoint) GetCount() int64 { if x != nil { return x.Count } return 0 } type TrendResponse struct { state protoimpl.MessageState `protogen:"open.v1"` Points []*TrendPoint `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TrendResponse) Reset() { *x = TrendResponse{} mi := &file_logtail_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TrendResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*TrendResponse) ProtoMessage() {} func (x *TrendResponse) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[6] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TrendResponse.ProtoReflect.Descriptor instead. func (*TrendResponse) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{6} } func (x *TrendResponse) GetPoints() []*TrendPoint { if x != nil { return x.Points } return nil } func (x *TrendResponse) GetSource() string { if x != nil { return x.Source } return "" } type SnapshotRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *SnapshotRequest) Reset() { *x = SnapshotRequest{} mi := &file_logtail_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *SnapshotRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*SnapshotRequest) ProtoMessage() {} func (x *SnapshotRequest) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[7] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead. func (*SnapshotRequest) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{7} } type Snapshot struct { state protoimpl.MessageState `protogen:"open.v1"` Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Entries []*TopNEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"` // top-50K for this 1-minute bucket, sorted desc unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *Snapshot) Reset() { *x = Snapshot{} mi := &file_logtail_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *Snapshot) String() string { return protoimpl.X.MessageStringOf(x) } func (*Snapshot) ProtoMessage() {} func (x *Snapshot) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[8] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Snapshot.ProtoReflect.Descriptor instead. func (*Snapshot) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{8} } func (x *Snapshot) GetSource() string { if x != nil { return x.Source } return "" } func (x *Snapshot) GetTimestamp() int64 { if x != nil { return x.Timestamp } return 0 } func (x *Snapshot) GetEntries() []*TopNEntry { if x != nil { return x.Entries } return nil } type ListTargetsRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListTargetsRequest) Reset() { *x = ListTargetsRequest{} mi := &file_logtail_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListTargetsRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListTargetsRequest) ProtoMessage() {} func (x *ListTargetsRequest) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[9] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListTargetsRequest.ProtoReflect.Descriptor instead. func (*ListTargetsRequest) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{9} } type TargetInfo struct { state protoimpl.MessageState `protogen:"open.v1"` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // display name (the --source value of the collector) Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` // gRPC address to use as target=; empty means "this endpoint" unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TargetInfo) Reset() { *x = TargetInfo{} mi := &file_logtail_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TargetInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*TargetInfo) ProtoMessage() {} func (x *TargetInfo) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TargetInfo.ProtoReflect.Descriptor instead. func (*TargetInfo) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{10} } func (x *TargetInfo) GetName() string { if x != nil { return x.Name } return "" } func (x *TargetInfo) GetAddr() string { if x != nil { return x.Addr } return "" } type ListTargetsResponse struct { state protoimpl.MessageState `protogen:"open.v1"` Targets []*TargetInfo `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ListTargetsResponse) Reset() { *x = ListTargetsResponse{} mi := &file_logtail_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ListTargetsResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*ListTargetsResponse) ProtoMessage() {} func (x *ListTargetsResponse) ProtoReflect() protoreflect.Message { mi := &file_logtail_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ListTargetsResponse.ProtoReflect.Descriptor instead. func (*ListTargetsResponse) Descriptor() ([]byte, []int) { return file_logtail_proto_rawDescGZIP(), []int{11} } func (x *ListTargetsResponse) GetTargets() []*TargetInfo { if x != nil { return x.Targets } return nil } var File_logtail_proto protoreflect.FileDescriptor const file_logtail_proto_rawDesc = "" + "\n" + "\rlogtail.proto\x12\alogtail\"\x8b\x03\n" + "\x06Filter\x12\x1d\n" + "\awebsite\x18\x01 \x01(\tH\x00R\awebsite\x88\x01\x01\x12(\n" + "\rclient_prefix\x18\x02 \x01(\tH\x01R\fclientPrefix\x88\x01\x01\x12-\n" + "\x10http_request_uri\x18\x03 \x01(\tH\x02R\x0ehttpRequestUri\x88\x01\x01\x12(\n" + "\rhttp_response\x18\x04 \x01(\x05H\x03R\fhttpResponse\x88\x01\x01\x12.\n" + "\tstatus_op\x18\x05 \x01(\x0e2\x11.logtail.StatusOpR\bstatusOp\x12(\n" + "\rwebsite_regex\x18\x06 \x01(\tH\x04R\fwebsiteRegex\x88\x01\x01\x12 \n" + "\turi_regex\x18\a \x01(\tH\x05R\buriRegex\x88\x01\x01B\n" + "\n" + "\b_websiteB\x10\n" + "\x0e_client_prefixB\x13\n" + "\x11_http_request_uriB\x10\n" + "\x0e_http_responseB\x10\n" + "\x0e_website_regexB\f\n" + "\n" + "_uri_regex\"\x9a\x01\n" + "\vTopNRequest\x12'\n" + "\x06filter\x18\x01 \x01(\v2\x0f.logtail.FilterR\x06filter\x12+\n" + "\bgroup_by\x18\x02 \x01(\x0e2\x10.logtail.GroupByR\agroupBy\x12\f\n" + "\x01n\x18\x03 \x01(\x05R\x01n\x12'\n" + "\x06window\x18\x04 \x01(\x0e2\x0f.logtail.WindowR\x06window\"7\n" + "\tTopNEntry\x12\x14\n" + "\x05label\x18\x01 \x01(\tR\x05label\x12\x14\n" + "\x05count\x18\x02 \x01(\x03R\x05count\"T\n" + "\fTopNResponse\x12,\n" + "\aentries\x18\x01 \x03(\v2\x12.logtail.TopNEntryR\aentries\x12\x16\n" + "\x06source\x18\x02 \x01(\tR\x06source\"`\n" + "\fTrendRequest\x12'\n" + "\x06filter\x18\x01 \x01(\v2\x0f.logtail.FilterR\x06filter\x12'\n" + "\x06window\x18\x02 \x01(\x0e2\x0f.logtail.WindowR\x06window\"I\n" + "\n" + "TrendPoint\x12%\n" + "\x0etimestamp_unix\x18\x01 \x01(\x03R\rtimestampUnix\x12\x14\n" + "\x05count\x18\x02 \x01(\x03R\x05count\"T\n" + "\rTrendResponse\x12+\n" + "\x06points\x18\x01 \x03(\v2\x13.logtail.TrendPointR\x06points\x12\x16\n" + "\x06source\x18\x02 \x01(\tR\x06source\"\x11\n" + "\x0fSnapshotRequest\"n\n" + "\bSnapshot\x12\x16\n" + "\x06source\x18\x01 \x01(\tR\x06source\x12\x1c\n" + "\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\x12,\n" + "\aentries\x18\x03 \x03(\v2\x12.logtail.TopNEntryR\aentries\"\x14\n" + "\x12ListTargetsRequest\"4\n" + "\n" + "TargetInfo\x12\x12\n" + "\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n" + "\x04addr\x18\x02 \x01(\tR\x04addr\"D\n" + "\x13ListTargetsResponse\x12-\n" + "\atargets\x18\x01 \x03(\v2\x13.logtail.TargetInfoR\atargets*:\n" + "\bStatusOp\x12\x06\n" + "\x02EQ\x10\x00\x12\x06\n" + "\x02NE\x10\x01\x12\x06\n" + "\x02GT\x10\x02\x12\x06\n" + "\x02GE\x10\x03\x12\x06\n" + "\x02LT\x10\x04\x12\x06\n" + "\x02LE\x10\x05*M\n" + "\aGroupBy\x12\v\n" + "\aWEBSITE\x10\x00\x12\x11\n" + "\rCLIENT_PREFIX\x10\x01\x12\x0f\n" + "\vREQUEST_URI\x10\x02\x12\x11\n" + "\rHTTP_RESPONSE\x10\x03*A\n" + "\x06Window\x12\a\n" + "\x03W1M\x10\x00\x12\a\n" + "\x03W5M\x10\x01\x12\b\n" + "\x04W15M\x10\x02\x12\b\n" + "\x04W60M\x10\x03\x12\a\n" + "\x03W6H\x10\x04\x12\b\n" + "\x04W24H\x10\x052\x89\x02\n" + "\x0eLogtailService\x123\n" + "\x04TopN\x12\x14.logtail.TopNRequest\x1a\x15.logtail.TopNResponse\x126\n" + "\x05Trend\x12\x15.logtail.TrendRequest\x1a\x16.logtail.TrendResponse\x12@\n" + "\x0fStreamSnapshots\x12\x18.logtail.SnapshotRequest\x1a\x11.logtail.Snapshot0\x01\x12H\n" + "\vListTargets\x12\x1b.logtail.ListTargetsRequest\x1a\x1c.logtail.ListTargetsResponseB0Z.git.ipng.ch/ipng/nginx-logtail/proto/logtailpbb\x06proto3" var ( file_logtail_proto_rawDescOnce sync.Once file_logtail_proto_rawDescData []byte ) func file_logtail_proto_rawDescGZIP() []byte { file_logtail_proto_rawDescOnce.Do(func() { file_logtail_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_logtail_proto_rawDesc), len(file_logtail_proto_rawDesc))) }) return file_logtail_proto_rawDescData } var file_logtail_proto_enumTypes = make([]protoimpl.EnumInfo, 3) var file_logtail_proto_msgTypes = make([]protoimpl.MessageInfo, 12) var file_logtail_proto_goTypes = []any{ (StatusOp)(0), // 0: logtail.StatusOp (GroupBy)(0), // 1: logtail.GroupBy (Window)(0), // 2: logtail.Window (*Filter)(nil), // 3: logtail.Filter (*TopNRequest)(nil), // 4: logtail.TopNRequest (*TopNEntry)(nil), // 5: logtail.TopNEntry (*TopNResponse)(nil), // 6: logtail.TopNResponse (*TrendRequest)(nil), // 7: logtail.TrendRequest (*TrendPoint)(nil), // 8: logtail.TrendPoint (*TrendResponse)(nil), // 9: logtail.TrendResponse (*SnapshotRequest)(nil), // 10: logtail.SnapshotRequest (*Snapshot)(nil), // 11: logtail.Snapshot (*ListTargetsRequest)(nil), // 12: logtail.ListTargetsRequest (*TargetInfo)(nil), // 13: logtail.TargetInfo (*ListTargetsResponse)(nil), // 14: logtail.ListTargetsResponse } var file_logtail_proto_depIdxs = []int32{ 0, // 0: logtail.Filter.status_op:type_name -> logtail.StatusOp 3, // 1: logtail.TopNRequest.filter:type_name -> logtail.Filter 1, // 2: logtail.TopNRequest.group_by:type_name -> logtail.GroupBy 2, // 3: logtail.TopNRequest.window:type_name -> logtail.Window 5, // 4: logtail.TopNResponse.entries:type_name -> logtail.TopNEntry 3, // 5: logtail.TrendRequest.filter:type_name -> logtail.Filter 2, // 6: logtail.TrendRequest.window:type_name -> logtail.Window 8, // 7: logtail.TrendResponse.points:type_name -> logtail.TrendPoint 5, // 8: logtail.Snapshot.entries:type_name -> logtail.TopNEntry 13, // 9: logtail.ListTargetsResponse.targets:type_name -> logtail.TargetInfo 4, // 10: logtail.LogtailService.TopN:input_type -> logtail.TopNRequest 7, // 11: logtail.LogtailService.Trend:input_type -> logtail.TrendRequest 10, // 12: logtail.LogtailService.StreamSnapshots:input_type -> logtail.SnapshotRequest 12, // 13: logtail.LogtailService.ListTargets:input_type -> logtail.ListTargetsRequest 6, // 14: logtail.LogtailService.TopN:output_type -> logtail.TopNResponse 9, // 15: logtail.LogtailService.Trend:output_type -> logtail.TrendResponse 11, // 16: logtail.LogtailService.StreamSnapshots:output_type -> logtail.Snapshot 14, // 17: logtail.LogtailService.ListTargets:output_type -> logtail.ListTargetsResponse 14, // [14:18] is the sub-list for method output_type 10, // [10:14] is the sub-list for method input_type 10, // [10:10] is the sub-list for extension type_name 10, // [10:10] is the sub-list for extension extendee 0, // [0:10] is the sub-list for field type_name } func init() { file_logtail_proto_init() } func file_logtail_proto_init() { if File_logtail_proto != nil { return } file_logtail_proto_msgTypes[0].OneofWrappers = []any{} type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_logtail_proto_rawDesc), len(file_logtail_proto_rawDesc)), NumEnums: 3, NumMessages: 12, NumExtensions: 0, NumServices: 1, }, GoTypes: file_logtail_proto_goTypes, DependencyIndexes: file_logtail_proto_depIdxs, EnumInfos: file_logtail_proto_enumTypes, MessageInfos: file_logtail_proto_msgTypes, }.Build() File_logtail_proto = out.File file_logtail_proto_goTypes = nil file_logtail_proto_depIdxs = nil }