You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

946 lines
37 KiB

  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // versions:
  3. // protoc-gen-go v1.34.2
  4. // protoc v5.28.3
  5. // source: mq_agent.proto
  6. package mq_agent_pb
  7. import (
  8. schema_pb "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb"
  9. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  10. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  11. reflect "reflect"
  12. sync "sync"
  13. )
  14. const (
  15. // Verify that this generated code is sufficiently up-to-date.
  16. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  17. // Verify that runtime/protoimpl is sufficiently up-to-date.
  18. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  19. )
  20. // ////////////////////////////////////////////////
  21. type StartPublishSessionRequest struct {
  22. state protoimpl.MessageState
  23. sizeCache protoimpl.SizeCache
  24. unknownFields protoimpl.UnknownFields
  25. Topic *schema_pb.Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
  26. PartitionCount int32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
  27. RecordType *schema_pb.RecordType `protobuf:"bytes,3,opt,name=record_type,json=recordType,proto3" json:"record_type,omitempty"`
  28. PublisherName string `protobuf:"bytes,4,opt,name=publisher_name,json=publisherName,proto3" json:"publisher_name,omitempty"`
  29. }
  30. func (x *StartPublishSessionRequest) Reset() {
  31. *x = StartPublishSessionRequest{}
  32. if protoimpl.UnsafeEnabled {
  33. mi := &file_mq_agent_proto_msgTypes[0]
  34. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  35. ms.StoreMessageInfo(mi)
  36. }
  37. }
  38. func (x *StartPublishSessionRequest) String() string {
  39. return protoimpl.X.MessageStringOf(x)
  40. }
  41. func (*StartPublishSessionRequest) ProtoMessage() {}
  42. func (x *StartPublishSessionRequest) ProtoReflect() protoreflect.Message {
  43. mi := &file_mq_agent_proto_msgTypes[0]
  44. if protoimpl.UnsafeEnabled && x != nil {
  45. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  46. if ms.LoadMessageInfo() == nil {
  47. ms.StoreMessageInfo(mi)
  48. }
  49. return ms
  50. }
  51. return mi.MessageOf(x)
  52. }
  53. // Deprecated: Use StartPublishSessionRequest.ProtoReflect.Descriptor instead.
  54. func (*StartPublishSessionRequest) Descriptor() ([]byte, []int) {
  55. return file_mq_agent_proto_rawDescGZIP(), []int{0}
  56. }
  57. func (x *StartPublishSessionRequest) GetTopic() *schema_pb.Topic {
  58. if x != nil {
  59. return x.Topic
  60. }
  61. return nil
  62. }
  63. func (x *StartPublishSessionRequest) GetPartitionCount() int32 {
  64. if x != nil {
  65. return x.PartitionCount
  66. }
  67. return 0
  68. }
  69. func (x *StartPublishSessionRequest) GetRecordType() *schema_pb.RecordType {
  70. if x != nil {
  71. return x.RecordType
  72. }
  73. return nil
  74. }
  75. func (x *StartPublishSessionRequest) GetPublisherName() string {
  76. if x != nil {
  77. return x.PublisherName
  78. }
  79. return ""
  80. }
  81. type StartPublishSessionResponse struct {
  82. state protoimpl.MessageState
  83. sizeCache protoimpl.SizeCache
  84. unknownFields protoimpl.UnknownFields
  85. Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
  86. SessionId int64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
  87. }
  88. func (x *StartPublishSessionResponse) Reset() {
  89. *x = StartPublishSessionResponse{}
  90. if protoimpl.UnsafeEnabled {
  91. mi := &file_mq_agent_proto_msgTypes[1]
  92. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  93. ms.StoreMessageInfo(mi)
  94. }
  95. }
  96. func (x *StartPublishSessionResponse) String() string {
  97. return protoimpl.X.MessageStringOf(x)
  98. }
  99. func (*StartPublishSessionResponse) ProtoMessage() {}
  100. func (x *StartPublishSessionResponse) ProtoReflect() protoreflect.Message {
  101. mi := &file_mq_agent_proto_msgTypes[1]
  102. if protoimpl.UnsafeEnabled && x != nil {
  103. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  104. if ms.LoadMessageInfo() == nil {
  105. ms.StoreMessageInfo(mi)
  106. }
  107. return ms
  108. }
  109. return mi.MessageOf(x)
  110. }
  111. // Deprecated: Use StartPublishSessionResponse.ProtoReflect.Descriptor instead.
  112. func (*StartPublishSessionResponse) Descriptor() ([]byte, []int) {
  113. return file_mq_agent_proto_rawDescGZIP(), []int{1}
  114. }
  115. func (x *StartPublishSessionResponse) GetError() string {
  116. if x != nil {
  117. return x.Error
  118. }
  119. return ""
  120. }
  121. func (x *StartPublishSessionResponse) GetSessionId() int64 {
  122. if x != nil {
  123. return x.SessionId
  124. }
  125. return 0
  126. }
  127. type ClosePublishSessionRequest struct {
  128. state protoimpl.MessageState
  129. sizeCache protoimpl.SizeCache
  130. unknownFields protoimpl.UnknownFields
  131. SessionId int64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
  132. }
  133. func (x *ClosePublishSessionRequest) Reset() {
  134. *x = ClosePublishSessionRequest{}
  135. if protoimpl.UnsafeEnabled {
  136. mi := &file_mq_agent_proto_msgTypes[2]
  137. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  138. ms.StoreMessageInfo(mi)
  139. }
  140. }
  141. func (x *ClosePublishSessionRequest) String() string {
  142. return protoimpl.X.MessageStringOf(x)
  143. }
  144. func (*ClosePublishSessionRequest) ProtoMessage() {}
  145. func (x *ClosePublishSessionRequest) ProtoReflect() protoreflect.Message {
  146. mi := &file_mq_agent_proto_msgTypes[2]
  147. if protoimpl.UnsafeEnabled && x != nil {
  148. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  149. if ms.LoadMessageInfo() == nil {
  150. ms.StoreMessageInfo(mi)
  151. }
  152. return ms
  153. }
  154. return mi.MessageOf(x)
  155. }
  156. // Deprecated: Use ClosePublishSessionRequest.ProtoReflect.Descriptor instead.
  157. func (*ClosePublishSessionRequest) Descriptor() ([]byte, []int) {
  158. return file_mq_agent_proto_rawDescGZIP(), []int{2}
  159. }
  160. func (x *ClosePublishSessionRequest) GetSessionId() int64 {
  161. if x != nil {
  162. return x.SessionId
  163. }
  164. return 0
  165. }
  166. type ClosePublishSessionResponse struct {
  167. state protoimpl.MessageState
  168. sizeCache protoimpl.SizeCache
  169. unknownFields protoimpl.UnknownFields
  170. Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
  171. }
  172. func (x *ClosePublishSessionResponse) Reset() {
  173. *x = ClosePublishSessionResponse{}
  174. if protoimpl.UnsafeEnabled {
  175. mi := &file_mq_agent_proto_msgTypes[3]
  176. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  177. ms.StoreMessageInfo(mi)
  178. }
  179. }
  180. func (x *ClosePublishSessionResponse) String() string {
  181. return protoimpl.X.MessageStringOf(x)
  182. }
  183. func (*ClosePublishSessionResponse) ProtoMessage() {}
  184. func (x *ClosePublishSessionResponse) ProtoReflect() protoreflect.Message {
  185. mi := &file_mq_agent_proto_msgTypes[3]
  186. if protoimpl.UnsafeEnabled && x != nil {
  187. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  188. if ms.LoadMessageInfo() == nil {
  189. ms.StoreMessageInfo(mi)
  190. }
  191. return ms
  192. }
  193. return mi.MessageOf(x)
  194. }
  195. // Deprecated: Use ClosePublishSessionResponse.ProtoReflect.Descriptor instead.
  196. func (*ClosePublishSessionResponse) Descriptor() ([]byte, []int) {
  197. return file_mq_agent_proto_rawDescGZIP(), []int{3}
  198. }
  199. func (x *ClosePublishSessionResponse) GetError() string {
  200. if x != nil {
  201. return x.Error
  202. }
  203. return ""
  204. }
  205. // ////////////////////////////////////////////////
  206. type PublishRecordRequest struct {
  207. state protoimpl.MessageState
  208. sizeCache protoimpl.SizeCache
  209. unknownFields protoimpl.UnknownFields
  210. SessionId int64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // session_id is required for the first record
  211. Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
  212. Value *schema_pb.RecordValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
  213. }
  214. func (x *PublishRecordRequest) Reset() {
  215. *x = PublishRecordRequest{}
  216. if protoimpl.UnsafeEnabled {
  217. mi := &file_mq_agent_proto_msgTypes[4]
  218. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  219. ms.StoreMessageInfo(mi)
  220. }
  221. }
  222. func (x *PublishRecordRequest) String() string {
  223. return protoimpl.X.MessageStringOf(x)
  224. }
  225. func (*PublishRecordRequest) ProtoMessage() {}
  226. func (x *PublishRecordRequest) ProtoReflect() protoreflect.Message {
  227. mi := &file_mq_agent_proto_msgTypes[4]
  228. if protoimpl.UnsafeEnabled && x != nil {
  229. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  230. if ms.LoadMessageInfo() == nil {
  231. ms.StoreMessageInfo(mi)
  232. }
  233. return ms
  234. }
  235. return mi.MessageOf(x)
  236. }
  237. // Deprecated: Use PublishRecordRequest.ProtoReflect.Descriptor instead.
  238. func (*PublishRecordRequest) Descriptor() ([]byte, []int) {
  239. return file_mq_agent_proto_rawDescGZIP(), []int{4}
  240. }
  241. func (x *PublishRecordRequest) GetSessionId() int64 {
  242. if x != nil {
  243. return x.SessionId
  244. }
  245. return 0
  246. }
  247. func (x *PublishRecordRequest) GetKey() []byte {
  248. if x != nil {
  249. return x.Key
  250. }
  251. return nil
  252. }
  253. func (x *PublishRecordRequest) GetValue() *schema_pb.RecordValue {
  254. if x != nil {
  255. return x.Value
  256. }
  257. return nil
  258. }
  259. type PublishRecordResponse struct {
  260. state protoimpl.MessageState
  261. sizeCache protoimpl.SizeCache
  262. unknownFields protoimpl.UnknownFields
  263. AckSequence int64 `protobuf:"varint,1,opt,name=ack_sequence,json=ackSequence,proto3" json:"ack_sequence,omitempty"`
  264. Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
  265. }
  266. func (x *PublishRecordResponse) Reset() {
  267. *x = PublishRecordResponse{}
  268. if protoimpl.UnsafeEnabled {
  269. mi := &file_mq_agent_proto_msgTypes[5]
  270. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  271. ms.StoreMessageInfo(mi)
  272. }
  273. }
  274. func (x *PublishRecordResponse) String() string {
  275. return protoimpl.X.MessageStringOf(x)
  276. }
  277. func (*PublishRecordResponse) ProtoMessage() {}
  278. func (x *PublishRecordResponse) ProtoReflect() protoreflect.Message {
  279. mi := &file_mq_agent_proto_msgTypes[5]
  280. if protoimpl.UnsafeEnabled && x != nil {
  281. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  282. if ms.LoadMessageInfo() == nil {
  283. ms.StoreMessageInfo(mi)
  284. }
  285. return ms
  286. }
  287. return mi.MessageOf(x)
  288. }
  289. // Deprecated: Use PublishRecordResponse.ProtoReflect.Descriptor instead.
  290. func (*PublishRecordResponse) Descriptor() ([]byte, []int) {
  291. return file_mq_agent_proto_rawDescGZIP(), []int{5}
  292. }
  293. func (x *PublishRecordResponse) GetAckSequence() int64 {
  294. if x != nil {
  295. return x.AckSequence
  296. }
  297. return 0
  298. }
  299. func (x *PublishRecordResponse) GetError() string {
  300. if x != nil {
  301. return x.Error
  302. }
  303. return ""
  304. }
  305. // ////////////////////////////////////////////////
  306. type SubscribeRecordRequest struct {
  307. state protoimpl.MessageState
  308. sizeCache protoimpl.SizeCache
  309. unknownFields protoimpl.UnknownFields
  310. Init *SubscribeRecordRequest_InitSubscribeRecordRequest `protobuf:"bytes,1,opt,name=init,proto3" json:"init,omitempty"`
  311. AckSequence int64 `protobuf:"varint,2,opt,name=ack_sequence,json=ackSequence,proto3" json:"ack_sequence,omitempty"`
  312. AckKey []byte `protobuf:"bytes,3,opt,name=ack_key,json=ackKey,proto3" json:"ack_key,omitempty"`
  313. }
  314. func (x *SubscribeRecordRequest) Reset() {
  315. *x = SubscribeRecordRequest{}
  316. if protoimpl.UnsafeEnabled {
  317. mi := &file_mq_agent_proto_msgTypes[6]
  318. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  319. ms.StoreMessageInfo(mi)
  320. }
  321. }
  322. func (x *SubscribeRecordRequest) String() string {
  323. return protoimpl.X.MessageStringOf(x)
  324. }
  325. func (*SubscribeRecordRequest) ProtoMessage() {}
  326. func (x *SubscribeRecordRequest) ProtoReflect() protoreflect.Message {
  327. mi := &file_mq_agent_proto_msgTypes[6]
  328. if protoimpl.UnsafeEnabled && x != nil {
  329. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  330. if ms.LoadMessageInfo() == nil {
  331. ms.StoreMessageInfo(mi)
  332. }
  333. return ms
  334. }
  335. return mi.MessageOf(x)
  336. }
  337. // Deprecated: Use SubscribeRecordRequest.ProtoReflect.Descriptor instead.
  338. func (*SubscribeRecordRequest) Descriptor() ([]byte, []int) {
  339. return file_mq_agent_proto_rawDescGZIP(), []int{6}
  340. }
  341. func (x *SubscribeRecordRequest) GetInit() *SubscribeRecordRequest_InitSubscribeRecordRequest {
  342. if x != nil {
  343. return x.Init
  344. }
  345. return nil
  346. }
  347. func (x *SubscribeRecordRequest) GetAckSequence() int64 {
  348. if x != nil {
  349. return x.AckSequence
  350. }
  351. return 0
  352. }
  353. func (x *SubscribeRecordRequest) GetAckKey() []byte {
  354. if x != nil {
  355. return x.AckKey
  356. }
  357. return nil
  358. }
  359. type SubscribeRecordResponse struct {
  360. state protoimpl.MessageState
  361. sizeCache protoimpl.SizeCache
  362. unknownFields protoimpl.UnknownFields
  363. Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
  364. Value *schema_pb.RecordValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
  365. TsNs int64 `protobuf:"varint,4,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
  366. Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
  367. IsEndOfStream bool `protobuf:"varint,6,opt,name=is_end_of_stream,json=isEndOfStream,proto3" json:"is_end_of_stream,omitempty"`
  368. IsEndOfTopic bool `protobuf:"varint,7,opt,name=is_end_of_topic,json=isEndOfTopic,proto3" json:"is_end_of_topic,omitempty"`
  369. }
  370. func (x *SubscribeRecordResponse) Reset() {
  371. *x = SubscribeRecordResponse{}
  372. if protoimpl.UnsafeEnabled {
  373. mi := &file_mq_agent_proto_msgTypes[7]
  374. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  375. ms.StoreMessageInfo(mi)
  376. }
  377. }
  378. func (x *SubscribeRecordResponse) String() string {
  379. return protoimpl.X.MessageStringOf(x)
  380. }
  381. func (*SubscribeRecordResponse) ProtoMessage() {}
  382. func (x *SubscribeRecordResponse) ProtoReflect() protoreflect.Message {
  383. mi := &file_mq_agent_proto_msgTypes[7]
  384. if protoimpl.UnsafeEnabled && x != nil {
  385. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  386. if ms.LoadMessageInfo() == nil {
  387. ms.StoreMessageInfo(mi)
  388. }
  389. return ms
  390. }
  391. return mi.MessageOf(x)
  392. }
  393. // Deprecated: Use SubscribeRecordResponse.ProtoReflect.Descriptor instead.
  394. func (*SubscribeRecordResponse) Descriptor() ([]byte, []int) {
  395. return file_mq_agent_proto_rawDescGZIP(), []int{7}
  396. }
  397. func (x *SubscribeRecordResponse) GetKey() []byte {
  398. if x != nil {
  399. return x.Key
  400. }
  401. return nil
  402. }
  403. func (x *SubscribeRecordResponse) GetValue() *schema_pb.RecordValue {
  404. if x != nil {
  405. return x.Value
  406. }
  407. return nil
  408. }
  409. func (x *SubscribeRecordResponse) GetTsNs() int64 {
  410. if x != nil {
  411. return x.TsNs
  412. }
  413. return 0
  414. }
  415. func (x *SubscribeRecordResponse) GetError() string {
  416. if x != nil {
  417. return x.Error
  418. }
  419. return ""
  420. }
  421. func (x *SubscribeRecordResponse) GetIsEndOfStream() bool {
  422. if x != nil {
  423. return x.IsEndOfStream
  424. }
  425. return false
  426. }
  427. func (x *SubscribeRecordResponse) GetIsEndOfTopic() bool {
  428. if x != nil {
  429. return x.IsEndOfTopic
  430. }
  431. return false
  432. }
  433. type SubscribeRecordRequest_InitSubscribeRecordRequest struct {
  434. state protoimpl.MessageState
  435. sizeCache protoimpl.SizeCache
  436. unknownFields protoimpl.UnknownFields
  437. ConsumerGroup string `protobuf:"bytes,1,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
  438. ConsumerGroupInstanceId string `protobuf:"bytes,2,opt,name=consumer_group_instance_id,json=consumerGroupInstanceId,proto3" json:"consumer_group_instance_id,omitempty"`
  439. Topic *schema_pb.Topic `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
  440. PartitionOffsets []*schema_pb.PartitionOffset `protobuf:"bytes,5,rep,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
  441. OffsetType schema_pb.OffsetType `protobuf:"varint,6,opt,name=offset_type,json=offsetType,proto3,enum=schema_pb.OffsetType" json:"offset_type,omitempty"`
  442. OffsetTsNs int64 `protobuf:"varint,7,opt,name=offset_ts_ns,json=offsetTsNs,proto3" json:"offset_ts_ns,omitempty"`
  443. Filter string `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
  444. MaxSubscribedPartitions int32 `protobuf:"varint,11,opt,name=max_subscribed_partitions,json=maxSubscribedPartitions,proto3" json:"max_subscribed_partitions,omitempty"`
  445. SlidingWindowSize int32 `protobuf:"varint,12,opt,name=sliding_window_size,json=slidingWindowSize,proto3" json:"sliding_window_size,omitempty"`
  446. }
  447. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) Reset() {
  448. *x = SubscribeRecordRequest_InitSubscribeRecordRequest{}
  449. if protoimpl.UnsafeEnabled {
  450. mi := &file_mq_agent_proto_msgTypes[8]
  451. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  452. ms.StoreMessageInfo(mi)
  453. }
  454. }
  455. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) String() string {
  456. return protoimpl.X.MessageStringOf(x)
  457. }
  458. func (*SubscribeRecordRequest_InitSubscribeRecordRequest) ProtoMessage() {}
  459. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) ProtoReflect() protoreflect.Message {
  460. mi := &file_mq_agent_proto_msgTypes[8]
  461. if protoimpl.UnsafeEnabled && x != nil {
  462. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  463. if ms.LoadMessageInfo() == nil {
  464. ms.StoreMessageInfo(mi)
  465. }
  466. return ms
  467. }
  468. return mi.MessageOf(x)
  469. }
  470. // Deprecated: Use SubscribeRecordRequest_InitSubscribeRecordRequest.ProtoReflect.Descriptor instead.
  471. func (*SubscribeRecordRequest_InitSubscribeRecordRequest) Descriptor() ([]byte, []int) {
  472. return file_mq_agent_proto_rawDescGZIP(), []int{6, 0}
  473. }
  474. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetConsumerGroup() string {
  475. if x != nil {
  476. return x.ConsumerGroup
  477. }
  478. return ""
  479. }
  480. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetConsumerGroupInstanceId() string {
  481. if x != nil {
  482. return x.ConsumerGroupInstanceId
  483. }
  484. return ""
  485. }
  486. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetTopic() *schema_pb.Topic {
  487. if x != nil {
  488. return x.Topic
  489. }
  490. return nil
  491. }
  492. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetPartitionOffsets() []*schema_pb.PartitionOffset {
  493. if x != nil {
  494. return x.PartitionOffsets
  495. }
  496. return nil
  497. }
  498. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetOffsetType() schema_pb.OffsetType {
  499. if x != nil {
  500. return x.OffsetType
  501. }
  502. return schema_pb.OffsetType(0)
  503. }
  504. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetOffsetTsNs() int64 {
  505. if x != nil {
  506. return x.OffsetTsNs
  507. }
  508. return 0
  509. }
  510. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetFilter() string {
  511. if x != nil {
  512. return x.Filter
  513. }
  514. return ""
  515. }
  516. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetMaxSubscribedPartitions() int32 {
  517. if x != nil {
  518. return x.MaxSubscribedPartitions
  519. }
  520. return 0
  521. }
  522. func (x *SubscribeRecordRequest_InitSubscribeRecordRequest) GetSlidingWindowSize() int32 {
  523. if x != nil {
  524. return x.SlidingWindowSize
  525. }
  526. return 0
  527. }
  528. var File_mq_agent_proto protoreflect.FileDescriptor
  529. var file_mq_agent_proto_rawDesc = []byte{
  530. 0x0a, 0x0e, 0x6d, 0x71, 0x5f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  531. 0x12, 0x0c, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x1a, 0x0f,
  532. 0x6d, 0x71, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
  533. 0xcc, 0x01, 0x0a, 0x1a, 0x53, 0x74, 0x61, 0x72, 0x74, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68,
  534. 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26,
  535. 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e,
  536. 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52,
  537. 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74,
  538. 0x69, 0x6f, 0x6e, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52,
  539. 0x0e, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12,
  540. 0x36, 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03,
  541. 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62,
  542. 0x2e, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 0x72, 0x65, 0x63,
  543. 0x6f, 0x72, 0x64, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x70, 0x75, 0x62, 0x6c, 0x69,
  544. 0x73, 0x68, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52,
  545. 0x0d, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x52,
  546. 0x0a, 0x1b, 0x53, 0x74, 0x61, 0x72, 0x74, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65,
  547. 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a,
  548. 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72,
  549. 0x72, 0x6f, 0x72, 0x12, 0x1d, 0x0a, 0x0a, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69,
  550. 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
  551. 0x49, 0x64, 0x22, 0x3b, 0x0a, 0x1a, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69,
  552. 0x73, 0x68, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  553. 0x12, 0x1d, 0x0a, 0x0a, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01,
  554. 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22,
  555. 0x33, 0x0a, 0x1b, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53,
  556. 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x14,
  557. 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65,
  558. 0x72, 0x72, 0x6f, 0x72, 0x22, 0x75, 0x0a, 0x14, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52,
  559. 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a,
  560. 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
  561. 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x6b,
  562. 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x2c, 0x0a,
  563. 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x73,
  564. 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x56,
  565. 0x61, 0x6c, 0x75, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x50, 0x0a, 0x15, 0x50,
  566. 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x73, 0x70,
  567. 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x65, 0x71, 0x75,
  568. 0x65, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x61, 0x63, 0x6b, 0x53,
  569. 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72,
  570. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0xfb, 0x04,
  571. 0x0a, 0x16, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72,
  572. 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x53, 0x0a, 0x04, 0x69, 0x6e, 0x69, 0x74,
  573. 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3f, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69,
  574. 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52,
  575. 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x6e, 0x69,
  576. 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64,
  577. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x52, 0x04, 0x69, 0x6e, 0x69, 0x74, 0x12, 0x21, 0x0a,
  578. 0x0c, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x18, 0x02, 0x20,
  579. 0x01, 0x28, 0x03, 0x52, 0x0b, 0x61, 0x63, 0x6b, 0x53, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65,
  580. 0x12, 0x17, 0x0a, 0x07, 0x61, 0x63, 0x6b, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28,
  581. 0x0c, 0x52, 0x06, 0x61, 0x63, 0x6b, 0x4b, 0x65, 0x79, 0x1a, 0xcf, 0x03, 0x0a, 0x1a, 0x49, 0x6e,
  582. 0x69, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72,
  583. 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x25, 0x0a, 0x0e, 0x63, 0x6f, 0x6e, 0x73,
  584. 0x75, 0x6d, 0x65, 0x72, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
  585. 0x52, 0x0d, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x12,
  586. 0x3b, 0x0a, 0x1a, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x5f, 0x67, 0x72, 0x6f, 0x75,
  587. 0x70, 0x5f, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
  588. 0x01, 0x28, 0x09, 0x52, 0x17, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x72, 0x47, 0x72, 0x6f,
  589. 0x75, 0x70, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x49, 0x64, 0x12, 0x26, 0x0a, 0x05,
  590. 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x73, 0x63,
  591. 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x05, 0x74,
  592. 0x6f, 0x70, 0x69, 0x63, 0x12, 0x47, 0x0a, 0x11, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f,
  593. 0x6e, 0x5f, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32,
  594. 0x1a, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x50, 0x61, 0x72, 0x74,
  595. 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x52, 0x10, 0x70, 0x61, 0x72,
  596. 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x12, 0x36, 0x0a,
  597. 0x0b, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x06, 0x20, 0x01,
  598. 0x28, 0x0e, 0x32, 0x15, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x4f,
  599. 0x66, 0x66, 0x73, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 0x6f, 0x66, 0x66, 0x73, 0x65,
  600. 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0c, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x5f,
  601. 0x74, 0x73, 0x5f, 0x6e, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x6f, 0x66, 0x66,
  602. 0x73, 0x65, 0x74, 0x54, 0x73, 0x4e, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65,
  603. 0x72, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12,
  604. 0x3a, 0x0a, 0x19, 0x6d, 0x61, 0x78, 0x5f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65,
  605. 0x64, 0x5f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x0b, 0x20, 0x01,
  606. 0x28, 0x05, 0x52, 0x17, 0x6d, 0x61, 0x78, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65,
  607. 0x64, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x2e, 0x0a, 0x13, 0x73,
  608. 0x6c, 0x69, 0x64, 0x69, 0x6e, 0x67, 0x5f, 0x77, 0x69, 0x6e, 0x64, 0x6f, 0x77, 0x5f, 0x73, 0x69,
  609. 0x7a, 0x65, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x73, 0x6c, 0x69, 0x64, 0x69, 0x6e,
  610. 0x67, 0x57, 0x69, 0x6e, 0x64, 0x6f, 0x77, 0x53, 0x69, 0x7a, 0x65, 0x22, 0xd4, 0x01, 0x0a, 0x17,
  611. 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52,
  612. 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x02,
  613. 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x2c, 0x0a, 0x05, 0x76, 0x61, 0x6c,
  614. 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x6d,
  615. 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65,
  616. 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x13, 0x0a, 0x05, 0x74, 0x73, 0x5f, 0x6e, 0x73,
  617. 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x74, 0x73, 0x4e, 0x73, 0x12, 0x14, 0x0a, 0x05,
  618. 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72,
  619. 0x6f, 0x72, 0x12, 0x27, 0x0a, 0x10, 0x69, 0x73, 0x5f, 0x65, 0x6e, 0x64, 0x5f, 0x6f, 0x66, 0x5f,
  620. 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x69, 0x73,
  621. 0x45, 0x6e, 0x64, 0x4f, 0x66, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x25, 0x0a, 0x0f, 0x69,
  622. 0x73, 0x5f, 0x65, 0x6e, 0x64, 0x5f, 0x6f, 0x66, 0x5f, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x07,
  623. 0x20, 0x01, 0x28, 0x08, 0x52, 0x0c, 0x69, 0x73, 0x45, 0x6e, 0x64, 0x4f, 0x66, 0x54, 0x6f, 0x70,
  624. 0x69, 0x63, 0x32, 0xb9, 0x03, 0x0a, 0x15, 0x53, 0x65, 0x61, 0x77, 0x65, 0x65, 0x64, 0x4d, 0x65,
  625. 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x41, 0x67, 0x65, 0x6e, 0x74, 0x12, 0x6c, 0x0a, 0x13,
  626. 0x53, 0x74, 0x61, 0x72, 0x74, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65, 0x73, 0x73,
  627. 0x69, 0x6f, 0x6e, 0x12, 0x28, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f,
  628. 0x70, 0x62, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53,
  629. 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e,
  630. 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x53, 0x74, 0x61,
  631. 0x72, 0x74, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
  632. 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x6c, 0x0a, 0x13, 0x43, 0x6c,
  633. 0x6f, 0x73, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f,
  634. 0x6e, 0x12, 0x28, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62,
  635. 0x2e, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65, 0x73,
  636. 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x6d, 0x65,
  637. 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x43, 0x6c, 0x6f, 0x73, 0x65,
  638. 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65,
  639. 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x5e, 0x0a, 0x0d, 0x50, 0x75, 0x62, 0x6c,
  640. 0x69, 0x73, 0x68, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x12, 0x22, 0x2e, 0x6d, 0x65, 0x73, 0x73,
  641. 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68,
  642. 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e,
  643. 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x50, 0x75, 0x62,
  644. 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  645. 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x64, 0x0a, 0x0f, 0x53, 0x75, 0x62, 0x73,
  646. 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x12, 0x24, 0x2e, 0x6d, 0x65,
  647. 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63,
  648. 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  649. 0x74, 0x1a, 0x25, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x5f, 0x70, 0x62,
  650. 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64,
  651. 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x42, 0x60,
  652. 0x0a, 0x12, 0x73, 0x65, 0x61, 0x77, 0x65, 0x65, 0x64, 0x66, 0x73, 0x2e, 0x6d, 0x71, 0x5f, 0x61,
  653. 0x67, 0x65, 0x6e, 0x74, 0x42, 0x16, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x51, 0x75, 0x65,
  654. 0x75, 0x65, 0x41, 0x67, 0x65, 0x6e, 0x74, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x32, 0x67, 0x69,
  655. 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x65, 0x61, 0x77, 0x65, 0x65, 0x64,
  656. 0x66, 0x73, 0x2f, 0x73, 0x65, 0x61, 0x77, 0x65, 0x65, 0x64, 0x66, 0x73, 0x2f, 0x77, 0x65, 0x65,
  657. 0x64, 0x2f, 0x70, 0x62, 0x2f, 0x6d, 0x71, 0x5f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x70, 0x62,
  658. 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  659. }
  660. var (
  661. file_mq_agent_proto_rawDescOnce sync.Once
  662. file_mq_agent_proto_rawDescData = file_mq_agent_proto_rawDesc
  663. )
  664. func file_mq_agent_proto_rawDescGZIP() []byte {
  665. file_mq_agent_proto_rawDescOnce.Do(func() {
  666. file_mq_agent_proto_rawDescData = protoimpl.X.CompressGZIP(file_mq_agent_proto_rawDescData)
  667. })
  668. return file_mq_agent_proto_rawDescData
  669. }
  670. var file_mq_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
  671. var file_mq_agent_proto_goTypes = []any{
  672. (*StartPublishSessionRequest)(nil), // 0: messaging_pb.StartPublishSessionRequest
  673. (*StartPublishSessionResponse)(nil), // 1: messaging_pb.StartPublishSessionResponse
  674. (*ClosePublishSessionRequest)(nil), // 2: messaging_pb.ClosePublishSessionRequest
  675. (*ClosePublishSessionResponse)(nil), // 3: messaging_pb.ClosePublishSessionResponse
  676. (*PublishRecordRequest)(nil), // 4: messaging_pb.PublishRecordRequest
  677. (*PublishRecordResponse)(nil), // 5: messaging_pb.PublishRecordResponse
  678. (*SubscribeRecordRequest)(nil), // 6: messaging_pb.SubscribeRecordRequest
  679. (*SubscribeRecordResponse)(nil), // 7: messaging_pb.SubscribeRecordResponse
  680. (*SubscribeRecordRequest_InitSubscribeRecordRequest)(nil), // 8: messaging_pb.SubscribeRecordRequest.InitSubscribeRecordRequest
  681. (*schema_pb.Topic)(nil), // 9: schema_pb.Topic
  682. (*schema_pb.RecordType)(nil), // 10: schema_pb.RecordType
  683. (*schema_pb.RecordValue)(nil), // 11: schema_pb.RecordValue
  684. (*schema_pb.PartitionOffset)(nil), // 12: schema_pb.PartitionOffset
  685. (schema_pb.OffsetType)(0), // 13: schema_pb.OffsetType
  686. }
  687. var file_mq_agent_proto_depIdxs = []int32{
  688. 9, // 0: messaging_pb.StartPublishSessionRequest.topic:type_name -> schema_pb.Topic
  689. 10, // 1: messaging_pb.StartPublishSessionRequest.record_type:type_name -> schema_pb.RecordType
  690. 11, // 2: messaging_pb.PublishRecordRequest.value:type_name -> schema_pb.RecordValue
  691. 8, // 3: messaging_pb.SubscribeRecordRequest.init:type_name -> messaging_pb.SubscribeRecordRequest.InitSubscribeRecordRequest
  692. 11, // 4: messaging_pb.SubscribeRecordResponse.value:type_name -> schema_pb.RecordValue
  693. 9, // 5: messaging_pb.SubscribeRecordRequest.InitSubscribeRecordRequest.topic:type_name -> schema_pb.Topic
  694. 12, // 6: messaging_pb.SubscribeRecordRequest.InitSubscribeRecordRequest.partition_offsets:type_name -> schema_pb.PartitionOffset
  695. 13, // 7: messaging_pb.SubscribeRecordRequest.InitSubscribeRecordRequest.offset_type:type_name -> schema_pb.OffsetType
  696. 0, // 8: messaging_pb.SeaweedMessagingAgent.StartPublishSession:input_type -> messaging_pb.StartPublishSessionRequest
  697. 2, // 9: messaging_pb.SeaweedMessagingAgent.ClosePublishSession:input_type -> messaging_pb.ClosePublishSessionRequest
  698. 4, // 10: messaging_pb.SeaweedMessagingAgent.PublishRecord:input_type -> messaging_pb.PublishRecordRequest
  699. 6, // 11: messaging_pb.SeaweedMessagingAgent.SubscribeRecord:input_type -> messaging_pb.SubscribeRecordRequest
  700. 1, // 12: messaging_pb.SeaweedMessagingAgent.StartPublishSession:output_type -> messaging_pb.StartPublishSessionResponse
  701. 3, // 13: messaging_pb.SeaweedMessagingAgent.ClosePublishSession:output_type -> messaging_pb.ClosePublishSessionResponse
  702. 5, // 14: messaging_pb.SeaweedMessagingAgent.PublishRecord:output_type -> messaging_pb.PublishRecordResponse
  703. 7, // 15: messaging_pb.SeaweedMessagingAgent.SubscribeRecord:output_type -> messaging_pb.SubscribeRecordResponse
  704. 12, // [12:16] is the sub-list for method output_type
  705. 8, // [8:12] is the sub-list for method input_type
  706. 8, // [8:8] is the sub-list for extension type_name
  707. 8, // [8:8] is the sub-list for extension extendee
  708. 0, // [0:8] is the sub-list for field type_name
  709. }
  710. func init() { file_mq_agent_proto_init() }
  711. func file_mq_agent_proto_init() {
  712. if File_mq_agent_proto != nil {
  713. return
  714. }
  715. if !protoimpl.UnsafeEnabled {
  716. file_mq_agent_proto_msgTypes[0].Exporter = func(v any, i int) any {
  717. switch v := v.(*StartPublishSessionRequest); i {
  718. case 0:
  719. return &v.state
  720. case 1:
  721. return &v.sizeCache
  722. case 2:
  723. return &v.unknownFields
  724. default:
  725. return nil
  726. }
  727. }
  728. file_mq_agent_proto_msgTypes[1].Exporter = func(v any, i int) any {
  729. switch v := v.(*StartPublishSessionResponse); i {
  730. case 0:
  731. return &v.state
  732. case 1:
  733. return &v.sizeCache
  734. case 2:
  735. return &v.unknownFields
  736. default:
  737. return nil
  738. }
  739. }
  740. file_mq_agent_proto_msgTypes[2].Exporter = func(v any, i int) any {
  741. switch v := v.(*ClosePublishSessionRequest); i {
  742. case 0:
  743. return &v.state
  744. case 1:
  745. return &v.sizeCache
  746. case 2:
  747. return &v.unknownFields
  748. default:
  749. return nil
  750. }
  751. }
  752. file_mq_agent_proto_msgTypes[3].Exporter = func(v any, i int) any {
  753. switch v := v.(*ClosePublishSessionResponse); i {
  754. case 0:
  755. return &v.state
  756. case 1:
  757. return &v.sizeCache
  758. case 2:
  759. return &v.unknownFields
  760. default:
  761. return nil
  762. }
  763. }
  764. file_mq_agent_proto_msgTypes[4].Exporter = func(v any, i int) any {
  765. switch v := v.(*PublishRecordRequest); i {
  766. case 0:
  767. return &v.state
  768. case 1:
  769. return &v.sizeCache
  770. case 2:
  771. return &v.unknownFields
  772. default:
  773. return nil
  774. }
  775. }
  776. file_mq_agent_proto_msgTypes[5].Exporter = func(v any, i int) any {
  777. switch v := v.(*PublishRecordResponse); i {
  778. case 0:
  779. return &v.state
  780. case 1:
  781. return &v.sizeCache
  782. case 2:
  783. return &v.unknownFields
  784. default:
  785. return nil
  786. }
  787. }
  788. file_mq_agent_proto_msgTypes[6].Exporter = func(v any, i int) any {
  789. switch v := v.(*SubscribeRecordRequest); i {
  790. case 0:
  791. return &v.state
  792. case 1:
  793. return &v.sizeCache
  794. case 2:
  795. return &v.unknownFields
  796. default:
  797. return nil
  798. }
  799. }
  800. file_mq_agent_proto_msgTypes[7].Exporter = func(v any, i int) any {
  801. switch v := v.(*SubscribeRecordResponse); i {
  802. case 0:
  803. return &v.state
  804. case 1:
  805. return &v.sizeCache
  806. case 2:
  807. return &v.unknownFields
  808. default:
  809. return nil
  810. }
  811. }
  812. file_mq_agent_proto_msgTypes[8].Exporter = func(v any, i int) any {
  813. switch v := v.(*SubscribeRecordRequest_InitSubscribeRecordRequest); i {
  814. case 0:
  815. return &v.state
  816. case 1:
  817. return &v.sizeCache
  818. case 2:
  819. return &v.unknownFields
  820. default:
  821. return nil
  822. }
  823. }
  824. }
  825. type x struct{}
  826. out := protoimpl.TypeBuilder{
  827. File: protoimpl.DescBuilder{
  828. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  829. RawDescriptor: file_mq_agent_proto_rawDesc,
  830. NumEnums: 0,
  831. NumMessages: 9,
  832. NumExtensions: 0,
  833. NumServices: 1,
  834. },
  835. GoTypes: file_mq_agent_proto_goTypes,
  836. DependencyIndexes: file_mq_agent_proto_depIdxs,
  837. MessageInfos: file_mq_agent_proto_msgTypes,
  838. }.Build()
  839. File_mq_agent_proto = out.File
  840. file_mq_agent_proto_rawDesc = nil
  841. file_mq_agent_proto_goTypes = nil
  842. file_mq_agent_proto_depIdxs = nil
  843. }