search.pb.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // versions:
  3. // protoc-gen-go v1.26.0
  4. // protoc v3.19.1
  5. // source: eventsearcher/proto/search.proto
  6. package proto
  7. import (
  8. context "context"
  9. grpc "google.golang.org/grpc"
  10. codes "google.golang.org/grpc/codes"
  11. status "google.golang.org/grpc/status"
  12. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  13. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  14. reflect "reflect"
  15. sync "sync"
  16. )
  17. const (
  18. // Verify that this generated code is sufficiently up-to-date.
  19. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  20. // Verify that runtime/protoimpl is sufficiently up-to-date.
  21. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  22. )
  23. type FsEventsFilter_Order int32
  24. const (
  25. FsEventsFilter_DESC FsEventsFilter_Order = 0
  26. FsEventsFilter_ASC FsEventsFilter_Order = 1
  27. )
  28. // Enum value maps for FsEventsFilter_Order.
  29. var (
  30. FsEventsFilter_Order_name = map[int32]string{
  31. 0: "DESC",
  32. 1: "ASC",
  33. }
  34. FsEventsFilter_Order_value = map[string]int32{
  35. "DESC": 0,
  36. "ASC": 1,
  37. }
  38. )
  39. func (x FsEventsFilter_Order) Enum() *FsEventsFilter_Order {
  40. p := new(FsEventsFilter_Order)
  41. *p = x
  42. return p
  43. }
  44. func (x FsEventsFilter_Order) String() string {
  45. return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  46. }
  47. func (FsEventsFilter_Order) Descriptor() protoreflect.EnumDescriptor {
  48. return file_eventsearcher_proto_search_proto_enumTypes[0].Descriptor()
  49. }
  50. func (FsEventsFilter_Order) Type() protoreflect.EnumType {
  51. return &file_eventsearcher_proto_search_proto_enumTypes[0]
  52. }
  53. func (x FsEventsFilter_Order) Number() protoreflect.EnumNumber {
  54. return protoreflect.EnumNumber(x)
  55. }
  56. // Deprecated: Use FsEventsFilter_Order.Descriptor instead.
  57. func (FsEventsFilter_Order) EnumDescriptor() ([]byte, []int) {
  58. return file_eventsearcher_proto_search_proto_rawDescGZIP(), []int{0, 0}
  59. }
  60. type ProviderEventsFilter_Order int32
  61. const (
  62. ProviderEventsFilter_DESC ProviderEventsFilter_Order = 0
  63. ProviderEventsFilter_ASC ProviderEventsFilter_Order = 1
  64. )
  65. // Enum value maps for ProviderEventsFilter_Order.
  66. var (
  67. ProviderEventsFilter_Order_name = map[int32]string{
  68. 0: "DESC",
  69. 1: "ASC",
  70. }
  71. ProviderEventsFilter_Order_value = map[string]int32{
  72. "DESC": 0,
  73. "ASC": 1,
  74. }
  75. )
  76. func (x ProviderEventsFilter_Order) Enum() *ProviderEventsFilter_Order {
  77. p := new(ProviderEventsFilter_Order)
  78. *p = x
  79. return p
  80. }
  81. func (x ProviderEventsFilter_Order) String() string {
  82. return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  83. }
  84. func (ProviderEventsFilter_Order) Descriptor() protoreflect.EnumDescriptor {
  85. return file_eventsearcher_proto_search_proto_enumTypes[1].Descriptor()
  86. }
  87. func (ProviderEventsFilter_Order) Type() protoreflect.EnumType {
  88. return &file_eventsearcher_proto_search_proto_enumTypes[1]
  89. }
  90. func (x ProviderEventsFilter_Order) Number() protoreflect.EnumNumber {
  91. return protoreflect.EnumNumber(x)
  92. }
  93. // Deprecated: Use ProviderEventsFilter_Order.Descriptor instead.
  94. func (ProviderEventsFilter_Order) EnumDescriptor() ([]byte, []int) {
  95. return file_eventsearcher_proto_search_proto_rawDescGZIP(), []int{1, 0}
  96. }
  97. type FsEventsFilter struct {
  98. state protoimpl.MessageState
  99. sizeCache protoimpl.SizeCache
  100. unknownFields protoimpl.UnknownFields
  101. StartTimestamp int64 `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
  102. EndTimestamp int64 `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
  103. Actions []string `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
  104. Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
  105. Ip string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
  106. SshCmd string `protobuf:"bytes,6,opt,name=ssh_cmd,json=sshCmd,proto3" json:"ssh_cmd,omitempty"`
  107. Protocols []string `protobuf:"bytes,7,rep,name=protocols,proto3" json:"protocols,omitempty"`
  108. Statuses []int32 `protobuf:"varint,8,rep,packed,name=statuses,proto3" json:"statuses,omitempty"`
  109. InstanceIds []string `protobuf:"bytes,9,rep,name=instance_ids,json=instanceIds,proto3" json:"instance_ids,omitempty"`
  110. Limit int32 `protobuf:"varint,10,opt,name=limit,proto3" json:"limit,omitempty"`
  111. ExcludeIds []string `protobuf:"bytes,11,rep,name=exclude_ids,json=excludeIds,proto3" json:"exclude_ids,omitempty"`
  112. FsProvider int32 `protobuf:"varint,12,opt,name=fs_provider,json=fsProvider,proto3" json:"fs_provider,omitempty"`
  113. Bucket string `protobuf:"bytes,13,opt,name=bucket,proto3" json:"bucket,omitempty"`
  114. Endpoint string `protobuf:"bytes,14,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
  115. Order FsEventsFilter_Order `protobuf:"varint,15,opt,name=order,proto3,enum=proto.FsEventsFilter_Order" json:"order,omitempty"`
  116. }
  117. func (x *FsEventsFilter) Reset() {
  118. *x = FsEventsFilter{}
  119. if protoimpl.UnsafeEnabled {
  120. mi := &file_eventsearcher_proto_search_proto_msgTypes[0]
  121. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  122. ms.StoreMessageInfo(mi)
  123. }
  124. }
  125. func (x *FsEventsFilter) String() string {
  126. return protoimpl.X.MessageStringOf(x)
  127. }
  128. func (*FsEventsFilter) ProtoMessage() {}
  129. func (x *FsEventsFilter) ProtoReflect() protoreflect.Message {
  130. mi := &file_eventsearcher_proto_search_proto_msgTypes[0]
  131. if protoimpl.UnsafeEnabled && x != nil {
  132. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  133. if ms.LoadMessageInfo() == nil {
  134. ms.StoreMessageInfo(mi)
  135. }
  136. return ms
  137. }
  138. return mi.MessageOf(x)
  139. }
  140. // Deprecated: Use FsEventsFilter.ProtoReflect.Descriptor instead.
  141. func (*FsEventsFilter) Descriptor() ([]byte, []int) {
  142. return file_eventsearcher_proto_search_proto_rawDescGZIP(), []int{0}
  143. }
  144. func (x *FsEventsFilter) GetStartTimestamp() int64 {
  145. if x != nil {
  146. return x.StartTimestamp
  147. }
  148. return 0
  149. }
  150. func (x *FsEventsFilter) GetEndTimestamp() int64 {
  151. if x != nil {
  152. return x.EndTimestamp
  153. }
  154. return 0
  155. }
  156. func (x *FsEventsFilter) GetActions() []string {
  157. if x != nil {
  158. return x.Actions
  159. }
  160. return nil
  161. }
  162. func (x *FsEventsFilter) GetUsername() string {
  163. if x != nil {
  164. return x.Username
  165. }
  166. return ""
  167. }
  168. func (x *FsEventsFilter) GetIp() string {
  169. if x != nil {
  170. return x.Ip
  171. }
  172. return ""
  173. }
  174. func (x *FsEventsFilter) GetSshCmd() string {
  175. if x != nil {
  176. return x.SshCmd
  177. }
  178. return ""
  179. }
  180. func (x *FsEventsFilter) GetProtocols() []string {
  181. if x != nil {
  182. return x.Protocols
  183. }
  184. return nil
  185. }
  186. func (x *FsEventsFilter) GetStatuses() []int32 {
  187. if x != nil {
  188. return x.Statuses
  189. }
  190. return nil
  191. }
  192. func (x *FsEventsFilter) GetInstanceIds() []string {
  193. if x != nil {
  194. return x.InstanceIds
  195. }
  196. return nil
  197. }
  198. func (x *FsEventsFilter) GetLimit() int32 {
  199. if x != nil {
  200. return x.Limit
  201. }
  202. return 0
  203. }
  204. func (x *FsEventsFilter) GetExcludeIds() []string {
  205. if x != nil {
  206. return x.ExcludeIds
  207. }
  208. return nil
  209. }
  210. func (x *FsEventsFilter) GetFsProvider() int32 {
  211. if x != nil {
  212. return x.FsProvider
  213. }
  214. return 0
  215. }
  216. func (x *FsEventsFilter) GetBucket() string {
  217. if x != nil {
  218. return x.Bucket
  219. }
  220. return ""
  221. }
  222. func (x *FsEventsFilter) GetEndpoint() string {
  223. if x != nil {
  224. return x.Endpoint
  225. }
  226. return ""
  227. }
  228. func (x *FsEventsFilter) GetOrder() FsEventsFilter_Order {
  229. if x != nil {
  230. return x.Order
  231. }
  232. return FsEventsFilter_DESC
  233. }
  234. type ProviderEventsFilter struct {
  235. state protoimpl.MessageState
  236. sizeCache protoimpl.SizeCache
  237. unknownFields protoimpl.UnknownFields
  238. StartTimestamp int64 `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
  239. EndTimestamp int64 `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
  240. Actions []string `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
  241. Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
  242. Ip string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
  243. ObjectTypes []string `protobuf:"bytes,6,rep,name=object_types,json=objectTypes,proto3" json:"object_types,omitempty"`
  244. ObjectName string `protobuf:"bytes,7,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
  245. InstanceIds []string `protobuf:"bytes,8,rep,name=instance_ids,json=instanceIds,proto3" json:"instance_ids,omitempty"`
  246. Limit int32 `protobuf:"varint,9,opt,name=limit,proto3" json:"limit,omitempty"`
  247. ExcludeIds []string `protobuf:"bytes,10,rep,name=exclude_ids,json=excludeIds,proto3" json:"exclude_ids,omitempty"`
  248. Order ProviderEventsFilter_Order `protobuf:"varint,11,opt,name=order,proto3,enum=proto.ProviderEventsFilter_Order" json:"order,omitempty"`
  249. }
  250. func (x *ProviderEventsFilter) Reset() {
  251. *x = ProviderEventsFilter{}
  252. if protoimpl.UnsafeEnabled {
  253. mi := &file_eventsearcher_proto_search_proto_msgTypes[1]
  254. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  255. ms.StoreMessageInfo(mi)
  256. }
  257. }
  258. func (x *ProviderEventsFilter) String() string {
  259. return protoimpl.X.MessageStringOf(x)
  260. }
  261. func (*ProviderEventsFilter) ProtoMessage() {}
  262. func (x *ProviderEventsFilter) ProtoReflect() protoreflect.Message {
  263. mi := &file_eventsearcher_proto_search_proto_msgTypes[1]
  264. if protoimpl.UnsafeEnabled && x != nil {
  265. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  266. if ms.LoadMessageInfo() == nil {
  267. ms.StoreMessageInfo(mi)
  268. }
  269. return ms
  270. }
  271. return mi.MessageOf(x)
  272. }
  273. // Deprecated: Use ProviderEventsFilter.ProtoReflect.Descriptor instead.
  274. func (*ProviderEventsFilter) Descriptor() ([]byte, []int) {
  275. return file_eventsearcher_proto_search_proto_rawDescGZIP(), []int{1}
  276. }
  277. func (x *ProviderEventsFilter) GetStartTimestamp() int64 {
  278. if x != nil {
  279. return x.StartTimestamp
  280. }
  281. return 0
  282. }
  283. func (x *ProviderEventsFilter) GetEndTimestamp() int64 {
  284. if x != nil {
  285. return x.EndTimestamp
  286. }
  287. return 0
  288. }
  289. func (x *ProviderEventsFilter) GetActions() []string {
  290. if x != nil {
  291. return x.Actions
  292. }
  293. return nil
  294. }
  295. func (x *ProviderEventsFilter) GetUsername() string {
  296. if x != nil {
  297. return x.Username
  298. }
  299. return ""
  300. }
  301. func (x *ProviderEventsFilter) GetIp() string {
  302. if x != nil {
  303. return x.Ip
  304. }
  305. return ""
  306. }
  307. func (x *ProviderEventsFilter) GetObjectTypes() []string {
  308. if x != nil {
  309. return x.ObjectTypes
  310. }
  311. return nil
  312. }
  313. func (x *ProviderEventsFilter) GetObjectName() string {
  314. if x != nil {
  315. return x.ObjectName
  316. }
  317. return ""
  318. }
  319. func (x *ProviderEventsFilter) GetInstanceIds() []string {
  320. if x != nil {
  321. return x.InstanceIds
  322. }
  323. return nil
  324. }
  325. func (x *ProviderEventsFilter) GetLimit() int32 {
  326. if x != nil {
  327. return x.Limit
  328. }
  329. return 0
  330. }
  331. func (x *ProviderEventsFilter) GetExcludeIds() []string {
  332. if x != nil {
  333. return x.ExcludeIds
  334. }
  335. return nil
  336. }
  337. func (x *ProviderEventsFilter) GetOrder() ProviderEventsFilter_Order {
  338. if x != nil {
  339. return x.Order
  340. }
  341. return ProviderEventsFilter_DESC
  342. }
  343. type SearchResponse struct {
  344. state protoimpl.MessageState
  345. sizeCache protoimpl.SizeCache
  346. unknownFields protoimpl.UnknownFields
  347. Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // JSON serialized response to return
  348. SameTsAtStart []string `protobuf:"bytes,2,rep,name=same_ts_at_start,json=sameTsAtStart,proto3" json:"same_ts_at_start,omitempty"`
  349. SameTsAtEnd []string `protobuf:"bytes,3,rep,name=same_ts_at_end,json=sameTsAtEnd,proto3" json:"same_ts_at_end,omitempty"`
  350. }
  351. func (x *SearchResponse) Reset() {
  352. *x = SearchResponse{}
  353. if protoimpl.UnsafeEnabled {
  354. mi := &file_eventsearcher_proto_search_proto_msgTypes[2]
  355. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  356. ms.StoreMessageInfo(mi)
  357. }
  358. }
  359. func (x *SearchResponse) String() string {
  360. return protoimpl.X.MessageStringOf(x)
  361. }
  362. func (*SearchResponse) ProtoMessage() {}
  363. func (x *SearchResponse) ProtoReflect() protoreflect.Message {
  364. mi := &file_eventsearcher_proto_search_proto_msgTypes[2]
  365. if protoimpl.UnsafeEnabled && x != nil {
  366. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  367. if ms.LoadMessageInfo() == nil {
  368. ms.StoreMessageInfo(mi)
  369. }
  370. return ms
  371. }
  372. return mi.MessageOf(x)
  373. }
  374. // Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
  375. func (*SearchResponse) Descriptor() ([]byte, []int) {
  376. return file_eventsearcher_proto_search_proto_rawDescGZIP(), []int{2}
  377. }
  378. func (x *SearchResponse) GetData() []byte {
  379. if x != nil {
  380. return x.Data
  381. }
  382. return nil
  383. }
  384. func (x *SearchResponse) GetSameTsAtStart() []string {
  385. if x != nil {
  386. return x.SameTsAtStart
  387. }
  388. return nil
  389. }
  390. func (x *SearchResponse) GetSameTsAtEnd() []string {
  391. if x != nil {
  392. return x.SameTsAtEnd
  393. }
  394. return nil
  395. }
  396. var File_eventsearcher_proto_search_proto protoreflect.FileDescriptor
  397. var file_eventsearcher_proto_search_proto_rawDesc = []byte{
  398. 0x0a, 0x20, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x65, 0x61, 0x72, 0x63, 0x68, 0x65, 0x72, 0x2f,
  399. 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x73, 0x65, 0x61, 0x72, 0x63, 0x68, 0x2e, 0x70, 0x72, 0x6f,
  400. 0x74, 0x6f, 0x12, 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xf5, 0x03, 0x0a, 0x0e, 0x46, 0x73,
  401. 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x27, 0x0a, 0x0f,
  402. 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18,
  403. 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0e, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65,
  404. 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x23, 0x0a, 0x0d, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d,
  405. 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x65, 0x6e,
  406. 0x64, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x63,
  407. 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x61, 0x63, 0x74,
  408. 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65,
  409. 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65,
  410. 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x70, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x70,
  411. 0x12, 0x17, 0x0a, 0x07, 0x73, 0x73, 0x68, 0x5f, 0x63, 0x6d, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28,
  412. 0x09, 0x52, 0x06, 0x73, 0x73, 0x68, 0x43, 0x6d, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x72, 0x6f,
  413. 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x18, 0x07, 0x20, 0x03, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72,
  414. 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x74, 0x61, 0x74, 0x75,
  415. 0x73, 0x65, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x05, 0x52, 0x08, 0x73, 0x74, 0x61, 0x74, 0x75,
  416. 0x73, 0x65, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f,
  417. 0x69, 0x64, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61,
  418. 0x6e, 0x63, 0x65, 0x49, 0x64, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18,
  419. 0x0a, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x1f, 0x0a, 0x0b,
  420. 0x65, 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x0b, 0x20, 0x03, 0x28,
  421. 0x09, 0x52, 0x0a, 0x65, 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x49, 0x64, 0x73, 0x12, 0x1f, 0x0a,
  422. 0x0b, 0x66, 0x73, 0x5f, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x18, 0x0c, 0x20, 0x01,
  423. 0x28, 0x05, 0x52, 0x0a, 0x66, 0x73, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x12, 0x16,
  424. 0x0a, 0x06, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
  425. 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69,
  426. 0x6e, 0x74, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69,
  427. 0x6e, 0x74, 0x12, 0x31, 0x0a, 0x05, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x18, 0x0f, 0x20, 0x01, 0x28,
  428. 0x0e, 0x32, 0x1b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x46, 0x73, 0x45, 0x76, 0x65, 0x6e,
  429. 0x74, 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x2e, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x52, 0x05,
  430. 0x6f, 0x72, 0x64, 0x65, 0x72, 0x22, 0x1a, 0x0a, 0x05, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x12, 0x08,
  431. 0x0a, 0x04, 0x44, 0x45, 0x53, 0x43, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x41, 0x53, 0x43, 0x10,
  432. 0x01, 0x22, 0x9d, 0x03, 0x0a, 0x14, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x45, 0x76,
  433. 0x65, 0x6e, 0x74, 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x74,
  434. 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20,
  435. 0x01, 0x28, 0x03, 0x52, 0x0e, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74,
  436. 0x61, 0x6d, 0x70, 0x12, 0x23, 0x0a, 0x0d, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73,
  437. 0x74, 0x61, 0x6d, 0x70, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x65, 0x6e, 0x64, 0x54,
  438. 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x63, 0x74, 0x69,
  439. 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f,
  440. 0x6e, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04,
  441. 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x0e,
  442. 0x0a, 0x02, 0x69, 0x70, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x70, 0x12, 0x21,
  443. 0x0a, 0x0c, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x18, 0x06,
  444. 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x54, 0x79, 0x70, 0x65,
  445. 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65,
  446. 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x4e, 0x61,
  447. 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x69,
  448. 0x64, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
  449. 0x63, 0x65, 0x49, 0x64, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x09,
  450. 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x65,
  451. 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x09,
  452. 0x52, 0x0a, 0x65, 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x49, 0x64, 0x73, 0x12, 0x37, 0x0a, 0x05,
  453. 0x6f, 0x72, 0x64, 0x65, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x21, 0x2e, 0x70, 0x72,
  454. 0x6f, 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e,
  455. 0x74, 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x2e, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x52, 0x05,
  456. 0x6f, 0x72, 0x64, 0x65, 0x72, 0x22, 0x1a, 0x0a, 0x05, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x12, 0x08,
  457. 0x0a, 0x04, 0x44, 0x45, 0x53, 0x43, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x41, 0x53, 0x43, 0x10,
  458. 0x01, 0x22, 0x72, 0x0a, 0x0e, 0x53, 0x65, 0x61, 0x72, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f,
  459. 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28,
  460. 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x27, 0x0a, 0x10, 0x73, 0x61, 0x6d, 0x65, 0x5f,
  461. 0x74, 0x73, 0x5f, 0x61, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x18, 0x02, 0x20, 0x03, 0x28,
  462. 0x09, 0x52, 0x0d, 0x73, 0x61, 0x6d, 0x65, 0x54, 0x73, 0x41, 0x74, 0x53, 0x74, 0x61, 0x72, 0x74,
  463. 0x12, 0x23, 0x0a, 0x0e, 0x73, 0x61, 0x6d, 0x65, 0x5f, 0x74, 0x73, 0x5f, 0x61, 0x74, 0x5f, 0x65,
  464. 0x6e, 0x64, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x61, 0x6d, 0x65, 0x54, 0x73,
  465. 0x41, 0x74, 0x45, 0x6e, 0x64, 0x32, 0x96, 0x01, 0x0a, 0x08, 0x53, 0x65, 0x61, 0x72, 0x63, 0x68,
  466. 0x65, 0x72, 0x12, 0x3e, 0x0a, 0x0e, 0x53, 0x65, 0x61, 0x72, 0x63, 0x68, 0x46, 0x73, 0x45, 0x76,
  467. 0x65, 0x6e, 0x74, 0x73, 0x12, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x46, 0x73, 0x45,
  468. 0x76, 0x65, 0x6e, 0x74, 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x1a, 0x15, 0x2e, 0x70, 0x72,
  469. 0x6f, 0x74, 0x6f, 0x2e, 0x53, 0x65, 0x61, 0x72, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  470. 0x73, 0x65, 0x12, 0x4a, 0x0a, 0x14, 0x53, 0x65, 0x61, 0x72, 0x63, 0x68, 0x50, 0x72, 0x6f, 0x76,
  471. 0x69, 0x64, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x1b, 0x2e, 0x70, 0x72, 0x6f,
  472. 0x74, 0x6f, 0x2e, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x45, 0x76, 0x65, 0x6e, 0x74,
  473. 0x73, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x1a, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e,
  474. 0x53, 0x65, 0x61, 0x72, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x20,
  475. 0x5a, 0x1e, 0x73, 0x64, 0x6b, 0x2f, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2f, 0x65, 0x76, 0x65,
  476. 0x6e, 0x74, 0x73, 0x65, 0x61, 0x72, 0x63, 0x68, 0x65, 0x72, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  477. 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  478. }
  479. var (
  480. file_eventsearcher_proto_search_proto_rawDescOnce sync.Once
  481. file_eventsearcher_proto_search_proto_rawDescData = file_eventsearcher_proto_search_proto_rawDesc
  482. )
  483. func file_eventsearcher_proto_search_proto_rawDescGZIP() []byte {
  484. file_eventsearcher_proto_search_proto_rawDescOnce.Do(func() {
  485. file_eventsearcher_proto_search_proto_rawDescData = protoimpl.X.CompressGZIP(file_eventsearcher_proto_search_proto_rawDescData)
  486. })
  487. return file_eventsearcher_proto_search_proto_rawDescData
  488. }
  489. var file_eventsearcher_proto_search_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
  490. var file_eventsearcher_proto_search_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
  491. var file_eventsearcher_proto_search_proto_goTypes = []interface{}{
  492. (FsEventsFilter_Order)(0), // 0: proto.FsEventsFilter.Order
  493. (ProviderEventsFilter_Order)(0), // 1: proto.ProviderEventsFilter.Order
  494. (*FsEventsFilter)(nil), // 2: proto.FsEventsFilter
  495. (*ProviderEventsFilter)(nil), // 3: proto.ProviderEventsFilter
  496. (*SearchResponse)(nil), // 4: proto.SearchResponse
  497. }
  498. var file_eventsearcher_proto_search_proto_depIdxs = []int32{
  499. 0, // 0: proto.FsEventsFilter.order:type_name -> proto.FsEventsFilter.Order
  500. 1, // 1: proto.ProviderEventsFilter.order:type_name -> proto.ProviderEventsFilter.Order
  501. 2, // 2: proto.Searcher.SearchFsEvents:input_type -> proto.FsEventsFilter
  502. 3, // 3: proto.Searcher.SearchProviderEvents:input_type -> proto.ProviderEventsFilter
  503. 4, // 4: proto.Searcher.SearchFsEvents:output_type -> proto.SearchResponse
  504. 4, // 5: proto.Searcher.SearchProviderEvents:output_type -> proto.SearchResponse
  505. 4, // [4:6] is the sub-list for method output_type
  506. 2, // [2:4] is the sub-list for method input_type
  507. 2, // [2:2] is the sub-list for extension type_name
  508. 2, // [2:2] is the sub-list for extension extendee
  509. 0, // [0:2] is the sub-list for field type_name
  510. }
  511. func init() { file_eventsearcher_proto_search_proto_init() }
  512. func file_eventsearcher_proto_search_proto_init() {
  513. if File_eventsearcher_proto_search_proto != nil {
  514. return
  515. }
  516. if !protoimpl.UnsafeEnabled {
  517. file_eventsearcher_proto_search_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  518. switch v := v.(*FsEventsFilter); i {
  519. case 0:
  520. return &v.state
  521. case 1:
  522. return &v.sizeCache
  523. case 2:
  524. return &v.unknownFields
  525. default:
  526. return nil
  527. }
  528. }
  529. file_eventsearcher_proto_search_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  530. switch v := v.(*ProviderEventsFilter); i {
  531. case 0:
  532. return &v.state
  533. case 1:
  534. return &v.sizeCache
  535. case 2:
  536. return &v.unknownFields
  537. default:
  538. return nil
  539. }
  540. }
  541. file_eventsearcher_proto_search_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  542. switch v := v.(*SearchResponse); i {
  543. case 0:
  544. return &v.state
  545. case 1:
  546. return &v.sizeCache
  547. case 2:
  548. return &v.unknownFields
  549. default:
  550. return nil
  551. }
  552. }
  553. }
  554. type x struct{}
  555. out := protoimpl.TypeBuilder{
  556. File: protoimpl.DescBuilder{
  557. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  558. RawDescriptor: file_eventsearcher_proto_search_proto_rawDesc,
  559. NumEnums: 2,
  560. NumMessages: 3,
  561. NumExtensions: 0,
  562. NumServices: 1,
  563. },
  564. GoTypes: file_eventsearcher_proto_search_proto_goTypes,
  565. DependencyIndexes: file_eventsearcher_proto_search_proto_depIdxs,
  566. EnumInfos: file_eventsearcher_proto_search_proto_enumTypes,
  567. MessageInfos: file_eventsearcher_proto_search_proto_msgTypes,
  568. }.Build()
  569. File_eventsearcher_proto_search_proto = out.File
  570. file_eventsearcher_proto_search_proto_rawDesc = nil
  571. file_eventsearcher_proto_search_proto_goTypes = nil
  572. file_eventsearcher_proto_search_proto_depIdxs = nil
  573. }
  574. // Reference imports to suppress errors if they are not otherwise used.
  575. var _ context.Context
  576. var _ grpc.ClientConnInterface
  577. // This is a compile-time assertion to ensure that this generated file
  578. // is compatible with the grpc package it is being compiled against.
  579. const _ = grpc.SupportPackageIsVersion6
  580. // SearcherClient is the client API for Searcher service.
  581. //
  582. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  583. type SearcherClient interface {
  584. SearchFsEvents(ctx context.Context, in *FsEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error)
  585. SearchProviderEvents(ctx context.Context, in *ProviderEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error)
  586. }
  587. type searcherClient struct {
  588. cc grpc.ClientConnInterface
  589. }
  590. func NewSearcherClient(cc grpc.ClientConnInterface) SearcherClient {
  591. return &searcherClient{cc}
  592. }
  593. func (c *searcherClient) SearchFsEvents(ctx context.Context, in *FsEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error) {
  594. out := new(SearchResponse)
  595. err := c.cc.Invoke(ctx, "/proto.Searcher/SearchFsEvents", in, out, opts...)
  596. if err != nil {
  597. return nil, err
  598. }
  599. return out, nil
  600. }
  601. func (c *searcherClient) SearchProviderEvents(ctx context.Context, in *ProviderEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error) {
  602. out := new(SearchResponse)
  603. err := c.cc.Invoke(ctx, "/proto.Searcher/SearchProviderEvents", in, out, opts...)
  604. if err != nil {
  605. return nil, err
  606. }
  607. return out, nil
  608. }
  609. // SearcherServer is the server API for Searcher service.
  610. type SearcherServer interface {
  611. SearchFsEvents(context.Context, *FsEventsFilter) (*SearchResponse, error)
  612. SearchProviderEvents(context.Context, *ProviderEventsFilter) (*SearchResponse, error)
  613. }
  614. // UnimplementedSearcherServer can be embedded to have forward compatible implementations.
  615. type UnimplementedSearcherServer struct {
  616. }
  617. func (*UnimplementedSearcherServer) SearchFsEvents(context.Context, *FsEventsFilter) (*SearchResponse, error) {
  618. return nil, status.Errorf(codes.Unimplemented, "method SearchFsEvents not implemented")
  619. }
  620. func (*UnimplementedSearcherServer) SearchProviderEvents(context.Context, *ProviderEventsFilter) (*SearchResponse, error) {
  621. return nil, status.Errorf(codes.Unimplemented, "method SearchProviderEvents not implemented")
  622. }
  623. func RegisterSearcherServer(s *grpc.Server, srv SearcherServer) {
  624. s.RegisterService(&_Searcher_serviceDesc, srv)
  625. }
  626. func _Searcher_SearchFsEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  627. in := new(FsEventsFilter)
  628. if err := dec(in); err != nil {
  629. return nil, err
  630. }
  631. if interceptor == nil {
  632. return srv.(SearcherServer).SearchFsEvents(ctx, in)
  633. }
  634. info := &grpc.UnaryServerInfo{
  635. Server: srv,
  636. FullMethod: "/proto.Searcher/SearchFsEvents",
  637. }
  638. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  639. return srv.(SearcherServer).SearchFsEvents(ctx, req.(*FsEventsFilter))
  640. }
  641. return interceptor(ctx, in, info, handler)
  642. }
  643. func _Searcher_SearchProviderEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  644. in := new(ProviderEventsFilter)
  645. if err := dec(in); err != nil {
  646. return nil, err
  647. }
  648. if interceptor == nil {
  649. return srv.(SearcherServer).SearchProviderEvents(ctx, in)
  650. }
  651. info := &grpc.UnaryServerInfo{
  652. Server: srv,
  653. FullMethod: "/proto.Searcher/SearchProviderEvents",
  654. }
  655. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  656. return srv.(SearcherServer).SearchProviderEvents(ctx, req.(*ProviderEventsFilter))
  657. }
  658. return interceptor(ctx, in, info, handler)
  659. }
  660. var _Searcher_serviceDesc = grpc.ServiceDesc{
  661. ServiceName: "proto.Searcher",
  662. HandlerType: (*SearcherServer)(nil),
  663. Methods: []grpc.MethodDesc{
  664. {
  665. MethodName: "SearchFsEvents",
  666. Handler: _Searcher_SearchFsEvents_Handler,
  667. },
  668. {
  669. MethodName: "SearchProviderEvents",
  670. Handler: _Searcher_SearchProviderEvents_Handler,
  671. },
  672. },
  673. Streams: []grpc.StreamDesc{},
  674. Metadata: "eventsearcher/proto/search.proto",
  675. }