WAL.pb.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: WAL.proto
  3. package pb
  4. import proto "github.com/golang/protobuf/proto"
  5. import fmt "fmt"
  6. import math "math"
  7. // Reference imports to suppress errors if they are not otherwise used.
  8. var _ = proto.Marshal
  9. var _ = fmt.Errorf
  10. var _ = math.Inf
  11. type ScopeType int32
  12. const (
  13. ScopeType_REPLICATION_SCOPE_LOCAL ScopeType = 0
  14. ScopeType_REPLICATION_SCOPE_GLOBAL ScopeType = 1
  15. )
  16. var ScopeType_name = map[int32]string{
  17. 0: "REPLICATION_SCOPE_LOCAL",
  18. 1: "REPLICATION_SCOPE_GLOBAL",
  19. }
  20. var ScopeType_value = map[string]int32{
  21. "REPLICATION_SCOPE_LOCAL": 0,
  22. "REPLICATION_SCOPE_GLOBAL": 1,
  23. }
  24. func (x ScopeType) Enum() *ScopeType {
  25. p := new(ScopeType)
  26. *p = x
  27. return p
  28. }
  29. func (x ScopeType) String() string {
  30. return proto.EnumName(ScopeType_name, int32(x))
  31. }
  32. func (x *ScopeType) UnmarshalJSON(data []byte) error {
  33. value, err := proto.UnmarshalJSONEnum(ScopeType_value, data, "ScopeType")
  34. if err != nil {
  35. return err
  36. }
  37. *x = ScopeType(value)
  38. return nil
  39. }
  40. func (ScopeType) EnumDescriptor() ([]byte, []int) { return fileDescriptor18, []int{0} }
  41. type FlushDescriptor_FlushAction int32
  42. const (
  43. FlushDescriptor_START_FLUSH FlushDescriptor_FlushAction = 0
  44. FlushDescriptor_COMMIT_FLUSH FlushDescriptor_FlushAction = 1
  45. FlushDescriptor_ABORT_FLUSH FlushDescriptor_FlushAction = 2
  46. FlushDescriptor_CANNOT_FLUSH FlushDescriptor_FlushAction = 3
  47. )
  48. var FlushDescriptor_FlushAction_name = map[int32]string{
  49. 0: "START_FLUSH",
  50. 1: "COMMIT_FLUSH",
  51. 2: "ABORT_FLUSH",
  52. 3: "CANNOT_FLUSH",
  53. }
  54. var FlushDescriptor_FlushAction_value = map[string]int32{
  55. "START_FLUSH": 0,
  56. "COMMIT_FLUSH": 1,
  57. "ABORT_FLUSH": 2,
  58. "CANNOT_FLUSH": 3,
  59. }
  60. func (x FlushDescriptor_FlushAction) Enum() *FlushDescriptor_FlushAction {
  61. p := new(FlushDescriptor_FlushAction)
  62. *p = x
  63. return p
  64. }
  65. func (x FlushDescriptor_FlushAction) String() string {
  66. return proto.EnumName(FlushDescriptor_FlushAction_name, int32(x))
  67. }
  68. func (x *FlushDescriptor_FlushAction) UnmarshalJSON(data []byte) error {
  69. value, err := proto.UnmarshalJSONEnum(FlushDescriptor_FlushAction_value, data, "FlushDescriptor_FlushAction")
  70. if err != nil {
  71. return err
  72. }
  73. *x = FlushDescriptor_FlushAction(value)
  74. return nil
  75. }
  76. func (FlushDescriptor_FlushAction) EnumDescriptor() ([]byte, []int) {
  77. return fileDescriptor18, []int{4, 0}
  78. }
  79. type RegionEventDescriptor_EventType int32
  80. const (
  81. RegionEventDescriptor_REGION_OPEN RegionEventDescriptor_EventType = 0
  82. RegionEventDescriptor_REGION_CLOSE RegionEventDescriptor_EventType = 1
  83. )
  84. var RegionEventDescriptor_EventType_name = map[int32]string{
  85. 0: "REGION_OPEN",
  86. 1: "REGION_CLOSE",
  87. }
  88. var RegionEventDescriptor_EventType_value = map[string]int32{
  89. "REGION_OPEN": 0,
  90. "REGION_CLOSE": 1,
  91. }
  92. func (x RegionEventDescriptor_EventType) Enum() *RegionEventDescriptor_EventType {
  93. p := new(RegionEventDescriptor_EventType)
  94. *p = x
  95. return p
  96. }
  97. func (x RegionEventDescriptor_EventType) String() string {
  98. return proto.EnumName(RegionEventDescriptor_EventType_name, int32(x))
  99. }
  100. func (x *RegionEventDescriptor_EventType) UnmarshalJSON(data []byte) error {
  101. value, err := proto.UnmarshalJSONEnum(RegionEventDescriptor_EventType_value, data, "RegionEventDescriptor_EventType")
  102. if err != nil {
  103. return err
  104. }
  105. *x = RegionEventDescriptor_EventType(value)
  106. return nil
  107. }
  108. func (RegionEventDescriptor_EventType) EnumDescriptor() ([]byte, []int) {
  109. return fileDescriptor18, []int{7, 0}
  110. }
  111. type WALHeader struct {
  112. HasCompression *bool `protobuf:"varint,1,opt,name=has_compression,json=hasCompression" json:"has_compression,omitempty"`
  113. EncryptionKey []byte `protobuf:"bytes,2,opt,name=encryption_key,json=encryptionKey" json:"encryption_key,omitempty"`
  114. HasTagCompression *bool `protobuf:"varint,3,opt,name=has_tag_compression,json=hasTagCompression" json:"has_tag_compression,omitempty"`
  115. WriterClsName *string `protobuf:"bytes,4,opt,name=writer_cls_name,json=writerClsName" json:"writer_cls_name,omitempty"`
  116. CellCodecClsName *string `protobuf:"bytes,5,opt,name=cell_codec_cls_name,json=cellCodecClsName" json:"cell_codec_cls_name,omitempty"`
  117. XXX_unrecognized []byte `json:"-"`
  118. }
  119. func (m *WALHeader) Reset() { *m = WALHeader{} }
  120. func (m *WALHeader) String() string { return proto.CompactTextString(m) }
  121. func (*WALHeader) ProtoMessage() {}
  122. func (*WALHeader) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{0} }
  123. func (m *WALHeader) GetHasCompression() bool {
  124. if m != nil && m.HasCompression != nil {
  125. return *m.HasCompression
  126. }
  127. return false
  128. }
  129. func (m *WALHeader) GetEncryptionKey() []byte {
  130. if m != nil {
  131. return m.EncryptionKey
  132. }
  133. return nil
  134. }
  135. func (m *WALHeader) GetHasTagCompression() bool {
  136. if m != nil && m.HasTagCompression != nil {
  137. return *m.HasTagCompression
  138. }
  139. return false
  140. }
  141. func (m *WALHeader) GetWriterClsName() string {
  142. if m != nil && m.WriterClsName != nil {
  143. return *m.WriterClsName
  144. }
  145. return ""
  146. }
  147. func (m *WALHeader) GetCellCodecClsName() string {
  148. if m != nil && m.CellCodecClsName != nil {
  149. return *m.CellCodecClsName
  150. }
  151. return ""
  152. }
  153. //
  154. // Protocol buffer version of WALKey; see WALKey comment, not really a key but WALEdit header
  155. // for some KVs
  156. type WALKey struct {
  157. EncodedRegionName []byte `protobuf:"bytes,1,req,name=encoded_region_name,json=encodedRegionName" json:"encoded_region_name,omitempty"`
  158. TableName []byte `protobuf:"bytes,2,req,name=table_name,json=tableName" json:"table_name,omitempty"`
  159. LogSequenceNumber *uint64 `protobuf:"varint,3,req,name=log_sequence_number,json=logSequenceNumber" json:"log_sequence_number,omitempty"`
  160. WriteTime *uint64 `protobuf:"varint,4,req,name=write_time,json=writeTime" json:"write_time,omitempty"`
  161. //
  162. // This parameter is deprecated in favor of clusters which
  163. // contains the list of clusters that have consumed the change.
  164. // It is retained so that the log created by earlier releases (0.94)
  165. // can be read by the newer releases.
  166. ClusterId *UUID `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
  167. Scopes []*FamilyScope `protobuf:"bytes,6,rep,name=scopes" json:"scopes,omitempty"`
  168. FollowingKvCount *uint32 `protobuf:"varint,7,opt,name=following_kv_count,json=followingKvCount" json:"following_kv_count,omitempty"`
  169. //
  170. // This field contains the list of clusters that have
  171. // consumed the change
  172. ClusterIds []*UUID `protobuf:"bytes,8,rep,name=cluster_ids,json=clusterIds" json:"cluster_ids,omitempty"`
  173. NonceGroup *uint64 `protobuf:"varint,9,opt,name=nonceGroup" json:"nonceGroup,omitempty"`
  174. Nonce *uint64 `protobuf:"varint,10,opt,name=nonce" json:"nonce,omitempty"`
  175. OrigSequenceNumber *uint64 `protobuf:"varint,11,opt,name=orig_sequence_number,json=origSequenceNumber" json:"orig_sequence_number,omitempty"`
  176. XXX_unrecognized []byte `json:"-"`
  177. }
  178. func (m *WALKey) Reset() { *m = WALKey{} }
  179. func (m *WALKey) String() string { return proto.CompactTextString(m) }
  180. func (*WALKey) ProtoMessage() {}
  181. func (*WALKey) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{1} }
  182. func (m *WALKey) GetEncodedRegionName() []byte {
  183. if m != nil {
  184. return m.EncodedRegionName
  185. }
  186. return nil
  187. }
  188. func (m *WALKey) GetTableName() []byte {
  189. if m != nil {
  190. return m.TableName
  191. }
  192. return nil
  193. }
  194. func (m *WALKey) GetLogSequenceNumber() uint64 {
  195. if m != nil && m.LogSequenceNumber != nil {
  196. return *m.LogSequenceNumber
  197. }
  198. return 0
  199. }
  200. func (m *WALKey) GetWriteTime() uint64 {
  201. if m != nil && m.WriteTime != nil {
  202. return *m.WriteTime
  203. }
  204. return 0
  205. }
  206. func (m *WALKey) GetClusterId() *UUID {
  207. if m != nil {
  208. return m.ClusterId
  209. }
  210. return nil
  211. }
  212. func (m *WALKey) GetScopes() []*FamilyScope {
  213. if m != nil {
  214. return m.Scopes
  215. }
  216. return nil
  217. }
  218. func (m *WALKey) GetFollowingKvCount() uint32 {
  219. if m != nil && m.FollowingKvCount != nil {
  220. return *m.FollowingKvCount
  221. }
  222. return 0
  223. }
  224. func (m *WALKey) GetClusterIds() []*UUID {
  225. if m != nil {
  226. return m.ClusterIds
  227. }
  228. return nil
  229. }
  230. func (m *WALKey) GetNonceGroup() uint64 {
  231. if m != nil && m.NonceGroup != nil {
  232. return *m.NonceGroup
  233. }
  234. return 0
  235. }
  236. func (m *WALKey) GetNonce() uint64 {
  237. if m != nil && m.Nonce != nil {
  238. return *m.Nonce
  239. }
  240. return 0
  241. }
  242. func (m *WALKey) GetOrigSequenceNumber() uint64 {
  243. if m != nil && m.OrigSequenceNumber != nil {
  244. return *m.OrigSequenceNumber
  245. }
  246. return 0
  247. }
  248. type FamilyScope struct {
  249. Family []byte `protobuf:"bytes,1,req,name=family" json:"family,omitempty"`
  250. ScopeType *ScopeType `protobuf:"varint,2,req,name=scope_type,json=scopeType,enum=pb.ScopeType" json:"scope_type,omitempty"`
  251. XXX_unrecognized []byte `json:"-"`
  252. }
  253. func (m *FamilyScope) Reset() { *m = FamilyScope{} }
  254. func (m *FamilyScope) String() string { return proto.CompactTextString(m) }
  255. func (*FamilyScope) ProtoMessage() {}
  256. func (*FamilyScope) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{2} }
  257. func (m *FamilyScope) GetFamily() []byte {
  258. if m != nil {
  259. return m.Family
  260. }
  261. return nil
  262. }
  263. func (m *FamilyScope) GetScopeType() ScopeType {
  264. if m != nil && m.ScopeType != nil {
  265. return *m.ScopeType
  266. }
  267. return ScopeType_REPLICATION_SCOPE_LOCAL
  268. }
  269. // *
  270. // Special WAL entry to hold all related to a compaction.
  271. // Written to WAL before completing compaction. There is
  272. // sufficient info in the below message to complete later
  273. // the * compaction should we fail the WAL write.
  274. type CompactionDescriptor struct {
  275. TableName []byte `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
  276. EncodedRegionName []byte `protobuf:"bytes,2,req,name=encoded_region_name,json=encodedRegionName" json:"encoded_region_name,omitempty"`
  277. FamilyName []byte `protobuf:"bytes,3,req,name=family_name,json=familyName" json:"family_name,omitempty"`
  278. CompactionInput []string `protobuf:"bytes,4,rep,name=compaction_input,json=compactionInput" json:"compaction_input,omitempty"`
  279. CompactionOutput []string `protobuf:"bytes,5,rep,name=compaction_output,json=compactionOutput" json:"compaction_output,omitempty"`
  280. StoreHomeDir *string `protobuf:"bytes,6,req,name=store_home_dir,json=storeHomeDir" json:"store_home_dir,omitempty"`
  281. RegionName []byte `protobuf:"bytes,7,opt,name=region_name,json=regionName" json:"region_name,omitempty"`
  282. XXX_unrecognized []byte `json:"-"`
  283. }
  284. func (m *CompactionDescriptor) Reset() { *m = CompactionDescriptor{} }
  285. func (m *CompactionDescriptor) String() string { return proto.CompactTextString(m) }
  286. func (*CompactionDescriptor) ProtoMessage() {}
  287. func (*CompactionDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{3} }
  288. func (m *CompactionDescriptor) GetTableName() []byte {
  289. if m != nil {
  290. return m.TableName
  291. }
  292. return nil
  293. }
  294. func (m *CompactionDescriptor) GetEncodedRegionName() []byte {
  295. if m != nil {
  296. return m.EncodedRegionName
  297. }
  298. return nil
  299. }
  300. func (m *CompactionDescriptor) GetFamilyName() []byte {
  301. if m != nil {
  302. return m.FamilyName
  303. }
  304. return nil
  305. }
  306. func (m *CompactionDescriptor) GetCompactionInput() []string {
  307. if m != nil {
  308. return m.CompactionInput
  309. }
  310. return nil
  311. }
  312. func (m *CompactionDescriptor) GetCompactionOutput() []string {
  313. if m != nil {
  314. return m.CompactionOutput
  315. }
  316. return nil
  317. }
  318. func (m *CompactionDescriptor) GetStoreHomeDir() string {
  319. if m != nil && m.StoreHomeDir != nil {
  320. return *m.StoreHomeDir
  321. }
  322. return ""
  323. }
  324. func (m *CompactionDescriptor) GetRegionName() []byte {
  325. if m != nil {
  326. return m.RegionName
  327. }
  328. return nil
  329. }
  330. // *
  331. // Special WAL entry to hold all related to a flush.
  332. type FlushDescriptor struct {
  333. Action *FlushDescriptor_FlushAction `protobuf:"varint,1,req,name=action,enum=pb.FlushDescriptor_FlushAction" json:"action,omitempty"`
  334. TableName []byte `protobuf:"bytes,2,req,name=table_name,json=tableName" json:"table_name,omitempty"`
  335. EncodedRegionName []byte `protobuf:"bytes,3,req,name=encoded_region_name,json=encodedRegionName" json:"encoded_region_name,omitempty"`
  336. FlushSequenceNumber *uint64 `protobuf:"varint,4,opt,name=flush_sequence_number,json=flushSequenceNumber" json:"flush_sequence_number,omitempty"`
  337. StoreFlushes []*FlushDescriptor_StoreFlushDescriptor `protobuf:"bytes,5,rep,name=store_flushes,json=storeFlushes" json:"store_flushes,omitempty"`
  338. RegionName []byte `protobuf:"bytes,6,opt,name=region_name,json=regionName" json:"region_name,omitempty"`
  339. XXX_unrecognized []byte `json:"-"`
  340. }
  341. func (m *FlushDescriptor) Reset() { *m = FlushDescriptor{} }
  342. func (m *FlushDescriptor) String() string { return proto.CompactTextString(m) }
  343. func (*FlushDescriptor) ProtoMessage() {}
  344. func (*FlushDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{4} }
  345. func (m *FlushDescriptor) GetAction() FlushDescriptor_FlushAction {
  346. if m != nil && m.Action != nil {
  347. return *m.Action
  348. }
  349. return FlushDescriptor_START_FLUSH
  350. }
  351. func (m *FlushDescriptor) GetTableName() []byte {
  352. if m != nil {
  353. return m.TableName
  354. }
  355. return nil
  356. }
  357. func (m *FlushDescriptor) GetEncodedRegionName() []byte {
  358. if m != nil {
  359. return m.EncodedRegionName
  360. }
  361. return nil
  362. }
  363. func (m *FlushDescriptor) GetFlushSequenceNumber() uint64 {
  364. if m != nil && m.FlushSequenceNumber != nil {
  365. return *m.FlushSequenceNumber
  366. }
  367. return 0
  368. }
  369. func (m *FlushDescriptor) GetStoreFlushes() []*FlushDescriptor_StoreFlushDescriptor {
  370. if m != nil {
  371. return m.StoreFlushes
  372. }
  373. return nil
  374. }
  375. func (m *FlushDescriptor) GetRegionName() []byte {
  376. if m != nil {
  377. return m.RegionName
  378. }
  379. return nil
  380. }
  381. type FlushDescriptor_StoreFlushDescriptor struct {
  382. FamilyName []byte `protobuf:"bytes,1,req,name=family_name,json=familyName" json:"family_name,omitempty"`
  383. StoreHomeDir *string `protobuf:"bytes,2,req,name=store_home_dir,json=storeHomeDir" json:"store_home_dir,omitempty"`
  384. FlushOutput []string `protobuf:"bytes,3,rep,name=flush_output,json=flushOutput" json:"flush_output,omitempty"`
  385. XXX_unrecognized []byte `json:"-"`
  386. }
  387. func (m *FlushDescriptor_StoreFlushDescriptor) Reset() { *m = FlushDescriptor_StoreFlushDescriptor{} }
  388. func (m *FlushDescriptor_StoreFlushDescriptor) String() string { return proto.CompactTextString(m) }
  389. func (*FlushDescriptor_StoreFlushDescriptor) ProtoMessage() {}
  390. func (*FlushDescriptor_StoreFlushDescriptor) Descriptor() ([]byte, []int) {
  391. return fileDescriptor18, []int{4, 0}
  392. }
  393. func (m *FlushDescriptor_StoreFlushDescriptor) GetFamilyName() []byte {
  394. if m != nil {
  395. return m.FamilyName
  396. }
  397. return nil
  398. }
  399. func (m *FlushDescriptor_StoreFlushDescriptor) GetStoreHomeDir() string {
  400. if m != nil && m.StoreHomeDir != nil {
  401. return *m.StoreHomeDir
  402. }
  403. return ""
  404. }
  405. func (m *FlushDescriptor_StoreFlushDescriptor) GetFlushOutput() []string {
  406. if m != nil {
  407. return m.FlushOutput
  408. }
  409. return nil
  410. }
  411. type StoreDescriptor struct {
  412. FamilyName []byte `protobuf:"bytes,1,req,name=family_name,json=familyName" json:"family_name,omitempty"`
  413. StoreHomeDir *string `protobuf:"bytes,2,req,name=store_home_dir,json=storeHomeDir" json:"store_home_dir,omitempty"`
  414. StoreFile []string `protobuf:"bytes,3,rep,name=store_file,json=storeFile" json:"store_file,omitempty"`
  415. StoreFileSizeBytes *uint64 `protobuf:"varint,4,opt,name=store_file_size_bytes,json=storeFileSizeBytes" json:"store_file_size_bytes,omitempty"`
  416. XXX_unrecognized []byte `json:"-"`
  417. }
  418. func (m *StoreDescriptor) Reset() { *m = StoreDescriptor{} }
  419. func (m *StoreDescriptor) String() string { return proto.CompactTextString(m) }
  420. func (*StoreDescriptor) ProtoMessage() {}
  421. func (*StoreDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{5} }
  422. func (m *StoreDescriptor) GetFamilyName() []byte {
  423. if m != nil {
  424. return m.FamilyName
  425. }
  426. return nil
  427. }
  428. func (m *StoreDescriptor) GetStoreHomeDir() string {
  429. if m != nil && m.StoreHomeDir != nil {
  430. return *m.StoreHomeDir
  431. }
  432. return ""
  433. }
  434. func (m *StoreDescriptor) GetStoreFile() []string {
  435. if m != nil {
  436. return m.StoreFile
  437. }
  438. return nil
  439. }
  440. func (m *StoreDescriptor) GetStoreFileSizeBytes() uint64 {
  441. if m != nil && m.StoreFileSizeBytes != nil {
  442. return *m.StoreFileSizeBytes
  443. }
  444. return 0
  445. }
  446. // *
  447. // Special WAL entry used for writing bulk load events to WAL
  448. type BulkLoadDescriptor struct {
  449. TableName *TableName `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
  450. EncodedRegionName []byte `protobuf:"bytes,2,req,name=encoded_region_name,json=encodedRegionName" json:"encoded_region_name,omitempty"`
  451. Stores []*StoreDescriptor `protobuf:"bytes,3,rep,name=stores" json:"stores,omitempty"`
  452. BulkloadSeqNum *int64 `protobuf:"varint,4,req,name=bulkload_seq_num,json=bulkloadSeqNum" json:"bulkload_seq_num,omitempty"`
  453. XXX_unrecognized []byte `json:"-"`
  454. }
  455. func (m *BulkLoadDescriptor) Reset() { *m = BulkLoadDescriptor{} }
  456. func (m *BulkLoadDescriptor) String() string { return proto.CompactTextString(m) }
  457. func (*BulkLoadDescriptor) ProtoMessage() {}
  458. func (*BulkLoadDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{6} }
  459. func (m *BulkLoadDescriptor) GetTableName() *TableName {
  460. if m != nil {
  461. return m.TableName
  462. }
  463. return nil
  464. }
  465. func (m *BulkLoadDescriptor) GetEncodedRegionName() []byte {
  466. if m != nil {
  467. return m.EncodedRegionName
  468. }
  469. return nil
  470. }
  471. func (m *BulkLoadDescriptor) GetStores() []*StoreDescriptor {
  472. if m != nil {
  473. return m.Stores
  474. }
  475. return nil
  476. }
  477. func (m *BulkLoadDescriptor) GetBulkloadSeqNum() int64 {
  478. if m != nil && m.BulkloadSeqNum != nil {
  479. return *m.BulkloadSeqNum
  480. }
  481. return 0
  482. }
  483. // *
  484. // Special WAL entry to hold all related to a region event (open/close).
  485. type RegionEventDescriptor struct {
  486. EventType *RegionEventDescriptor_EventType `protobuf:"varint,1,req,name=event_type,json=eventType,enum=pb.RegionEventDescriptor_EventType" json:"event_type,omitempty"`
  487. TableName []byte `protobuf:"bytes,2,req,name=table_name,json=tableName" json:"table_name,omitempty"`
  488. EncodedRegionName []byte `protobuf:"bytes,3,req,name=encoded_region_name,json=encodedRegionName" json:"encoded_region_name,omitempty"`
  489. LogSequenceNumber *uint64 `protobuf:"varint,4,opt,name=log_sequence_number,json=logSequenceNumber" json:"log_sequence_number,omitempty"`
  490. Stores []*StoreDescriptor `protobuf:"bytes,5,rep,name=stores" json:"stores,omitempty"`
  491. Server *ServerName `protobuf:"bytes,6,opt,name=server" json:"server,omitempty"`
  492. RegionName []byte `protobuf:"bytes,7,opt,name=region_name,json=regionName" json:"region_name,omitempty"`
  493. XXX_unrecognized []byte `json:"-"`
  494. }
  495. func (m *RegionEventDescriptor) Reset() { *m = RegionEventDescriptor{} }
  496. func (m *RegionEventDescriptor) String() string { return proto.CompactTextString(m) }
  497. func (*RegionEventDescriptor) ProtoMessage() {}
  498. func (*RegionEventDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{7} }
  499. func (m *RegionEventDescriptor) GetEventType() RegionEventDescriptor_EventType {
  500. if m != nil && m.EventType != nil {
  501. return *m.EventType
  502. }
  503. return RegionEventDescriptor_REGION_OPEN
  504. }
  505. func (m *RegionEventDescriptor) GetTableName() []byte {
  506. if m != nil {
  507. return m.TableName
  508. }
  509. return nil
  510. }
  511. func (m *RegionEventDescriptor) GetEncodedRegionName() []byte {
  512. if m != nil {
  513. return m.EncodedRegionName
  514. }
  515. return nil
  516. }
  517. func (m *RegionEventDescriptor) GetLogSequenceNumber() uint64 {
  518. if m != nil && m.LogSequenceNumber != nil {
  519. return *m.LogSequenceNumber
  520. }
  521. return 0
  522. }
  523. func (m *RegionEventDescriptor) GetStores() []*StoreDescriptor {
  524. if m != nil {
  525. return m.Stores
  526. }
  527. return nil
  528. }
  529. func (m *RegionEventDescriptor) GetServer() *ServerName {
  530. if m != nil {
  531. return m.Server
  532. }
  533. return nil
  534. }
  535. func (m *RegionEventDescriptor) GetRegionName() []byte {
  536. if m != nil {
  537. return m.RegionName
  538. }
  539. return nil
  540. }
  541. // *
  542. // A trailer that is appended to the end of a properly closed WAL file.
  543. // If missing, this is either a legacy or a corrupted WAL file.
  544. // N.B. This trailer currently doesn't contain any information and we
  545. // purposefully don't expose it in the WAL APIs. It's for future growth.
  546. type WALTrailer struct {
  547. XXX_unrecognized []byte `json:"-"`
  548. }
  549. func (m *WALTrailer) Reset() { *m = WALTrailer{} }
  550. func (m *WALTrailer) String() string { return proto.CompactTextString(m) }
  551. func (*WALTrailer) ProtoMessage() {}
  552. func (*WALTrailer) Descriptor() ([]byte, []int) { return fileDescriptor18, []int{8} }
  553. func init() {
  554. proto.RegisterType((*WALHeader)(nil), "pb.WALHeader")
  555. proto.RegisterType((*WALKey)(nil), "pb.WALKey")
  556. proto.RegisterType((*FamilyScope)(nil), "pb.FamilyScope")
  557. proto.RegisterType((*CompactionDescriptor)(nil), "pb.CompactionDescriptor")
  558. proto.RegisterType((*FlushDescriptor)(nil), "pb.FlushDescriptor")
  559. proto.RegisterType((*FlushDescriptor_StoreFlushDescriptor)(nil), "pb.FlushDescriptor.StoreFlushDescriptor")
  560. proto.RegisterType((*StoreDescriptor)(nil), "pb.StoreDescriptor")
  561. proto.RegisterType((*BulkLoadDescriptor)(nil), "pb.BulkLoadDescriptor")
  562. proto.RegisterType((*RegionEventDescriptor)(nil), "pb.RegionEventDescriptor")
  563. proto.RegisterType((*WALTrailer)(nil), "pb.WALTrailer")
  564. proto.RegisterEnum("pb.ScopeType", ScopeType_name, ScopeType_value)
  565. proto.RegisterEnum("pb.FlushDescriptor_FlushAction", FlushDescriptor_FlushAction_name, FlushDescriptor_FlushAction_value)
  566. proto.RegisterEnum("pb.RegionEventDescriptor_EventType", RegionEventDescriptor_EventType_name, RegionEventDescriptor_EventType_value)
  567. }
  568. func init() { proto.RegisterFile("WAL.proto", fileDescriptor18) }
  569. var fileDescriptor18 = []byte{
  570. // 1104 bytes of a gzipped FileDescriptorProto
  571. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xdf, 0x72, 0xda, 0xc6,
  572. 0x17, 0x8e, 0x00, 0x93, 0xe8, 0x08, 0x03, 0x5e, 0xdb, 0xbf, 0x9f, 0xc6, 0x6d, 0x1a, 0x4a, 0xdb,
  573. 0x44, 0x89, 0x5d, 0xa6, 0xe5, 0xa6, 0x97, 0x1d, 0xc0, 0xd8, 0x66, 0x22, 0x83, 0x47, 0xe0, 0xf1,
  574. 0xa5, 0x46, 0x88, 0x35, 0x68, 0x2c, 0xb4, 0x8a, 0x56, 0x72, 0x86, 0x5c, 0xe5, 0xb2, 0x2f, 0xd0,
  575. 0xfb, 0xde, 0xf4, 0xa6, 0xef, 0xd0, 0x07, 0xe8, 0x6b, 0xf4, 0x49, 0x3a, 0x7b, 0x56, 0xfc, 0x31,
  576. 0xe0, 0x49, 0x67, 0x9a, 0x3b, 0xf6, 0xfb, 0xbe, 0xdd, 0x3d, 0xe7, 0x3b, 0xe7, 0xac, 0x00, 0xf5,
  577. 0xa6, 0x61, 0xd6, 0xc2, 0x88, 0xc5, 0x8c, 0x64, 0xc2, 0xe1, 0x91, 0x76, 0xd1, 0x74, 0x38, 0x95,
  578. 0xc0, 0x51, 0xa1, 0xe5, 0x7b, 0x34, 0x88, 0xe5, 0xaa, 0xfa, 0xb7, 0x82, 0xe2, 0x0b, 0xea, 0x8c,
  579. 0x68, 0x44, 0x5e, 0x41, 0x69, 0xe2, 0x70, 0xdb, 0x65, 0xd3, 0x30, 0xa2, 0x9c, 0x7b, 0x2c, 0xd0,
  580. 0x95, 0x8a, 0x62, 0x3c, 0xb3, 0x8a, 0x13, 0x87, 0xb7, 0x96, 0x28, 0xf9, 0x0e, 0x8a, 0x34, 0x70,
  581. 0xa3, 0x59, 0x18, 0x7b, 0x2c, 0xb0, 0xef, 0xe8, 0x4c, 0xcf, 0x54, 0x14, 0xa3, 0x60, 0xed, 0x2e,
  582. 0xd1, 0xb7, 0x74, 0x46, 0x6a, 0xb0, 0x2f, 0xce, 0x8b, 0x9d, 0xf1, 0x83, 0x33, 0xb3, 0x78, 0xe6,
  583. 0xde, 0xc4, 0xe1, 0x03, 0x67, 0xbc, 0x7a, 0xec, 0x4b, 0x28, 0xbd, 0x8f, 0xbc, 0x98, 0x46, 0xb6,
  584. 0xeb, 0x73, 0x3b, 0x70, 0xa6, 0x54, 0xcf, 0x55, 0x14, 0x43, 0xb5, 0x76, 0x25, 0xdc, 0xf2, 0x79,
  585. 0xd7, 0x99, 0x52, 0xf2, 0x3d, 0xec, 0xbb, 0xd4, 0xf7, 0x6d, 0x97, 0x8d, 0xa8, 0xbb, 0xd4, 0xee,
  586. 0xa0, 0xb6, 0x2c, 0xa8, 0x96, 0x60, 0x52, 0x79, 0xf5, 0xcf, 0x2c, 0xe4, 0x6f, 0x1a, 0x66, 0x1a,
  587. 0x11, 0x0d, 0xc4, 0xb6, 0x91, 0x1d, 0xd1, 0xb1, 0x08, 0x1e, 0x77, 0x2a, 0x95, 0x8c, 0x51, 0xb0,
  588. 0xf6, 0x52, 0xca, 0x42, 0x06, 0x6f, 0x7a, 0x0e, 0x10, 0x3b, 0x43, 0x9f, 0x4a, 0x59, 0x06, 0x65,
  589. 0x2a, 0x22, 0x48, 0xd7, 0x60, 0xdf, 0x67, 0x63, 0x9b, 0xd3, 0x77, 0x09, 0x0d, 0x5c, 0x6a, 0x07,
  590. 0xc9, 0x74, 0x48, 0x23, 0x3d, 0x5b, 0xc9, 0x18, 0x39, 0x6b, 0xcf, 0x67, 0xe3, 0x7e, 0xca, 0x74,
  591. 0x91, 0x10, 0xc7, 0x61, 0x26, 0x76, 0xec, 0x61, 0x6e, 0x42, 0xa6, 0x22, 0x32, 0xf0, 0xa6, 0x94,
  592. 0x1c, 0x03, 0xb8, 0x7e, 0xc2, 0x85, 0x01, 0xde, 0x08, 0xd3, 0xd1, 0xea, 0xcf, 0x6a, 0xe1, 0xb0,
  593. 0x76, 0x7d, 0xdd, 0x39, 0x6d, 0x66, 0x74, 0xc5, 0x52, 0x53, 0xbe, 0x33, 0x22, 0xaf, 0x20, 0xcf,
  594. 0x5d, 0x16, 0x52, 0xae, 0xe7, 0x2b, 0x59, 0x43, 0xab, 0x97, 0x84, 0xf0, 0xcc, 0x99, 0x7a, 0xfe,
  595. 0xac, 0x2f, 0x70, 0x2b, 0xa5, 0xc9, 0x09, 0x90, 0x5b, 0xe6, 0xfb, 0xec, 0xbd, 0x17, 0x8c, 0xed,
  596. 0xbb, 0x7b, 0xdb, 0x65, 0x49, 0x10, 0xeb, 0x4f, 0x2b, 0x8a, 0xb1, 0x6b, 0x95, 0x17, 0xcc, 0xdb,
  597. 0xfb, 0x96, 0xc0, 0xc9, 0x6b, 0xd0, 0x96, 0x31, 0x70, 0xfd, 0x19, 0x9e, 0xbd, 0x08, 0xc2, 0x82,
  598. 0x45, 0x00, 0x9c, 0x7c, 0x05, 0x10, 0xb0, 0xc0, 0xa5, 0xe7, 0x11, 0x4b, 0x42, 0x5d, 0xad, 0x28,
  599. 0x46, 0xce, 0x5a, 0x41, 0xc8, 0x01, 0xec, 0xe0, 0x4a, 0x07, 0xa4, 0xe4, 0x82, 0xfc, 0x00, 0x07,
  600. 0x2c, 0xf2, 0x36, 0x4d, 0xd3, 0x50, 0x44, 0x04, 0xf7, 0xd0, 0xb5, 0x6a, 0x1f, 0xb4, 0x95, 0xbc,
  601. 0xc8, 0xff, 0x20, 0x7f, 0x8b, 0xcb, 0xb4, 0x6c, 0xe9, 0x8a, 0x9c, 0x00, 0x60, 0xc6, 0x76, 0x3c,
  602. 0x0b, 0x65, 0xad, 0x8a, 0xf5, 0x5d, 0x11, 0x38, 0x6e, 0x1b, 0xcc, 0x42, 0x6a, 0xa9, 0x7c, 0xfe,
  603. 0xb3, 0xfa, 0x7b, 0x06, 0x0e, 0x44, 0xef, 0x39, 0xae, 0xe8, 0xd6, 0x53, 0xca, 0xdd, 0xc8, 0x0b,
  604. 0x63, 0x16, 0xad, 0x95, 0x5c, 0xd9, 0x52, 0xf2, 0x6d, 0x1d, 0x94, 0x79, 0xac, 0x83, 0x5e, 0x80,
  605. 0x26, 0xe3, 0x93, 0xba, 0x2c, 0xea, 0x40, 0x42, 0x28, 0x78, 0x0d, 0x65, 0x77, 0x11, 0x87, 0xed,
  606. 0x05, 0x61, 0x12, 0xeb, 0xb9, 0x4a, 0xd6, 0x50, 0xad, 0xd2, 0x12, 0xef, 0x08, 0x98, 0x1c, 0xc3,
  607. 0xde, 0x8a, 0x94, 0x25, 0xb1, 0xd0, 0xee, 0xa0, 0x76, 0xe5, 0x8c, 0x1e, 0xe2, 0xe4, 0x5b, 0x28,
  608. 0xf2, 0x98, 0x45, 0xd4, 0x9e, 0xb0, 0x29, 0xb5, 0x47, 0x5e, 0xa4, 0xe7, 0x2b, 0x19, 0x43, 0xb5,
  609. 0x0a, 0x88, 0x5e, 0xb0, 0x29, 0x3d, 0xf5, 0x22, 0x11, 0xde, 0x6a, 0x1a, 0x4f, 0x71, 0x8c, 0x21,
  610. 0x5a, 0xc4, 0x5f, 0xfd, 0x35, 0x07, 0xa5, 0x33, 0x3f, 0xe1, 0x93, 0x15, 0x8b, 0x7e, 0x82, 0xbc,
  611. 0xbc, 0x0a, 0xed, 0x29, 0xd6, 0x5f, 0x60, 0xeb, 0x3d, 0x14, 0xc9, 0x75, 0x03, 0x65, 0x56, 0x2a,
  612. 0xff, 0x17, 0xe3, 0xb4, 0xcd, 0xdb, 0xec, 0x63, 0xde, 0xd6, 0xe1, 0xf0, 0x56, 0xdc, 0xb2, 0xd1,
  613. 0x4b, 0x39, 0xec, 0xa5, 0x7d, 0x24, 0xd7, 0x46, 0xf0, 0x12, 0x76, 0xa5, 0x2d, 0x48, 0x52, 0x8e,
  614. 0xfe, 0x69, 0x75, 0x63, 0x5b, 0x0a, 0x7d, 0x21, 0x5c, 0x03, 0x53, 0xff, 0xce, 0xe4, 0xee, 0x75,
  615. 0xff, 0xf2, 0xeb, 0xfe, 0x1d, 0x7d, 0x54, 0xe0, 0x60, 0xdb, 0x39, 0xeb, 0x8d, 0xa1, 0x6c, 0x34,
  616. 0xc6, 0x66, 0x01, 0x33, 0x5b, 0x0a, 0xf8, 0x35, 0x14, 0xa4, 0x07, 0x69, 0x3b, 0x64, 0xb1, 0x1d,
  617. 0x34, 0xc4, 0x64, 0x27, 0xe0, 0xfc, 0x2c, 0x8b, 0x41, 0x4a, 0xa0, 0xf5, 0x07, 0x0d, 0x6b, 0x60,
  618. 0x9f, 0x99, 0xd7, 0xfd, 0x8b, 0xf2, 0x13, 0x52, 0x86, 0x42, 0xab, 0x77, 0x79, 0xd9, 0x99, 0x23,
  619. 0x8a, 0x90, 0x34, 0x9a, 0xbd, 0x85, 0x24, 0x83, 0x92, 0x46, 0xb7, 0xdb, 0x9b, 0x23, 0xd9, 0xea,
  620. 0x1f, 0x0a, 0x94, 0x30, 0xaf, 0xcf, 0x9f, 0xd2, 0x73, 0x80, 0xb4, 0x44, 0x9e, 0x4f, 0xd3, 0x84,
  621. 0x54, 0xe9, 0xba, 0xe7, 0x53, 0xf2, 0x23, 0x1c, 0x2e, 0x69, 0x9b, 0x7b, 0x1f, 0xa8, 0x3d, 0x9c,
  622. 0xc5, 0x94, 0xa7, 0x55, 0x27, 0x0b, 0x65, 0xdf, 0xfb, 0x40, 0x9b, 0x82, 0xa9, 0xfe, 0xa5, 0x00,
  623. 0x69, 0x26, 0xfe, 0x9d, 0xc9, 0x9c, 0xd1, 0x4a, 0xbc, 0x27, 0x1b, 0xa3, 0xae, 0xc9, 0x17, 0x63,
  624. 0x30, 0x6f, 0xc9, 0xff, 0x32, 0xf9, 0xc7, 0x90, 0xc7, 0x50, 0x38, 0xa6, 0xa0, 0xd5, 0xf7, 0xf1,
  625. 0x2d, 0x7a, 0x68, 0x99, 0x95, 0x4a, 0x88, 0x01, 0xe5, 0x61, 0xe2, 0xdf, 0xf9, 0xcc, 0x19, 0x89,
  626. 0x6e, 0x16, 0x8d, 0x8c, 0xdf, 0x87, 0xac, 0x55, 0x9c, 0xe3, 0x7d, 0xfa, 0xae, 0x9b, 0x4c, 0xab,
  627. 0x1f, 0xb3, 0x70, 0x28, 0x6f, 0x69, 0xdf, 0xd3, 0x20, 0x5e, 0x49, 0xa7, 0x09, 0x40, 0x05, 0x24,
  628. 0x1f, 0x40, 0x39, 0x9a, 0xdf, 0x88, 0x4b, 0xb7, 0xca, 0x6b, 0xb8, 0x96, 0xcf, 0x22, 0x9d, 0xff,
  629. 0xfc, 0xdc, 0x13, 0xfa, 0xc8, 0x07, 0x52, 0x56, 0x6a, 0xcb, 0x07, 0x72, 0xe9, 0xd9, 0xce, 0xa7,
  630. 0x3d, 0x7b, 0x09, 0x79, 0x4e, 0xa3, 0x7b, 0x1a, 0xe1, 0xd8, 0x69, 0xf5, 0x22, 0x8a, 0x11, 0xc1,
  631. 0xda, 0xa5, 0xec, 0xa7, 0xdf, 0xb8, 0x1a, 0xa8, 0x0b, 0x33, 0x44, 0xef, 0x5b, 0xed, 0xf3, 0x4e,
  632. 0xaf, 0x6b, 0xf7, 0xae, 0xda, 0x5d, 0x39, 0x1e, 0x29, 0xd0, 0x32, 0x7b, 0xfd, 0x76, 0x59, 0xa9,
  633. 0x16, 0x00, 0x6e, 0x1a, 0xe6, 0x20, 0x72, 0x3c, 0x9f, 0x46, 0x6f, 0xce, 0x40, 0x5d, 0x7c, 0x61,
  634. 0xc8, 0x17, 0xf0, 0x7f, 0xab, 0x7d, 0x65, 0x76, 0x5a, 0x8d, 0x81, 0xd8, 0xd1, 0x6f, 0xf5, 0xae,
  635. 0xda, 0xb6, 0xd9, 0x6b, 0x35, 0xcc, 0xf2, 0x13, 0xf2, 0x25, 0xe8, 0x9b, 0xe4, 0xb9, 0xd9, 0x6b,
  636. 0x36, 0xcc, 0xb2, 0xd2, 0xfc, 0x19, 0xde, 0xb0, 0x68, 0x5c, 0x73, 0x42, 0xc7, 0x9d, 0xd0, 0xda,
  637. 0xc4, 0x19, 0x31, 0x16, 0xd6, 0x26, 0xc3, 0xc5, 0x5f, 0xb7, 0x61, 0x72, 0x5b, 0x1b, 0xd3, 0x80,
  638. 0x46, 0x4e, 0x4c, 0x47, 0x4d, 0xf1, 0xb7, 0xed, 0x4a, 0xc0, 0xfc, 0x42, 0xf9, 0x45, 0x79, 0xf2,
  639. 0x9b, 0xa2, 0xfc, 0x13, 0x00, 0x00, 0xff, 0xff, 0xed, 0x1e, 0xb6, 0x57, 0xf7, 0x09, 0x00, 0x00,
  640. }