ZooKeeper.pb.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: ZooKeeper.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 SplitLogTask_State int32
  12. const (
  13. SplitLogTask_UNASSIGNED SplitLogTask_State = 0
  14. SplitLogTask_OWNED SplitLogTask_State = 1
  15. SplitLogTask_RESIGNED SplitLogTask_State = 2
  16. SplitLogTask_DONE SplitLogTask_State = 3
  17. SplitLogTask_ERR SplitLogTask_State = 4
  18. )
  19. var SplitLogTask_State_name = map[int32]string{
  20. 0: "UNASSIGNED",
  21. 1: "OWNED",
  22. 2: "RESIGNED",
  23. 3: "DONE",
  24. 4: "ERR",
  25. }
  26. var SplitLogTask_State_value = map[string]int32{
  27. "UNASSIGNED": 0,
  28. "OWNED": 1,
  29. "RESIGNED": 2,
  30. "DONE": 3,
  31. "ERR": 4,
  32. }
  33. func (x SplitLogTask_State) Enum() *SplitLogTask_State {
  34. p := new(SplitLogTask_State)
  35. *p = x
  36. return p
  37. }
  38. func (x SplitLogTask_State) String() string {
  39. return proto.EnumName(SplitLogTask_State_name, int32(x))
  40. }
  41. func (x *SplitLogTask_State) UnmarshalJSON(data []byte) error {
  42. value, err := proto.UnmarshalJSONEnum(SplitLogTask_State_value, data, "SplitLogTask_State")
  43. if err != nil {
  44. return err
  45. }
  46. *x = SplitLogTask_State(value)
  47. return nil
  48. }
  49. func (SplitLogTask_State) EnumDescriptor() ([]byte, []int) { return fileDescriptor19, []int{4, 0} }
  50. type SplitLogTask_RecoveryMode int32
  51. const (
  52. SplitLogTask_UNKNOWN SplitLogTask_RecoveryMode = 0
  53. SplitLogTask_LOG_SPLITTING SplitLogTask_RecoveryMode = 1
  54. SplitLogTask_LOG_REPLAY SplitLogTask_RecoveryMode = 2
  55. )
  56. var SplitLogTask_RecoveryMode_name = map[int32]string{
  57. 0: "UNKNOWN",
  58. 1: "LOG_SPLITTING",
  59. 2: "LOG_REPLAY",
  60. }
  61. var SplitLogTask_RecoveryMode_value = map[string]int32{
  62. "UNKNOWN": 0,
  63. "LOG_SPLITTING": 1,
  64. "LOG_REPLAY": 2,
  65. }
  66. func (x SplitLogTask_RecoveryMode) Enum() *SplitLogTask_RecoveryMode {
  67. p := new(SplitLogTask_RecoveryMode)
  68. *p = x
  69. return p
  70. }
  71. func (x SplitLogTask_RecoveryMode) String() string {
  72. return proto.EnumName(SplitLogTask_RecoveryMode_name, int32(x))
  73. }
  74. func (x *SplitLogTask_RecoveryMode) UnmarshalJSON(data []byte) error {
  75. value, err := proto.UnmarshalJSONEnum(SplitLogTask_RecoveryMode_value, data, "SplitLogTask_RecoveryMode")
  76. if err != nil {
  77. return err
  78. }
  79. *x = SplitLogTask_RecoveryMode(value)
  80. return nil
  81. }
  82. func (SplitLogTask_RecoveryMode) EnumDescriptor() ([]byte, []int) {
  83. return fileDescriptor19, []int{4, 1}
  84. }
  85. // Table's current state
  86. type Table_State int32
  87. const (
  88. Table_ENABLED Table_State = 0
  89. Table_DISABLED Table_State = 1
  90. Table_DISABLING Table_State = 2
  91. Table_ENABLING Table_State = 3
  92. )
  93. var Table_State_name = map[int32]string{
  94. 0: "ENABLED",
  95. 1: "DISABLED",
  96. 2: "DISABLING",
  97. 3: "ENABLING",
  98. }
  99. var Table_State_value = map[string]int32{
  100. "ENABLED": 0,
  101. "DISABLED": 1,
  102. "DISABLING": 2,
  103. "ENABLING": 3,
  104. }
  105. func (x Table_State) Enum() *Table_State {
  106. p := new(Table_State)
  107. *p = x
  108. return p
  109. }
  110. func (x Table_State) String() string {
  111. return proto.EnumName(Table_State_name, int32(x))
  112. }
  113. func (x *Table_State) UnmarshalJSON(data []byte) error {
  114. value, err := proto.UnmarshalJSONEnum(Table_State_value, data, "Table_State")
  115. if err != nil {
  116. return err
  117. }
  118. *x = Table_State(value)
  119. return nil
  120. }
  121. func (Table_State) EnumDescriptor() ([]byte, []int) { return fileDescriptor19, []int{5, 0} }
  122. type ReplicationState_State int32
  123. const (
  124. ReplicationState_ENABLED ReplicationState_State = 0
  125. ReplicationState_DISABLED ReplicationState_State = 1
  126. )
  127. var ReplicationState_State_name = map[int32]string{
  128. 0: "ENABLED",
  129. 1: "DISABLED",
  130. }
  131. var ReplicationState_State_value = map[string]int32{
  132. "ENABLED": 0,
  133. "DISABLED": 1,
  134. }
  135. func (x ReplicationState_State) Enum() *ReplicationState_State {
  136. p := new(ReplicationState_State)
  137. *p = x
  138. return p
  139. }
  140. func (x ReplicationState_State) String() string {
  141. return proto.EnumName(ReplicationState_State_name, int32(x))
  142. }
  143. func (x *ReplicationState_State) UnmarshalJSON(data []byte) error {
  144. value, err := proto.UnmarshalJSONEnum(ReplicationState_State_value, data, "ReplicationState_State")
  145. if err != nil {
  146. return err
  147. }
  148. *x = ReplicationState_State(value)
  149. return nil
  150. }
  151. func (ReplicationState_State) EnumDescriptor() ([]byte, []int) { return fileDescriptor19, []int{7, 0} }
  152. // *
  153. // Content of the meta-region-server znode.
  154. type MetaRegionServer struct {
  155. // The ServerName hosting the meta region currently, or destination server,
  156. // if meta region is in transition.
  157. Server *ServerName `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
  158. // The major version of the rpc the server speaks. This is used so that
  159. // clients connecting to the cluster can have prior knowledge of what version
  160. // to send to a RegionServer. AsyncHBase will use this to detect versions.
  161. RpcVersion *uint32 `protobuf:"varint,2,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"`
  162. // State of the region transition. OPEN means fully operational 'hbase:meta'
  163. State *RegionState_State `protobuf:"varint,3,opt,name=state,enum=pb.RegionState_State" json:"state,omitempty"`
  164. XXX_unrecognized []byte `json:"-"`
  165. }
  166. func (m *MetaRegionServer) Reset() { *m = MetaRegionServer{} }
  167. func (m *MetaRegionServer) String() string { return proto.CompactTextString(m) }
  168. func (*MetaRegionServer) ProtoMessage() {}
  169. func (*MetaRegionServer) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{0} }
  170. func (m *MetaRegionServer) GetServer() *ServerName {
  171. if m != nil {
  172. return m.Server
  173. }
  174. return nil
  175. }
  176. func (m *MetaRegionServer) GetRpcVersion() uint32 {
  177. if m != nil && m.RpcVersion != nil {
  178. return *m.RpcVersion
  179. }
  180. return 0
  181. }
  182. func (m *MetaRegionServer) GetState() RegionState_State {
  183. if m != nil && m.State != nil {
  184. return *m.State
  185. }
  186. return RegionState_OFFLINE
  187. }
  188. // *
  189. // Content of the master znode.
  190. type Master struct {
  191. // The ServerName of the current Master
  192. Master *ServerName `protobuf:"bytes,1,req,name=master" json:"master,omitempty"`
  193. // Major RPC version so that clients can know what version the master can accept.
  194. RpcVersion *uint32 `protobuf:"varint,2,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"`
  195. InfoPort *uint32 `protobuf:"varint,3,opt,name=info_port,json=infoPort" json:"info_port,omitempty"`
  196. XXX_unrecognized []byte `json:"-"`
  197. }
  198. func (m *Master) Reset() { *m = Master{} }
  199. func (m *Master) String() string { return proto.CompactTextString(m) }
  200. func (*Master) ProtoMessage() {}
  201. func (*Master) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{1} }
  202. func (m *Master) GetMaster() *ServerName {
  203. if m != nil {
  204. return m.Master
  205. }
  206. return nil
  207. }
  208. func (m *Master) GetRpcVersion() uint32 {
  209. if m != nil && m.RpcVersion != nil {
  210. return *m.RpcVersion
  211. }
  212. return 0
  213. }
  214. func (m *Master) GetInfoPort() uint32 {
  215. if m != nil && m.InfoPort != nil {
  216. return *m.InfoPort
  217. }
  218. return 0
  219. }
  220. // *
  221. // Content of the '/hbase/running', cluster state, znode.
  222. type ClusterUp struct {
  223. // If this znode is present, cluster is up. Currently
  224. // the data is cluster start_date.
  225. StartDate *string `protobuf:"bytes,1,req,name=start_date,json=startDate" json:"start_date,omitempty"`
  226. XXX_unrecognized []byte `json:"-"`
  227. }
  228. func (m *ClusterUp) Reset() { *m = ClusterUp{} }
  229. func (m *ClusterUp) String() string { return proto.CompactTextString(m) }
  230. func (*ClusterUp) ProtoMessage() {}
  231. func (*ClusterUp) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{2} }
  232. func (m *ClusterUp) GetStartDate() string {
  233. if m != nil && m.StartDate != nil {
  234. return *m.StartDate
  235. }
  236. return ""
  237. }
  238. // *
  239. // What we write under unassigned up in zookeeper as a region moves through
  240. // open/close, etc., regions. Details a region in transition.
  241. type RegionTransition struct {
  242. // Code for EventType gotten by doing o.a.h.h.EventHandler.EventType.getCode()
  243. EventTypeCode *uint32 `protobuf:"varint,1,req,name=event_type_code,json=eventTypeCode" json:"event_type_code,omitempty"`
  244. // Full regionname in bytes
  245. RegionName []byte `protobuf:"bytes,2,req,name=region_name,json=regionName" json:"region_name,omitempty"`
  246. CreateTime *uint64 `protobuf:"varint,3,req,name=create_time,json=createTime" json:"create_time,omitempty"`
  247. // The region server where the transition will happen or is happening
  248. ServerName *ServerName `protobuf:"bytes,4,req,name=server_name,json=serverName" json:"server_name,omitempty"`
  249. Payload []byte `protobuf:"bytes,5,opt,name=payload" json:"payload,omitempty"`
  250. XXX_unrecognized []byte `json:"-"`
  251. }
  252. func (m *RegionTransition) Reset() { *m = RegionTransition{} }
  253. func (m *RegionTransition) String() string { return proto.CompactTextString(m) }
  254. func (*RegionTransition) ProtoMessage() {}
  255. func (*RegionTransition) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{3} }
  256. func (m *RegionTransition) GetEventTypeCode() uint32 {
  257. if m != nil && m.EventTypeCode != nil {
  258. return *m.EventTypeCode
  259. }
  260. return 0
  261. }
  262. func (m *RegionTransition) GetRegionName() []byte {
  263. if m != nil {
  264. return m.RegionName
  265. }
  266. return nil
  267. }
  268. func (m *RegionTransition) GetCreateTime() uint64 {
  269. if m != nil && m.CreateTime != nil {
  270. return *m.CreateTime
  271. }
  272. return 0
  273. }
  274. func (m *RegionTransition) GetServerName() *ServerName {
  275. if m != nil {
  276. return m.ServerName
  277. }
  278. return nil
  279. }
  280. func (m *RegionTransition) GetPayload() []byte {
  281. if m != nil {
  282. return m.Payload
  283. }
  284. return nil
  285. }
  286. // *
  287. // WAL SplitLog directory znodes have this for content. Used doing distributed
  288. // WAL splitting. Holds current state and name of server that originated split.
  289. type SplitLogTask struct {
  290. State *SplitLogTask_State `protobuf:"varint,1,req,name=state,enum=pb.SplitLogTask_State" json:"state,omitempty"`
  291. ServerName *ServerName `protobuf:"bytes,2,req,name=server_name,json=serverName" json:"server_name,omitempty"`
  292. Mode *SplitLogTask_RecoveryMode `protobuf:"varint,3,opt,name=mode,enum=pb.SplitLogTask_RecoveryMode,def=0" json:"mode,omitempty"`
  293. XXX_unrecognized []byte `json:"-"`
  294. }
  295. func (m *SplitLogTask) Reset() { *m = SplitLogTask{} }
  296. func (m *SplitLogTask) String() string { return proto.CompactTextString(m) }
  297. func (*SplitLogTask) ProtoMessage() {}
  298. func (*SplitLogTask) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{4} }
  299. const Default_SplitLogTask_Mode SplitLogTask_RecoveryMode = SplitLogTask_UNKNOWN
  300. func (m *SplitLogTask) GetState() SplitLogTask_State {
  301. if m != nil && m.State != nil {
  302. return *m.State
  303. }
  304. return SplitLogTask_UNASSIGNED
  305. }
  306. func (m *SplitLogTask) GetServerName() *ServerName {
  307. if m != nil {
  308. return m.ServerName
  309. }
  310. return nil
  311. }
  312. func (m *SplitLogTask) GetMode() SplitLogTask_RecoveryMode {
  313. if m != nil && m.Mode != nil {
  314. return *m.Mode
  315. }
  316. return Default_SplitLogTask_Mode
  317. }
  318. // *
  319. // The znode that holds state of table.
  320. type Table struct {
  321. // This is the table's state. If no znode for a table,
  322. // its state is presumed enabled. See o.a.h.h.zookeeper.ZKTable class
  323. // for more.
  324. State *Table_State `protobuf:"varint,1,req,name=state,enum=pb.Table_State,def=0" json:"state,omitempty"`
  325. XXX_unrecognized []byte `json:"-"`
  326. }
  327. func (m *Table) Reset() { *m = Table{} }
  328. func (m *Table) String() string { return proto.CompactTextString(m) }
  329. func (*Table) ProtoMessage() {}
  330. func (*Table) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{5} }
  331. const Default_Table_State Table_State = Table_ENABLED
  332. func (m *Table) GetState() Table_State {
  333. if m != nil && m.State != nil {
  334. return *m.State
  335. }
  336. return Default_Table_State
  337. }
  338. // *
  339. // Used by replication. Holds a replication peer key.
  340. type ReplicationPeer struct {
  341. // clusterkey is the concatenation of the slave cluster's
  342. // hbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent
  343. Clusterkey *string `protobuf:"bytes,1,req,name=clusterkey" json:"clusterkey,omitempty"`
  344. ReplicationEndpointImpl *string `protobuf:"bytes,2,opt,name=replicationEndpointImpl" json:"replicationEndpointImpl,omitempty"`
  345. Data []*BytesBytesPair `protobuf:"bytes,3,rep,name=data" json:"data,omitempty"`
  346. Configuration []*NameStringPair `protobuf:"bytes,4,rep,name=configuration" json:"configuration,omitempty"`
  347. XXX_unrecognized []byte `json:"-"`
  348. }
  349. func (m *ReplicationPeer) Reset() { *m = ReplicationPeer{} }
  350. func (m *ReplicationPeer) String() string { return proto.CompactTextString(m) }
  351. func (*ReplicationPeer) ProtoMessage() {}
  352. func (*ReplicationPeer) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{6} }
  353. func (m *ReplicationPeer) GetClusterkey() string {
  354. if m != nil && m.Clusterkey != nil {
  355. return *m.Clusterkey
  356. }
  357. return ""
  358. }
  359. func (m *ReplicationPeer) GetReplicationEndpointImpl() string {
  360. if m != nil && m.ReplicationEndpointImpl != nil {
  361. return *m.ReplicationEndpointImpl
  362. }
  363. return ""
  364. }
  365. func (m *ReplicationPeer) GetData() []*BytesBytesPair {
  366. if m != nil {
  367. return m.Data
  368. }
  369. return nil
  370. }
  371. func (m *ReplicationPeer) GetConfiguration() []*NameStringPair {
  372. if m != nil {
  373. return m.Configuration
  374. }
  375. return nil
  376. }
  377. // *
  378. // Used by replication. Holds whether enabled or disabled
  379. type ReplicationState struct {
  380. State *ReplicationState_State `protobuf:"varint,1,req,name=state,enum=pb.ReplicationState_State" json:"state,omitempty"`
  381. XXX_unrecognized []byte `json:"-"`
  382. }
  383. func (m *ReplicationState) Reset() { *m = ReplicationState{} }
  384. func (m *ReplicationState) String() string { return proto.CompactTextString(m) }
  385. func (*ReplicationState) ProtoMessage() {}
  386. func (*ReplicationState) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{7} }
  387. func (m *ReplicationState) GetState() ReplicationState_State {
  388. if m != nil && m.State != nil {
  389. return *m.State
  390. }
  391. return ReplicationState_ENABLED
  392. }
  393. // *
  394. // Used by replication. Holds the current position in an WAL file.
  395. type ReplicationHLogPosition struct {
  396. Position *int64 `protobuf:"varint,1,req,name=position" json:"position,omitempty"`
  397. XXX_unrecognized []byte `json:"-"`
  398. }
  399. func (m *ReplicationHLogPosition) Reset() { *m = ReplicationHLogPosition{} }
  400. func (m *ReplicationHLogPosition) String() string { return proto.CompactTextString(m) }
  401. func (*ReplicationHLogPosition) ProtoMessage() {}
  402. func (*ReplicationHLogPosition) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{8} }
  403. func (m *ReplicationHLogPosition) GetPosition() int64 {
  404. if m != nil && m.Position != nil {
  405. return *m.Position
  406. }
  407. return 0
  408. }
  409. // *
  410. // Used by replication. Used to lock a region server during failover.
  411. type ReplicationLock struct {
  412. LockOwner *string `protobuf:"bytes,1,req,name=lock_owner,json=lockOwner" json:"lock_owner,omitempty"`
  413. XXX_unrecognized []byte `json:"-"`
  414. }
  415. func (m *ReplicationLock) Reset() { *m = ReplicationLock{} }
  416. func (m *ReplicationLock) String() string { return proto.CompactTextString(m) }
  417. func (*ReplicationLock) ProtoMessage() {}
  418. func (*ReplicationLock) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{9} }
  419. func (m *ReplicationLock) GetLockOwner() string {
  420. if m != nil && m.LockOwner != nil {
  421. return *m.LockOwner
  422. }
  423. return ""
  424. }
  425. // *
  426. // Metadata associated with a table lock in zookeeper
  427. type TableLock struct {
  428. TableName *TableName `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
  429. LockOwner *ServerName `protobuf:"bytes,2,opt,name=lock_owner,json=lockOwner" json:"lock_owner,omitempty"`
  430. ThreadId *int64 `protobuf:"varint,3,opt,name=thread_id,json=threadId" json:"thread_id,omitempty"`
  431. IsShared *bool `protobuf:"varint,4,opt,name=is_shared,json=isShared" json:"is_shared,omitempty"`
  432. Purpose *string `protobuf:"bytes,5,opt,name=purpose" json:"purpose,omitempty"`
  433. CreateTime *int64 `protobuf:"varint,6,opt,name=create_time,json=createTime" json:"create_time,omitempty"`
  434. XXX_unrecognized []byte `json:"-"`
  435. }
  436. func (m *TableLock) Reset() { *m = TableLock{} }
  437. func (m *TableLock) String() string { return proto.CompactTextString(m) }
  438. func (*TableLock) ProtoMessage() {}
  439. func (*TableLock) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{10} }
  440. func (m *TableLock) GetTableName() *TableName {
  441. if m != nil {
  442. return m.TableName
  443. }
  444. return nil
  445. }
  446. func (m *TableLock) GetLockOwner() *ServerName {
  447. if m != nil {
  448. return m.LockOwner
  449. }
  450. return nil
  451. }
  452. func (m *TableLock) GetThreadId() int64 {
  453. if m != nil && m.ThreadId != nil {
  454. return *m.ThreadId
  455. }
  456. return 0
  457. }
  458. func (m *TableLock) GetIsShared() bool {
  459. if m != nil && m.IsShared != nil {
  460. return *m.IsShared
  461. }
  462. return false
  463. }
  464. func (m *TableLock) GetPurpose() string {
  465. if m != nil && m.Purpose != nil {
  466. return *m.Purpose
  467. }
  468. return ""
  469. }
  470. func (m *TableLock) GetCreateTime() int64 {
  471. if m != nil && m.CreateTime != nil {
  472. return *m.CreateTime
  473. }
  474. return 0
  475. }
  476. // *
  477. // State of the switch.
  478. type SwitchState struct {
  479. Enabled *bool `protobuf:"varint,1,opt,name=enabled" json:"enabled,omitempty"`
  480. XXX_unrecognized []byte `json:"-"`
  481. }
  482. func (m *SwitchState) Reset() { *m = SwitchState{} }
  483. func (m *SwitchState) String() string { return proto.CompactTextString(m) }
  484. func (*SwitchState) ProtoMessage() {}
  485. func (*SwitchState) Descriptor() ([]byte, []int) { return fileDescriptor19, []int{11} }
  486. func (m *SwitchState) GetEnabled() bool {
  487. if m != nil && m.Enabled != nil {
  488. return *m.Enabled
  489. }
  490. return false
  491. }
  492. func init() {
  493. proto.RegisterType((*MetaRegionServer)(nil), "pb.MetaRegionServer")
  494. proto.RegisterType((*Master)(nil), "pb.Master")
  495. proto.RegisterType((*ClusterUp)(nil), "pb.ClusterUp")
  496. proto.RegisterType((*RegionTransition)(nil), "pb.RegionTransition")
  497. proto.RegisterType((*SplitLogTask)(nil), "pb.SplitLogTask")
  498. proto.RegisterType((*Table)(nil), "pb.Table")
  499. proto.RegisterType((*ReplicationPeer)(nil), "pb.ReplicationPeer")
  500. proto.RegisterType((*ReplicationState)(nil), "pb.ReplicationState")
  501. proto.RegisterType((*ReplicationHLogPosition)(nil), "pb.ReplicationHLogPosition")
  502. proto.RegisterType((*ReplicationLock)(nil), "pb.ReplicationLock")
  503. proto.RegisterType((*TableLock)(nil), "pb.TableLock")
  504. proto.RegisterType((*SwitchState)(nil), "pb.SwitchState")
  505. proto.RegisterEnum("pb.SplitLogTask_State", SplitLogTask_State_name, SplitLogTask_State_value)
  506. proto.RegisterEnum("pb.SplitLogTask_RecoveryMode", SplitLogTask_RecoveryMode_name, SplitLogTask_RecoveryMode_value)
  507. proto.RegisterEnum("pb.Table_State", Table_State_name, Table_State_value)
  508. proto.RegisterEnum("pb.ReplicationState_State", ReplicationState_State_name, ReplicationState_State_value)
  509. }
  510. func init() { proto.RegisterFile("ZooKeeper.proto", fileDescriptor19) }
  511. var fileDescriptor19 = []byte{
  512. // 907 bytes of a gzipped FileDescriptorProto
  513. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x55, 0xef, 0x6e, 0xe2, 0x46,
  514. 0x10, 0x8f, 0x0d, 0x49, 0xf0, 0x10, 0x12, 0xba, 0x55, 0x7b, 0x56, 0xaa, 0x6b, 0x91, 0x3f, 0xa4,
  515. 0xe8, 0x7a, 0xa5, 0x27, 0xa4, 0x4a, 0xa7, 0x7c, 0x68, 0x15, 0x02, 0x4a, 0xd0, 0x11, 0x40, 0x6b,
  516. 0xd2, 0x53, 0xfb, 0xc5, 0x5a, 0xec, 0x09, 0x58, 0x01, 0xef, 0x6a, 0xbd, 0xe4, 0xca, 0x1b, 0xdc,
  517. 0x63, 0xf4, 0x09, 0xfa, 0x1a, 0xfd, 0xd4, 0x47, 0xe8, 0xbb, 0x54, 0xbb, 0x0b, 0x04, 0xd2, 0x9e,
  518. 0xf2, 0xc5, 0xda, 0xf9, 0xcd, 0x9f, 0xdf, 0xec, 0xec, 0xcc, 0x18, 0x4e, 0x7e, 0xe3, 0xfc, 0x1d,
  519. 0xa2, 0x40, 0xd9, 0x10, 0x92, 0x2b, 0x4e, 0x5c, 0x31, 0x3e, 0x2d, 0x5f, 0xb7, 0x58, 0x8e, 0x16,
  520. 0x38, 0xfd, 0xfc, 0x72, 0xb6, 0xc8, 0x15, 0xca, 0x50, 0x31, 0xb5, 0xc8, 0x2d, 0x18, 0x7c, 0x74,
  521. 0xa0, 0x7a, 0x83, 0x8a, 0x51, 0x9c, 0xa4, 0x3c, 0x0b, 0x51, 0x3e, 0xa0, 0x24, 0x67, 0x70, 0x90,
  522. 0x9b, 0x93, 0xef, 0xd4, 0xdc, 0x7a, 0xb9, 0x79, 0xdc, 0x10, 0xe3, 0x86, 0xd5, 0xf5, 0xd9, 0x1c,
  523. 0xe9, 0x4a, 0x4b, 0xbe, 0x81, 0xb2, 0x14, 0x71, 0xf4, 0x80, 0x32, 0x4f, 0x79, 0xe6, 0xbb, 0x35,
  524. 0xa7, 0x5e, 0xa1, 0x20, 0x45, 0xfc, 0x8b, 0x45, 0xc8, 0x77, 0xb0, 0x9f, 0x2b, 0xa6, 0xd0, 0x2f,
  525. 0xd4, 0x9c, 0xfa, 0x71, 0xf3, 0x0b, 0x1d, 0x67, 0xc5, 0xa4, 0xe1, 0x86, 0xf9, 0x52, 0x6b, 0x13,
  526. 0x64, 0x70, 0x70, 0xc3, 0x74, 0x82, 0x9a, 0x7f, 0x6e, 0x4e, 0x9f, 0xe2, 0xb7, 0xda, 0xe7, 0xf9,
  527. 0xbf, 0x02, 0x2f, 0xcd, 0xee, 0x78, 0x24, 0xb8, 0x54, 0x26, 0x87, 0x0a, 0x2d, 0x69, 0x60, 0xc8,
  528. 0xa5, 0x0a, 0x5e, 0x81, 0xb7, 0xaa, 0xc8, 0xad, 0x20, 0x2f, 0x01, 0x72, 0xc5, 0xa4, 0x8a, 0x12,
  529. 0x9d, 0xae, 0xa6, 0xf5, 0xa8, 0x67, 0x90, 0xb6, 0xce, 0xed, 0x2f, 0x07, 0xaa, 0x36, 0xf1, 0x91,
  530. 0x64, 0x59, 0x9e, 0x2a, 0x1d, 0xfd, 0x0c, 0x4e, 0xf0, 0x01, 0x33, 0x15, 0xa9, 0xa5, 0xc0, 0x28,
  531. 0xe6, 0x89, 0x75, 0xac, 0xd0, 0x8a, 0x81, 0x47, 0x4b, 0x81, 0x97, 0x3c, 0x41, 0x93, 0xa6, 0xf1,
  532. 0x8d, 0x32, 0x36, 0x47, 0xdf, 0xad, 0xb9, 0xf5, 0x23, 0x0a, 0x16, 0xd2, 0xf7, 0xd1, 0x06, 0xb1,
  533. 0x44, 0xa6, 0x30, 0x52, 0xe9, 0x5c, 0x17, 0xcb, 0xad, 0x17, 0x29, 0x58, 0x68, 0x94, 0xce, 0x91,
  534. 0xfc, 0x00, 0x65, 0x5b, 0x72, 0x1b, 0xa1, 0xf8, 0xbf, 0x55, 0x81, 0x7c, 0x73, 0x26, 0x3e, 0x1c,
  535. 0x0a, 0xb6, 0x9c, 0x71, 0x96, 0xf8, 0xfb, 0x35, 0xa7, 0x7e, 0x44, 0xd7, 0x62, 0xf0, 0xa7, 0x0b,
  536. 0x47, 0xa1, 0x98, 0xa5, 0xaa, 0xc7, 0x27, 0x23, 0x96, 0xdf, 0x93, 0xd7, 0xeb, 0x37, 0xd2, 0xb9,
  537. 0x1f, 0x37, 0xbf, 0x34, 0x51, 0xb7, 0x0c, 0x76, 0x1e, 0xe9, 0x69, 0x26, 0xee, 0xb3, 0x99, 0x9c,
  538. 0x43, 0x71, 0xae, 0x2b, 0x63, 0x3b, 0xe0, 0xe5, 0x7f, 0xa2, 0x53, 0x8c, 0xf9, 0x03, 0xca, 0xe5,
  539. 0x0d, 0x4f, 0xf0, 0xfc, 0xf0, 0xb6, 0xff, 0xae, 0x3f, 0x78, 0xdf, 0xa7, 0xc6, 0x27, 0xb8, 0x84,
  540. 0x7d, 0x43, 0x4e, 0x8e, 0x01, 0x6e, 0xfb, 0x17, 0x61, 0xd8, 0xbd, 0xea, 0x77, 0xda, 0xd5, 0x3d,
  541. 0xe2, 0xc1, 0xfe, 0xe0, 0xbd, 0x3e, 0x3a, 0xe4, 0x08, 0x4a, 0xb4, 0xb3, 0x52, 0xb8, 0xa4, 0x04,
  542. 0xc5, 0xf6, 0xa0, 0xdf, 0xa9, 0x16, 0xc8, 0x21, 0x14, 0x3a, 0x94, 0x56, 0x8b, 0xc1, 0x4f, 0x70,
  543. 0xb4, 0xcd, 0x41, 0xca, 0xb0, 0x66, 0xa9, 0xee, 0x91, 0xcf, 0xa0, 0xd2, 0x1b, 0x5c, 0x45, 0xe1,
  544. 0xb0, 0xd7, 0x1d, 0x8d, 0xba, 0xfd, 0xab, 0xaa, 0xa3, 0xb9, 0x34, 0x44, 0x3b, 0xc3, 0xde, 0xc5,
  545. 0xaf, 0x55, 0x37, 0xf8, 0x1d, 0xf6, 0x47, 0x6c, 0x3c, 0x43, 0xd2, 0xd8, 0x2d, 0xd4, 0x89, 0xbe,
  546. 0x8a, 0xd1, 0xd8, 0x0a, 0x9d, 0x1f, 0x76, 0xfa, 0x17, 0xad, 0x5e, 0xa7, 0xbd, 0xee, 0xe7, 0x9f,
  547. 0xd7, 0xd9, 0x97, 0x61, 0xad, 0xaa, 0xee, 0xe9, 0x7c, 0xdb, 0xdd, 0xd0, 0x4a, 0x0e, 0xa9, 0x80,
  548. 0x67, 0x25, 0xcd, 0xed, 0x6a, 0xa5, 0xb1, 0xd4, 0x52, 0x21, 0xf8, 0xdb, 0x81, 0x13, 0x8a, 0x62,
  549. 0x96, 0xc6, 0x4c, 0xf7, 0xdb, 0x10, 0x51, 0x92, 0xaf, 0x01, 0x62, 0xdb, 0xb4, 0xf7, 0xb8, 0x5c,
  550. 0xf5, 0xe9, 0x16, 0x42, 0xde, 0xc2, 0x0b, 0xf9, 0xe8, 0xd2, 0xc9, 0x12, 0xc1, 0xd3, 0x4c, 0x75,
  551. 0xe7, 0x62, 0x66, 0xc6, 0xc3, 0xa3, 0x9f, 0x52, 0x93, 0x33, 0x28, 0x26, 0x4c, 0x31, 0xbf, 0x50,
  552. 0x2b, 0xd4, 0xcb, 0x4d, 0xa2, 0x6f, 0xd7, 0x5a, 0x2a, 0xcc, 0xcd, 0x67, 0xc8, 0x52, 0x49, 0x8d,
  553. 0x9e, 0xbc, 0x85, 0x4a, 0xcc, 0xb3, 0xbb, 0x74, 0xb2, 0x90, 0x26, 0x88, 0x5f, 0x7c, 0x74, 0xd0,
  554. 0x2f, 0x1e, 0x2a, 0x99, 0x66, 0x13, 0xe3, 0xb0, 0x6b, 0x18, 0x4c, 0xf5, 0x0c, 0x6d, 0xc8, 0x6d,
  555. 0x6d, 0xde, 0xec, 0x16, 0xf5, 0xd4, 0x6e, 0x88, 0x5d, 0xa3, 0xdd, 0x35, 0x11, 0x3c, 0x5f, 0xd6,
  556. 0xe0, 0x47, 0x78, 0xb1, 0x15, 0xe4, 0xba, 0xc7, 0x27, 0x43, 0xbe, 0x1a, 0xda, 0x53, 0x28, 0x89,
  557. 0xd5, 0xd9, 0x70, 0x16, 0xe8, 0x46, 0x0e, 0xde, 0xec, 0xd4, 0xbb, 0xc7, 0xe3, 0x7b, 0xbd, 0x17,
  558. 0x66, 0x3c, 0xbe, 0x8f, 0xf8, 0x87, 0x6c, 0xb5, 0x8e, 0x3c, 0xea, 0x69, 0x64, 0xa0, 0x81, 0xe0,
  559. 0x1f, 0x07, 0x3c, 0xd3, 0x03, 0xc6, 0xf8, 0x35, 0x80, 0xd2, 0x82, 0x9d, 0x0d, 0xa7, 0xe6, 0xd4,
  560. 0xcb, 0xcd, 0xca, 0xa6, 0x4d, 0xcc, 0x68, 0x78, 0x6a, 0x7d, 0x24, 0xdf, 0xef, 0x84, 0x76, 0x8d,
  561. 0xf5, 0xd3, 0x49, 0x7a, 0xa4, 0xd2, 0xbb, 0x4c, 0x4d, 0x25, 0xb2, 0x24, 0x4a, 0x13, 0x33, 0x4d,
  562. 0x05, 0x5a, 0xb2, 0x40, 0x37, 0x31, 0x8b, 0x2e, 0x8f, 0xf2, 0x29, 0x93, 0x98, 0xf8, 0xc5, 0x9a,
  563. 0x53, 0x2f, 0xd1, 0x52, 0x9a, 0x87, 0x46, 0x36, 0xcb, 0x60, 0x21, 0x05, 0xcf, 0xd1, 0x2c, 0x03,
  564. 0x8f, 0xae, 0xc5, 0xa7, 0x8b, 0xe7, 0xc0, 0x44, 0xdd, 0x5a, 0x3c, 0xc1, 0xb7, 0x50, 0x0e, 0x3f,
  565. 0xa4, 0x2a, 0x9e, 0xda, 0x92, 0xfb, 0x70, 0x88, 0x99, 0xbe, 0x40, 0x62, 0x6e, 0x57, 0xa2, 0x6b,
  566. 0xb1, 0xd5, 0x81, 0x57, 0x5c, 0x4e, 0x1a, 0x4c, 0xb0, 0x78, 0x8a, 0x8d, 0x29, 0x4b, 0x38, 0x17,
  567. 0x8d, 0xe9, 0x78, 0xf3, 0xf7, 0x19, 0x2f, 0xee, 0x1a, 0x13, 0xcc, 0x50, 0x32, 0x85, 0x49, 0xeb,
  568. 0xf1, 0x67, 0x35, 0xd4, 0xca, 0xfc, 0xda, 0xf9, 0xe8, 0x38, 0x7f, 0x38, 0xce, 0xbf, 0x01, 0x00,
  569. 0x00, 0xff, 0xff, 0x48, 0xdb, 0x93, 0x4c, 0xc6, 0x06, 0x00, 0x00,
  570. }