command.pb.go 91 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // versions:
  3. // protoc-gen-go v1.28.1
  4. // protoc v3.12.4
  5. // source: v1/request/command.proto
  6. package request
  7. import (
  8. _ "github.com/mwitkow/go-proto-validators"
  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. type AutoMigrateRequest struct {
  21. state protoimpl.MessageState
  22. sizeCache protoimpl.SizeCache
  23. unknownFields protoimpl.UnknownFields
  24. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  25. Items []*AutoMigrateItem `protobuf:"bytes,2,rep,name=Items,proto3" json:"Items,omitempty"`
  26. }
  27. func (x *AutoMigrateRequest) Reset() {
  28. *x = AutoMigrateRequest{}
  29. if protoimpl.UnsafeEnabled {
  30. mi := &file_v1_request_command_proto_msgTypes[0]
  31. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  32. ms.StoreMessageInfo(mi)
  33. }
  34. }
  35. func (x *AutoMigrateRequest) String() string {
  36. return protoimpl.X.MessageStringOf(x)
  37. }
  38. func (*AutoMigrateRequest) ProtoMessage() {}
  39. func (x *AutoMigrateRequest) ProtoReflect() protoreflect.Message {
  40. mi := &file_v1_request_command_proto_msgTypes[0]
  41. if protoimpl.UnsafeEnabled && x != nil {
  42. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  43. if ms.LoadMessageInfo() == nil {
  44. ms.StoreMessageInfo(mi)
  45. }
  46. return ms
  47. }
  48. return mi.MessageOf(x)
  49. }
  50. // Deprecated: Use AutoMigrateRequest.ProtoReflect.Descriptor instead.
  51. func (*AutoMigrateRequest) Descriptor() ([]byte, []int) {
  52. return file_v1_request_command_proto_rawDescGZIP(), []int{0}
  53. }
  54. func (x *AutoMigrateRequest) GetDatabaseID() string {
  55. if x != nil {
  56. return x.DatabaseID
  57. }
  58. return ""
  59. }
  60. func (x *AutoMigrateRequest) GetItems() []*AutoMigrateItem {
  61. if x != nil {
  62. return x.Items
  63. }
  64. return nil
  65. }
  66. type AutoMigrateItem struct {
  67. state protoimpl.MessageState
  68. sizeCache protoimpl.SizeCache
  69. unknownFields protoimpl.UnknownFields
  70. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  71. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  72. TableModelDescribe []byte `protobuf:"bytes,3,opt,name=TableModelDescribe,proto3" json:"TableModelDescribe,omitempty"`
  73. }
  74. func (x *AutoMigrateItem) Reset() {
  75. *x = AutoMigrateItem{}
  76. if protoimpl.UnsafeEnabled {
  77. mi := &file_v1_request_command_proto_msgTypes[1]
  78. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  79. ms.StoreMessageInfo(mi)
  80. }
  81. }
  82. func (x *AutoMigrateItem) String() string {
  83. return protoimpl.X.MessageStringOf(x)
  84. }
  85. func (*AutoMigrateItem) ProtoMessage() {}
  86. func (x *AutoMigrateItem) ProtoReflect() protoreflect.Message {
  87. mi := &file_v1_request_command_proto_msgTypes[1]
  88. if protoimpl.UnsafeEnabled && x != nil {
  89. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  90. if ms.LoadMessageInfo() == nil {
  91. ms.StoreMessageInfo(mi)
  92. }
  93. return ms
  94. }
  95. return mi.MessageOf(x)
  96. }
  97. // Deprecated: Use AutoMigrateItem.ProtoReflect.Descriptor instead.
  98. func (*AutoMigrateItem) Descriptor() ([]byte, []int) {
  99. return file_v1_request_command_proto_rawDescGZIP(), []int{1}
  100. }
  101. func (x *AutoMigrateItem) GetTablePrefixWithSchema() string {
  102. if x != nil {
  103. return x.TablePrefixWithSchema
  104. }
  105. return ""
  106. }
  107. func (x *AutoMigrateItem) GetVersion() string {
  108. if x != nil {
  109. return x.Version
  110. }
  111. return ""
  112. }
  113. func (x *AutoMigrateItem) GetTableModelDescribe() []byte {
  114. if x != nil {
  115. return x.TableModelDescribe
  116. }
  117. return nil
  118. }
  119. type TransactionBeginRequest struct {
  120. state protoimpl.MessageState
  121. sizeCache protoimpl.SizeCache
  122. unknownFields protoimpl.UnknownFields
  123. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  124. }
  125. func (x *TransactionBeginRequest) Reset() {
  126. *x = TransactionBeginRequest{}
  127. if protoimpl.UnsafeEnabled {
  128. mi := &file_v1_request_command_proto_msgTypes[2]
  129. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  130. ms.StoreMessageInfo(mi)
  131. }
  132. }
  133. func (x *TransactionBeginRequest) String() string {
  134. return protoimpl.X.MessageStringOf(x)
  135. }
  136. func (*TransactionBeginRequest) ProtoMessage() {}
  137. func (x *TransactionBeginRequest) ProtoReflect() protoreflect.Message {
  138. mi := &file_v1_request_command_proto_msgTypes[2]
  139. if protoimpl.UnsafeEnabled && x != nil {
  140. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  141. if ms.LoadMessageInfo() == nil {
  142. ms.StoreMessageInfo(mi)
  143. }
  144. return ms
  145. }
  146. return mi.MessageOf(x)
  147. }
  148. // Deprecated: Use TransactionBeginRequest.ProtoReflect.Descriptor instead.
  149. func (*TransactionBeginRequest) Descriptor() ([]byte, []int) {
  150. return file_v1_request_command_proto_rawDescGZIP(), []int{2}
  151. }
  152. func (x *TransactionBeginRequest) GetDatabaseID() string {
  153. if x != nil {
  154. return x.DatabaseID
  155. }
  156. return ""
  157. }
  158. type InsertTxRequest struct {
  159. state protoimpl.MessageState
  160. sizeCache protoimpl.SizeCache
  161. unknownFields protoimpl.UnknownFields
  162. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  163. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  164. KeyColumns []string `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
  165. TableRow *TableRow `protobuf:"bytes,4,opt,name=TableRow,proto3" json:"TableRow,omitempty"`
  166. UserID string `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
  167. }
  168. func (x *InsertTxRequest) Reset() {
  169. *x = InsertTxRequest{}
  170. if protoimpl.UnsafeEnabled {
  171. mi := &file_v1_request_command_proto_msgTypes[3]
  172. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  173. ms.StoreMessageInfo(mi)
  174. }
  175. }
  176. func (x *InsertTxRequest) String() string {
  177. return protoimpl.X.MessageStringOf(x)
  178. }
  179. func (*InsertTxRequest) ProtoMessage() {}
  180. func (x *InsertTxRequest) ProtoReflect() protoreflect.Message {
  181. mi := &file_v1_request_command_proto_msgTypes[3]
  182. if protoimpl.UnsafeEnabled && x != nil {
  183. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  184. if ms.LoadMessageInfo() == nil {
  185. ms.StoreMessageInfo(mi)
  186. }
  187. return ms
  188. }
  189. return mi.MessageOf(x)
  190. }
  191. // Deprecated: Use InsertTxRequest.ProtoReflect.Descriptor instead.
  192. func (*InsertTxRequest) Descriptor() ([]byte, []int) {
  193. return file_v1_request_command_proto_rawDescGZIP(), []int{3}
  194. }
  195. func (x *InsertTxRequest) GetTablePrefixWithSchema() string {
  196. if x != nil {
  197. return x.TablePrefixWithSchema
  198. }
  199. return ""
  200. }
  201. func (x *InsertTxRequest) GetVersion() string {
  202. if x != nil {
  203. return x.Version
  204. }
  205. return ""
  206. }
  207. func (x *InsertTxRequest) GetKeyColumns() []string {
  208. if x != nil {
  209. return x.KeyColumns
  210. }
  211. return nil
  212. }
  213. func (x *InsertTxRequest) GetTableRow() *TableRow {
  214. if x != nil {
  215. return x.TableRow
  216. }
  217. return nil
  218. }
  219. func (x *InsertTxRequest) GetUserID() string {
  220. if x != nil {
  221. return x.UserID
  222. }
  223. return ""
  224. }
  225. type InsertBatchTxRequest struct {
  226. state protoimpl.MessageState
  227. sizeCache protoimpl.SizeCache
  228. unknownFields protoimpl.UnknownFields
  229. Items []*InsertTableRowItem `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
  230. UserID string `protobuf:"bytes,2,opt,name=UserID,proto3" json:"UserID,omitempty"`
  231. }
  232. func (x *InsertBatchTxRequest) Reset() {
  233. *x = InsertBatchTxRequest{}
  234. if protoimpl.UnsafeEnabled {
  235. mi := &file_v1_request_command_proto_msgTypes[4]
  236. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  237. ms.StoreMessageInfo(mi)
  238. }
  239. }
  240. func (x *InsertBatchTxRequest) String() string {
  241. return protoimpl.X.MessageStringOf(x)
  242. }
  243. func (*InsertBatchTxRequest) ProtoMessage() {}
  244. func (x *InsertBatchTxRequest) ProtoReflect() protoreflect.Message {
  245. mi := &file_v1_request_command_proto_msgTypes[4]
  246. if protoimpl.UnsafeEnabled && x != nil {
  247. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  248. if ms.LoadMessageInfo() == nil {
  249. ms.StoreMessageInfo(mi)
  250. }
  251. return ms
  252. }
  253. return mi.MessageOf(x)
  254. }
  255. // Deprecated: Use InsertBatchTxRequest.ProtoReflect.Descriptor instead.
  256. func (*InsertBatchTxRequest) Descriptor() ([]byte, []int) {
  257. return file_v1_request_command_proto_rawDescGZIP(), []int{4}
  258. }
  259. func (x *InsertBatchTxRequest) GetItems() []*InsertTableRowItem {
  260. if x != nil {
  261. return x.Items
  262. }
  263. return nil
  264. }
  265. func (x *InsertBatchTxRequest) GetUserID() string {
  266. if x != nil {
  267. return x.UserID
  268. }
  269. return ""
  270. }
  271. type DeleteTxRequest struct {
  272. state protoimpl.MessageState
  273. sizeCache protoimpl.SizeCache
  274. unknownFields protoimpl.UnknownFields
  275. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  276. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  277. KeyValues map[string]string `protobuf:"bytes,3,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  278. UserID string `protobuf:"bytes,4,opt,name=UserID,proto3" json:"UserID,omitempty"`
  279. }
  280. func (x *DeleteTxRequest) Reset() {
  281. *x = DeleteTxRequest{}
  282. if protoimpl.UnsafeEnabled {
  283. mi := &file_v1_request_command_proto_msgTypes[5]
  284. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  285. ms.StoreMessageInfo(mi)
  286. }
  287. }
  288. func (x *DeleteTxRequest) String() string {
  289. return protoimpl.X.MessageStringOf(x)
  290. }
  291. func (*DeleteTxRequest) ProtoMessage() {}
  292. func (x *DeleteTxRequest) ProtoReflect() protoreflect.Message {
  293. mi := &file_v1_request_command_proto_msgTypes[5]
  294. if protoimpl.UnsafeEnabled && x != nil {
  295. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  296. if ms.LoadMessageInfo() == nil {
  297. ms.StoreMessageInfo(mi)
  298. }
  299. return ms
  300. }
  301. return mi.MessageOf(x)
  302. }
  303. // Deprecated: Use DeleteTxRequest.ProtoReflect.Descriptor instead.
  304. func (*DeleteTxRequest) Descriptor() ([]byte, []int) {
  305. return file_v1_request_command_proto_rawDescGZIP(), []int{5}
  306. }
  307. func (x *DeleteTxRequest) GetTablePrefixWithSchema() string {
  308. if x != nil {
  309. return x.TablePrefixWithSchema
  310. }
  311. return ""
  312. }
  313. func (x *DeleteTxRequest) GetVersion() string {
  314. if x != nil {
  315. return x.Version
  316. }
  317. return ""
  318. }
  319. func (x *DeleteTxRequest) GetKeyValues() map[string]string {
  320. if x != nil {
  321. return x.KeyValues
  322. }
  323. return nil
  324. }
  325. func (x *DeleteTxRequest) GetUserID() string {
  326. if x != nil {
  327. return x.UserID
  328. }
  329. return ""
  330. }
  331. type DeleteWhereTxRequest struct {
  332. state protoimpl.MessageState
  333. sizeCache protoimpl.SizeCache
  334. unknownFields protoimpl.UnknownFields
  335. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  336. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  337. KeyColumns []string `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
  338. Where []byte `protobuf:"bytes,4,opt,name=Where,proto3" json:"Where,omitempty"`
  339. UserID string `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
  340. }
  341. func (x *DeleteWhereTxRequest) Reset() {
  342. *x = DeleteWhereTxRequest{}
  343. if protoimpl.UnsafeEnabled {
  344. mi := &file_v1_request_command_proto_msgTypes[6]
  345. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  346. ms.StoreMessageInfo(mi)
  347. }
  348. }
  349. func (x *DeleteWhereTxRequest) String() string {
  350. return protoimpl.X.MessageStringOf(x)
  351. }
  352. func (*DeleteWhereTxRequest) ProtoMessage() {}
  353. func (x *DeleteWhereTxRequest) ProtoReflect() protoreflect.Message {
  354. mi := &file_v1_request_command_proto_msgTypes[6]
  355. if protoimpl.UnsafeEnabled && x != nil {
  356. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  357. if ms.LoadMessageInfo() == nil {
  358. ms.StoreMessageInfo(mi)
  359. }
  360. return ms
  361. }
  362. return mi.MessageOf(x)
  363. }
  364. // Deprecated: Use DeleteWhereTxRequest.ProtoReflect.Descriptor instead.
  365. func (*DeleteWhereTxRequest) Descriptor() ([]byte, []int) {
  366. return file_v1_request_command_proto_rawDescGZIP(), []int{6}
  367. }
  368. func (x *DeleteWhereTxRequest) GetTablePrefixWithSchema() string {
  369. if x != nil {
  370. return x.TablePrefixWithSchema
  371. }
  372. return ""
  373. }
  374. func (x *DeleteWhereTxRequest) GetVersion() string {
  375. if x != nil {
  376. return x.Version
  377. }
  378. return ""
  379. }
  380. func (x *DeleteWhereTxRequest) GetKeyColumns() []string {
  381. if x != nil {
  382. return x.KeyColumns
  383. }
  384. return nil
  385. }
  386. func (x *DeleteWhereTxRequest) GetWhere() []byte {
  387. if x != nil {
  388. return x.Where
  389. }
  390. return nil
  391. }
  392. func (x *DeleteWhereTxRequest) GetUserID() string {
  393. if x != nil {
  394. return x.UserID
  395. }
  396. return ""
  397. }
  398. type DeleteBatchTxRequest struct {
  399. state protoimpl.MessageState
  400. sizeCache protoimpl.SizeCache
  401. unknownFields protoimpl.UnknownFields
  402. Items []*DeleteTableRowItem `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
  403. UserID string `protobuf:"bytes,2,opt,name=UserID,proto3" json:"UserID,omitempty"`
  404. }
  405. func (x *DeleteBatchTxRequest) Reset() {
  406. *x = DeleteBatchTxRequest{}
  407. if protoimpl.UnsafeEnabled {
  408. mi := &file_v1_request_command_proto_msgTypes[7]
  409. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  410. ms.StoreMessageInfo(mi)
  411. }
  412. }
  413. func (x *DeleteBatchTxRequest) String() string {
  414. return protoimpl.X.MessageStringOf(x)
  415. }
  416. func (*DeleteBatchTxRequest) ProtoMessage() {}
  417. func (x *DeleteBatchTxRequest) ProtoReflect() protoreflect.Message {
  418. mi := &file_v1_request_command_proto_msgTypes[7]
  419. if protoimpl.UnsafeEnabled && x != nil {
  420. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  421. if ms.LoadMessageInfo() == nil {
  422. ms.StoreMessageInfo(mi)
  423. }
  424. return ms
  425. }
  426. return mi.MessageOf(x)
  427. }
  428. // Deprecated: Use DeleteBatchTxRequest.ProtoReflect.Descriptor instead.
  429. func (*DeleteBatchTxRequest) Descriptor() ([]byte, []int) {
  430. return file_v1_request_command_proto_rawDescGZIP(), []int{7}
  431. }
  432. func (x *DeleteBatchTxRequest) GetItems() []*DeleteTableRowItem {
  433. if x != nil {
  434. return x.Items
  435. }
  436. return nil
  437. }
  438. func (x *DeleteBatchTxRequest) GetUserID() string {
  439. if x != nil {
  440. return x.UserID
  441. }
  442. return ""
  443. }
  444. type UpdateTxRequest struct {
  445. state protoimpl.MessageState
  446. sizeCache protoimpl.SizeCache
  447. unknownFields protoimpl.UnknownFields
  448. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  449. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  450. KeyValues map[string]string `protobuf:"bytes,3,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  451. NewTableRow *TableRow `protobuf:"bytes,4,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
  452. UserID string `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
  453. }
  454. func (x *UpdateTxRequest) Reset() {
  455. *x = UpdateTxRequest{}
  456. if protoimpl.UnsafeEnabled {
  457. mi := &file_v1_request_command_proto_msgTypes[8]
  458. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  459. ms.StoreMessageInfo(mi)
  460. }
  461. }
  462. func (x *UpdateTxRequest) String() string {
  463. return protoimpl.X.MessageStringOf(x)
  464. }
  465. func (*UpdateTxRequest) ProtoMessage() {}
  466. func (x *UpdateTxRequest) ProtoReflect() protoreflect.Message {
  467. mi := &file_v1_request_command_proto_msgTypes[8]
  468. if protoimpl.UnsafeEnabled && x != nil {
  469. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  470. if ms.LoadMessageInfo() == nil {
  471. ms.StoreMessageInfo(mi)
  472. }
  473. return ms
  474. }
  475. return mi.MessageOf(x)
  476. }
  477. // Deprecated: Use UpdateTxRequest.ProtoReflect.Descriptor instead.
  478. func (*UpdateTxRequest) Descriptor() ([]byte, []int) {
  479. return file_v1_request_command_proto_rawDescGZIP(), []int{8}
  480. }
  481. func (x *UpdateTxRequest) GetTablePrefixWithSchema() string {
  482. if x != nil {
  483. return x.TablePrefixWithSchema
  484. }
  485. return ""
  486. }
  487. func (x *UpdateTxRequest) GetVersion() string {
  488. if x != nil {
  489. return x.Version
  490. }
  491. return ""
  492. }
  493. func (x *UpdateTxRequest) GetKeyValues() map[string]string {
  494. if x != nil {
  495. return x.KeyValues
  496. }
  497. return nil
  498. }
  499. func (x *UpdateTxRequest) GetNewTableRow() *TableRow {
  500. if x != nil {
  501. return x.NewTableRow
  502. }
  503. return nil
  504. }
  505. func (x *UpdateTxRequest) GetUserID() string {
  506. if x != nil {
  507. return x.UserID
  508. }
  509. return ""
  510. }
  511. type TransactionEndRequest struct {
  512. state protoimpl.MessageState
  513. sizeCache protoimpl.SizeCache
  514. unknownFields protoimpl.UnknownFields
  515. }
  516. func (x *TransactionEndRequest) Reset() {
  517. *x = TransactionEndRequest{}
  518. if protoimpl.UnsafeEnabled {
  519. mi := &file_v1_request_command_proto_msgTypes[9]
  520. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  521. ms.StoreMessageInfo(mi)
  522. }
  523. }
  524. func (x *TransactionEndRequest) String() string {
  525. return protoimpl.X.MessageStringOf(x)
  526. }
  527. func (*TransactionEndRequest) ProtoMessage() {}
  528. func (x *TransactionEndRequest) ProtoReflect() protoreflect.Message {
  529. mi := &file_v1_request_command_proto_msgTypes[9]
  530. if protoimpl.UnsafeEnabled && x != nil {
  531. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  532. if ms.LoadMessageInfo() == nil {
  533. ms.StoreMessageInfo(mi)
  534. }
  535. return ms
  536. }
  537. return mi.MessageOf(x)
  538. }
  539. // Deprecated: Use TransactionEndRequest.ProtoReflect.Descriptor instead.
  540. func (*TransactionEndRequest) Descriptor() ([]byte, []int) {
  541. return file_v1_request_command_proto_rawDescGZIP(), []int{9}
  542. }
  543. type TransactionOperation struct {
  544. state protoimpl.MessageState
  545. sizeCache protoimpl.SizeCache
  546. unknownFields protoimpl.UnknownFields
  547. // Types that are assignable to Request:
  548. //
  549. // *TransactionOperation_TransactionBeginRequest
  550. // *TransactionOperation_InsertTxRequest
  551. // *TransactionOperation_InsertBatchTxRequest
  552. // *TransactionOperation_DeleteTxRequest
  553. // *TransactionOperation_DeleteWhereTxRequest
  554. // *TransactionOperation_DeleteBatchTxRequest
  555. // *TransactionOperation_UpdateTxRequest
  556. // *TransactionOperation_TransactionEndRequest
  557. Request isTransactionOperation_Request `protobuf_oneof:"Request"`
  558. }
  559. func (x *TransactionOperation) Reset() {
  560. *x = TransactionOperation{}
  561. if protoimpl.UnsafeEnabled {
  562. mi := &file_v1_request_command_proto_msgTypes[10]
  563. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  564. ms.StoreMessageInfo(mi)
  565. }
  566. }
  567. func (x *TransactionOperation) String() string {
  568. return protoimpl.X.MessageStringOf(x)
  569. }
  570. func (*TransactionOperation) ProtoMessage() {}
  571. func (x *TransactionOperation) ProtoReflect() protoreflect.Message {
  572. mi := &file_v1_request_command_proto_msgTypes[10]
  573. if protoimpl.UnsafeEnabled && x != nil {
  574. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  575. if ms.LoadMessageInfo() == nil {
  576. ms.StoreMessageInfo(mi)
  577. }
  578. return ms
  579. }
  580. return mi.MessageOf(x)
  581. }
  582. // Deprecated: Use TransactionOperation.ProtoReflect.Descriptor instead.
  583. func (*TransactionOperation) Descriptor() ([]byte, []int) {
  584. return file_v1_request_command_proto_rawDescGZIP(), []int{10}
  585. }
  586. func (m *TransactionOperation) GetRequest() isTransactionOperation_Request {
  587. if m != nil {
  588. return m.Request
  589. }
  590. return nil
  591. }
  592. func (x *TransactionOperation) GetTransactionBeginRequest() *TransactionBeginRequest {
  593. if x, ok := x.GetRequest().(*TransactionOperation_TransactionBeginRequest); ok {
  594. return x.TransactionBeginRequest
  595. }
  596. return nil
  597. }
  598. func (x *TransactionOperation) GetInsertTxRequest() *InsertTxRequest {
  599. if x, ok := x.GetRequest().(*TransactionOperation_InsertTxRequest); ok {
  600. return x.InsertTxRequest
  601. }
  602. return nil
  603. }
  604. func (x *TransactionOperation) GetInsertBatchTxRequest() *InsertBatchTxRequest {
  605. if x, ok := x.GetRequest().(*TransactionOperation_InsertBatchTxRequest); ok {
  606. return x.InsertBatchTxRequest
  607. }
  608. return nil
  609. }
  610. func (x *TransactionOperation) GetDeleteTxRequest() *DeleteTxRequest {
  611. if x, ok := x.GetRequest().(*TransactionOperation_DeleteTxRequest); ok {
  612. return x.DeleteTxRequest
  613. }
  614. return nil
  615. }
  616. func (x *TransactionOperation) GetDeleteWhereTxRequest() *DeleteWhereTxRequest {
  617. if x, ok := x.GetRequest().(*TransactionOperation_DeleteWhereTxRequest); ok {
  618. return x.DeleteWhereTxRequest
  619. }
  620. return nil
  621. }
  622. func (x *TransactionOperation) GetDeleteBatchTxRequest() *DeleteBatchTxRequest {
  623. if x, ok := x.GetRequest().(*TransactionOperation_DeleteBatchTxRequest); ok {
  624. return x.DeleteBatchTxRequest
  625. }
  626. return nil
  627. }
  628. func (x *TransactionOperation) GetUpdateTxRequest() *UpdateTxRequest {
  629. if x, ok := x.GetRequest().(*TransactionOperation_UpdateTxRequest); ok {
  630. return x.UpdateTxRequest
  631. }
  632. return nil
  633. }
  634. func (x *TransactionOperation) GetTransactionEndRequest() *TransactionEndRequest {
  635. if x, ok := x.GetRequest().(*TransactionOperation_TransactionEndRequest); ok {
  636. return x.TransactionEndRequest
  637. }
  638. return nil
  639. }
  640. type isTransactionOperation_Request interface {
  641. isTransactionOperation_Request()
  642. }
  643. type TransactionOperation_TransactionBeginRequest struct {
  644. TransactionBeginRequest *TransactionBeginRequest `protobuf:"bytes,1,opt,name=TransactionBeginRequest,proto3,oneof"`
  645. }
  646. type TransactionOperation_InsertTxRequest struct {
  647. InsertTxRequest *InsertTxRequest `protobuf:"bytes,2,opt,name=InsertTxRequest,proto3,oneof"`
  648. }
  649. type TransactionOperation_InsertBatchTxRequest struct {
  650. InsertBatchTxRequest *InsertBatchTxRequest `protobuf:"bytes,3,opt,name=InsertBatchTxRequest,proto3,oneof"`
  651. }
  652. type TransactionOperation_DeleteTxRequest struct {
  653. DeleteTxRequest *DeleteTxRequest `protobuf:"bytes,4,opt,name=DeleteTxRequest,proto3,oneof"`
  654. }
  655. type TransactionOperation_DeleteWhereTxRequest struct {
  656. DeleteWhereTxRequest *DeleteWhereTxRequest `protobuf:"bytes,5,opt,name=DeleteWhereTxRequest,proto3,oneof"`
  657. }
  658. type TransactionOperation_DeleteBatchTxRequest struct {
  659. DeleteBatchTxRequest *DeleteBatchTxRequest `protobuf:"bytes,6,opt,name=DeleteBatchTxRequest,proto3,oneof"`
  660. }
  661. type TransactionOperation_UpdateTxRequest struct {
  662. UpdateTxRequest *UpdateTxRequest `protobuf:"bytes,7,opt,name=UpdateTxRequest,proto3,oneof"`
  663. }
  664. type TransactionOperation_TransactionEndRequest struct {
  665. TransactionEndRequest *TransactionEndRequest `protobuf:"bytes,8,opt,name=TransactionEndRequest,proto3,oneof"`
  666. }
  667. func (*TransactionOperation_TransactionBeginRequest) isTransactionOperation_Request() {}
  668. func (*TransactionOperation_InsertTxRequest) isTransactionOperation_Request() {}
  669. func (*TransactionOperation_InsertBatchTxRequest) isTransactionOperation_Request() {}
  670. func (*TransactionOperation_DeleteTxRequest) isTransactionOperation_Request() {}
  671. func (*TransactionOperation_DeleteWhereTxRequest) isTransactionOperation_Request() {}
  672. func (*TransactionOperation_DeleteBatchTxRequest) isTransactionOperation_Request() {}
  673. func (*TransactionOperation_UpdateTxRequest) isTransactionOperation_Request() {}
  674. func (*TransactionOperation_TransactionEndRequest) isTransactionOperation_Request() {}
  675. type InsertRequest struct {
  676. state protoimpl.MessageState
  677. sizeCache protoimpl.SizeCache
  678. unknownFields protoimpl.UnknownFields
  679. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  680. TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  681. Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
  682. KeyColumns []string `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
  683. TableRow *TableRow `protobuf:"bytes,5,opt,name=TableRow,proto3" json:"TableRow,omitempty"`
  684. UserID string `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
  685. }
  686. func (x *InsertRequest) Reset() {
  687. *x = InsertRequest{}
  688. if protoimpl.UnsafeEnabled {
  689. mi := &file_v1_request_command_proto_msgTypes[11]
  690. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  691. ms.StoreMessageInfo(mi)
  692. }
  693. }
  694. func (x *InsertRequest) String() string {
  695. return protoimpl.X.MessageStringOf(x)
  696. }
  697. func (*InsertRequest) ProtoMessage() {}
  698. func (x *InsertRequest) ProtoReflect() protoreflect.Message {
  699. mi := &file_v1_request_command_proto_msgTypes[11]
  700. if protoimpl.UnsafeEnabled && x != nil {
  701. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  702. if ms.LoadMessageInfo() == nil {
  703. ms.StoreMessageInfo(mi)
  704. }
  705. return ms
  706. }
  707. return mi.MessageOf(x)
  708. }
  709. // Deprecated: Use InsertRequest.ProtoReflect.Descriptor instead.
  710. func (*InsertRequest) Descriptor() ([]byte, []int) {
  711. return file_v1_request_command_proto_rawDescGZIP(), []int{11}
  712. }
  713. func (x *InsertRequest) GetDatabaseID() string {
  714. if x != nil {
  715. return x.DatabaseID
  716. }
  717. return ""
  718. }
  719. func (x *InsertRequest) GetTablePrefixWithSchema() string {
  720. if x != nil {
  721. return x.TablePrefixWithSchema
  722. }
  723. return ""
  724. }
  725. func (x *InsertRequest) GetVersion() string {
  726. if x != nil {
  727. return x.Version
  728. }
  729. return ""
  730. }
  731. func (x *InsertRequest) GetKeyColumns() []string {
  732. if x != nil {
  733. return x.KeyColumns
  734. }
  735. return nil
  736. }
  737. func (x *InsertRequest) GetTableRow() *TableRow {
  738. if x != nil {
  739. return x.TableRow
  740. }
  741. return nil
  742. }
  743. func (x *InsertRequest) GetUserID() string {
  744. if x != nil {
  745. return x.UserID
  746. }
  747. return ""
  748. }
  749. type InsertBatchRequest struct {
  750. state protoimpl.MessageState
  751. sizeCache protoimpl.SizeCache
  752. unknownFields protoimpl.UnknownFields
  753. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  754. Items []*InsertTableRowItem `protobuf:"bytes,2,rep,name=Items,proto3" json:"Items,omitempty"`
  755. UserID string `protobuf:"bytes,3,opt,name=UserID,proto3" json:"UserID,omitempty"`
  756. }
  757. func (x *InsertBatchRequest) Reset() {
  758. *x = InsertBatchRequest{}
  759. if protoimpl.UnsafeEnabled {
  760. mi := &file_v1_request_command_proto_msgTypes[12]
  761. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  762. ms.StoreMessageInfo(mi)
  763. }
  764. }
  765. func (x *InsertBatchRequest) String() string {
  766. return protoimpl.X.MessageStringOf(x)
  767. }
  768. func (*InsertBatchRequest) ProtoMessage() {}
  769. func (x *InsertBatchRequest) ProtoReflect() protoreflect.Message {
  770. mi := &file_v1_request_command_proto_msgTypes[12]
  771. if protoimpl.UnsafeEnabled && x != nil {
  772. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  773. if ms.LoadMessageInfo() == nil {
  774. ms.StoreMessageInfo(mi)
  775. }
  776. return ms
  777. }
  778. return mi.MessageOf(x)
  779. }
  780. // Deprecated: Use InsertBatchRequest.ProtoReflect.Descriptor instead.
  781. func (*InsertBatchRequest) Descriptor() ([]byte, []int) {
  782. return file_v1_request_command_proto_rawDescGZIP(), []int{12}
  783. }
  784. func (x *InsertBatchRequest) GetDatabaseID() string {
  785. if x != nil {
  786. return x.DatabaseID
  787. }
  788. return ""
  789. }
  790. func (x *InsertBatchRequest) GetItems() []*InsertTableRowItem {
  791. if x != nil {
  792. return x.Items
  793. }
  794. return nil
  795. }
  796. func (x *InsertBatchRequest) GetUserID() string {
  797. if x != nil {
  798. return x.UserID
  799. }
  800. return ""
  801. }
  802. type InsertTableRowItem struct {
  803. state protoimpl.MessageState
  804. sizeCache protoimpl.SizeCache
  805. unknownFields protoimpl.UnknownFields
  806. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  807. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  808. KeyColumns []string `protobuf:"bytes,3,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
  809. TableRows []*TableRow `protobuf:"bytes,4,rep,name=TableRows,proto3" json:"TableRows,omitempty"`
  810. }
  811. func (x *InsertTableRowItem) Reset() {
  812. *x = InsertTableRowItem{}
  813. if protoimpl.UnsafeEnabled {
  814. mi := &file_v1_request_command_proto_msgTypes[13]
  815. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  816. ms.StoreMessageInfo(mi)
  817. }
  818. }
  819. func (x *InsertTableRowItem) String() string {
  820. return protoimpl.X.MessageStringOf(x)
  821. }
  822. func (*InsertTableRowItem) ProtoMessage() {}
  823. func (x *InsertTableRowItem) ProtoReflect() protoreflect.Message {
  824. mi := &file_v1_request_command_proto_msgTypes[13]
  825. if protoimpl.UnsafeEnabled && x != nil {
  826. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  827. if ms.LoadMessageInfo() == nil {
  828. ms.StoreMessageInfo(mi)
  829. }
  830. return ms
  831. }
  832. return mi.MessageOf(x)
  833. }
  834. // Deprecated: Use InsertTableRowItem.ProtoReflect.Descriptor instead.
  835. func (*InsertTableRowItem) Descriptor() ([]byte, []int) {
  836. return file_v1_request_command_proto_rawDescGZIP(), []int{13}
  837. }
  838. func (x *InsertTableRowItem) GetTablePrefixWithSchema() string {
  839. if x != nil {
  840. return x.TablePrefixWithSchema
  841. }
  842. return ""
  843. }
  844. func (x *InsertTableRowItem) GetVersion() string {
  845. if x != nil {
  846. return x.Version
  847. }
  848. return ""
  849. }
  850. func (x *InsertTableRowItem) GetKeyColumns() []string {
  851. if x != nil {
  852. return x.KeyColumns
  853. }
  854. return nil
  855. }
  856. func (x *InsertTableRowItem) GetTableRows() []*TableRow {
  857. if x != nil {
  858. return x.TableRows
  859. }
  860. return nil
  861. }
  862. type DeleteRequest struct {
  863. state protoimpl.MessageState
  864. sizeCache protoimpl.SizeCache
  865. unknownFields protoimpl.UnknownFields
  866. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  867. TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  868. Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
  869. KeyValues map[string]string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  870. UserID string `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
  871. }
  872. func (x *DeleteRequest) Reset() {
  873. *x = DeleteRequest{}
  874. if protoimpl.UnsafeEnabled {
  875. mi := &file_v1_request_command_proto_msgTypes[14]
  876. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  877. ms.StoreMessageInfo(mi)
  878. }
  879. }
  880. func (x *DeleteRequest) String() string {
  881. return protoimpl.X.MessageStringOf(x)
  882. }
  883. func (*DeleteRequest) ProtoMessage() {}
  884. func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
  885. mi := &file_v1_request_command_proto_msgTypes[14]
  886. if protoimpl.UnsafeEnabled && x != nil {
  887. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  888. if ms.LoadMessageInfo() == nil {
  889. ms.StoreMessageInfo(mi)
  890. }
  891. return ms
  892. }
  893. return mi.MessageOf(x)
  894. }
  895. // Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
  896. func (*DeleteRequest) Descriptor() ([]byte, []int) {
  897. return file_v1_request_command_proto_rawDescGZIP(), []int{14}
  898. }
  899. func (x *DeleteRequest) GetDatabaseID() string {
  900. if x != nil {
  901. return x.DatabaseID
  902. }
  903. return ""
  904. }
  905. func (x *DeleteRequest) GetTablePrefixWithSchema() string {
  906. if x != nil {
  907. return x.TablePrefixWithSchema
  908. }
  909. return ""
  910. }
  911. func (x *DeleteRequest) GetVersion() string {
  912. if x != nil {
  913. return x.Version
  914. }
  915. return ""
  916. }
  917. func (x *DeleteRequest) GetKeyValues() map[string]string {
  918. if x != nil {
  919. return x.KeyValues
  920. }
  921. return nil
  922. }
  923. func (x *DeleteRequest) GetUserID() string {
  924. if x != nil {
  925. return x.UserID
  926. }
  927. return ""
  928. }
  929. type DeleteWhereRequest struct {
  930. state protoimpl.MessageState
  931. sizeCache protoimpl.SizeCache
  932. unknownFields protoimpl.UnknownFields
  933. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  934. TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  935. Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
  936. KeyColumns []string `protobuf:"bytes,4,rep,name=KeyColumns,proto3" json:"KeyColumns,omitempty"`
  937. Where []byte `protobuf:"bytes,5,opt,name=Where,proto3" json:"Where,omitempty"`
  938. UserID string `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
  939. }
  940. func (x *DeleteWhereRequest) Reset() {
  941. *x = DeleteWhereRequest{}
  942. if protoimpl.UnsafeEnabled {
  943. mi := &file_v1_request_command_proto_msgTypes[15]
  944. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  945. ms.StoreMessageInfo(mi)
  946. }
  947. }
  948. func (x *DeleteWhereRequest) String() string {
  949. return protoimpl.X.MessageStringOf(x)
  950. }
  951. func (*DeleteWhereRequest) ProtoMessage() {}
  952. func (x *DeleteWhereRequest) ProtoReflect() protoreflect.Message {
  953. mi := &file_v1_request_command_proto_msgTypes[15]
  954. if protoimpl.UnsafeEnabled && x != nil {
  955. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  956. if ms.LoadMessageInfo() == nil {
  957. ms.StoreMessageInfo(mi)
  958. }
  959. return ms
  960. }
  961. return mi.MessageOf(x)
  962. }
  963. // Deprecated: Use DeleteWhereRequest.ProtoReflect.Descriptor instead.
  964. func (*DeleteWhereRequest) Descriptor() ([]byte, []int) {
  965. return file_v1_request_command_proto_rawDescGZIP(), []int{15}
  966. }
  967. func (x *DeleteWhereRequest) GetDatabaseID() string {
  968. if x != nil {
  969. return x.DatabaseID
  970. }
  971. return ""
  972. }
  973. func (x *DeleteWhereRequest) GetTablePrefixWithSchema() string {
  974. if x != nil {
  975. return x.TablePrefixWithSchema
  976. }
  977. return ""
  978. }
  979. func (x *DeleteWhereRequest) GetVersion() string {
  980. if x != nil {
  981. return x.Version
  982. }
  983. return ""
  984. }
  985. func (x *DeleteWhereRequest) GetKeyColumns() []string {
  986. if x != nil {
  987. return x.KeyColumns
  988. }
  989. return nil
  990. }
  991. func (x *DeleteWhereRequest) GetWhere() []byte {
  992. if x != nil {
  993. return x.Where
  994. }
  995. return nil
  996. }
  997. func (x *DeleteWhereRequest) GetUserID() string {
  998. if x != nil {
  999. return x.UserID
  1000. }
  1001. return ""
  1002. }
  1003. type DeleteBatchRequest struct {
  1004. state protoimpl.MessageState
  1005. sizeCache protoimpl.SizeCache
  1006. unknownFields protoimpl.UnknownFields
  1007. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  1008. Items []*DeleteTableRowItem `protobuf:"bytes,2,rep,name=Items,proto3" json:"Items,omitempty"`
  1009. UserID string `protobuf:"bytes,3,opt,name=UserID,proto3" json:"UserID,omitempty"`
  1010. }
  1011. func (x *DeleteBatchRequest) Reset() {
  1012. *x = DeleteBatchRequest{}
  1013. if protoimpl.UnsafeEnabled {
  1014. mi := &file_v1_request_command_proto_msgTypes[16]
  1015. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1016. ms.StoreMessageInfo(mi)
  1017. }
  1018. }
  1019. func (x *DeleteBatchRequest) String() string {
  1020. return protoimpl.X.MessageStringOf(x)
  1021. }
  1022. func (*DeleteBatchRequest) ProtoMessage() {}
  1023. func (x *DeleteBatchRequest) ProtoReflect() protoreflect.Message {
  1024. mi := &file_v1_request_command_proto_msgTypes[16]
  1025. if protoimpl.UnsafeEnabled && x != nil {
  1026. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1027. if ms.LoadMessageInfo() == nil {
  1028. ms.StoreMessageInfo(mi)
  1029. }
  1030. return ms
  1031. }
  1032. return mi.MessageOf(x)
  1033. }
  1034. // Deprecated: Use DeleteBatchRequest.ProtoReflect.Descriptor instead.
  1035. func (*DeleteBatchRequest) Descriptor() ([]byte, []int) {
  1036. return file_v1_request_command_proto_rawDescGZIP(), []int{16}
  1037. }
  1038. func (x *DeleteBatchRequest) GetDatabaseID() string {
  1039. if x != nil {
  1040. return x.DatabaseID
  1041. }
  1042. return ""
  1043. }
  1044. func (x *DeleteBatchRequest) GetItems() []*DeleteTableRowItem {
  1045. if x != nil {
  1046. return x.Items
  1047. }
  1048. return nil
  1049. }
  1050. func (x *DeleteBatchRequest) GetUserID() string {
  1051. if x != nil {
  1052. return x.UserID
  1053. }
  1054. return ""
  1055. }
  1056. type DeleteTableRowItem struct {
  1057. state protoimpl.MessageState
  1058. sizeCache protoimpl.SizeCache
  1059. unknownFields protoimpl.UnknownFields
  1060. TablePrefixWithSchema string `protobuf:"bytes,1,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  1061. Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
  1062. Items []*DeleteItem `protobuf:"bytes,3,rep,name=Items,proto3" json:"Items,omitempty"`
  1063. }
  1064. func (x *DeleteTableRowItem) Reset() {
  1065. *x = DeleteTableRowItem{}
  1066. if protoimpl.UnsafeEnabled {
  1067. mi := &file_v1_request_command_proto_msgTypes[17]
  1068. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1069. ms.StoreMessageInfo(mi)
  1070. }
  1071. }
  1072. func (x *DeleteTableRowItem) String() string {
  1073. return protoimpl.X.MessageStringOf(x)
  1074. }
  1075. func (*DeleteTableRowItem) ProtoMessage() {}
  1076. func (x *DeleteTableRowItem) ProtoReflect() protoreflect.Message {
  1077. mi := &file_v1_request_command_proto_msgTypes[17]
  1078. if protoimpl.UnsafeEnabled && x != nil {
  1079. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1080. if ms.LoadMessageInfo() == nil {
  1081. ms.StoreMessageInfo(mi)
  1082. }
  1083. return ms
  1084. }
  1085. return mi.MessageOf(x)
  1086. }
  1087. // Deprecated: Use DeleteTableRowItem.ProtoReflect.Descriptor instead.
  1088. func (*DeleteTableRowItem) Descriptor() ([]byte, []int) {
  1089. return file_v1_request_command_proto_rawDescGZIP(), []int{17}
  1090. }
  1091. func (x *DeleteTableRowItem) GetTablePrefixWithSchema() string {
  1092. if x != nil {
  1093. return x.TablePrefixWithSchema
  1094. }
  1095. return ""
  1096. }
  1097. func (x *DeleteTableRowItem) GetVersion() string {
  1098. if x != nil {
  1099. return x.Version
  1100. }
  1101. return ""
  1102. }
  1103. func (x *DeleteTableRowItem) GetItems() []*DeleteItem {
  1104. if x != nil {
  1105. return x.Items
  1106. }
  1107. return nil
  1108. }
  1109. type DeleteItem struct {
  1110. state protoimpl.MessageState
  1111. sizeCache protoimpl.SizeCache
  1112. unknownFields protoimpl.UnknownFields
  1113. KeyValues map[string]string `protobuf:"bytes,1,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  1114. }
  1115. func (x *DeleteItem) Reset() {
  1116. *x = DeleteItem{}
  1117. if protoimpl.UnsafeEnabled {
  1118. mi := &file_v1_request_command_proto_msgTypes[18]
  1119. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1120. ms.StoreMessageInfo(mi)
  1121. }
  1122. }
  1123. func (x *DeleteItem) String() string {
  1124. return protoimpl.X.MessageStringOf(x)
  1125. }
  1126. func (*DeleteItem) ProtoMessage() {}
  1127. func (x *DeleteItem) ProtoReflect() protoreflect.Message {
  1128. mi := &file_v1_request_command_proto_msgTypes[18]
  1129. if protoimpl.UnsafeEnabled && x != nil {
  1130. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1131. if ms.LoadMessageInfo() == nil {
  1132. ms.StoreMessageInfo(mi)
  1133. }
  1134. return ms
  1135. }
  1136. return mi.MessageOf(x)
  1137. }
  1138. // Deprecated: Use DeleteItem.ProtoReflect.Descriptor instead.
  1139. func (*DeleteItem) Descriptor() ([]byte, []int) {
  1140. return file_v1_request_command_proto_rawDescGZIP(), []int{18}
  1141. }
  1142. func (x *DeleteItem) GetKeyValues() map[string]string {
  1143. if x != nil {
  1144. return x.KeyValues
  1145. }
  1146. return nil
  1147. }
  1148. type UpdateRequest struct {
  1149. state protoimpl.MessageState
  1150. sizeCache protoimpl.SizeCache
  1151. unknownFields protoimpl.UnknownFields
  1152. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  1153. TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  1154. Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
  1155. KeyValues map[string]string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  1156. NewTableRow *TableRow `protobuf:"bytes,5,opt,name=NewTableRow,proto3" json:"NewTableRow,omitempty"`
  1157. UserID string `protobuf:"bytes,6,opt,name=UserID,proto3" json:"UserID,omitempty"`
  1158. }
  1159. func (x *UpdateRequest) Reset() {
  1160. *x = UpdateRequest{}
  1161. if protoimpl.UnsafeEnabled {
  1162. mi := &file_v1_request_command_proto_msgTypes[19]
  1163. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1164. ms.StoreMessageInfo(mi)
  1165. }
  1166. }
  1167. func (x *UpdateRequest) String() string {
  1168. return protoimpl.X.MessageStringOf(x)
  1169. }
  1170. func (*UpdateRequest) ProtoMessage() {}
  1171. func (x *UpdateRequest) ProtoReflect() protoreflect.Message {
  1172. mi := &file_v1_request_command_proto_msgTypes[19]
  1173. if protoimpl.UnsafeEnabled && x != nil {
  1174. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1175. if ms.LoadMessageInfo() == nil {
  1176. ms.StoreMessageInfo(mi)
  1177. }
  1178. return ms
  1179. }
  1180. return mi.MessageOf(x)
  1181. }
  1182. // Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
  1183. func (*UpdateRequest) Descriptor() ([]byte, []int) {
  1184. return file_v1_request_command_proto_rawDescGZIP(), []int{19}
  1185. }
  1186. func (x *UpdateRequest) GetDatabaseID() string {
  1187. if x != nil {
  1188. return x.DatabaseID
  1189. }
  1190. return ""
  1191. }
  1192. func (x *UpdateRequest) GetTablePrefixWithSchema() string {
  1193. if x != nil {
  1194. return x.TablePrefixWithSchema
  1195. }
  1196. return ""
  1197. }
  1198. func (x *UpdateRequest) GetVersion() string {
  1199. if x != nil {
  1200. return x.Version
  1201. }
  1202. return ""
  1203. }
  1204. func (x *UpdateRequest) GetKeyValues() map[string]string {
  1205. if x != nil {
  1206. return x.KeyValues
  1207. }
  1208. return nil
  1209. }
  1210. func (x *UpdateRequest) GetNewTableRow() *TableRow {
  1211. if x != nil {
  1212. return x.NewTableRow
  1213. }
  1214. return nil
  1215. }
  1216. func (x *UpdateRequest) GetUserID() string {
  1217. if x != nil {
  1218. return x.UserID
  1219. }
  1220. return ""
  1221. }
  1222. type ReplayRequest struct {
  1223. state protoimpl.MessageState
  1224. sizeCache protoimpl.SizeCache
  1225. unknownFields protoimpl.UnknownFields
  1226. DatabaseID string `protobuf:"bytes,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
  1227. TablePrefixWithSchema string `protobuf:"bytes,2,opt,name=TablePrefixWithSchema,proto3" json:"TablePrefixWithSchema,omitempty"`
  1228. Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
  1229. KeyValues map[string]string `protobuf:"bytes,4,rep,name=KeyValues,proto3" json:"KeyValues,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  1230. UserID string `protobuf:"bytes,5,opt,name=UserID,proto3" json:"UserID,omitempty"`
  1231. }
  1232. func (x *ReplayRequest) Reset() {
  1233. *x = ReplayRequest{}
  1234. if protoimpl.UnsafeEnabled {
  1235. mi := &file_v1_request_command_proto_msgTypes[20]
  1236. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1237. ms.StoreMessageInfo(mi)
  1238. }
  1239. }
  1240. func (x *ReplayRequest) String() string {
  1241. return protoimpl.X.MessageStringOf(x)
  1242. }
  1243. func (*ReplayRequest) ProtoMessage() {}
  1244. func (x *ReplayRequest) ProtoReflect() protoreflect.Message {
  1245. mi := &file_v1_request_command_proto_msgTypes[20]
  1246. if protoimpl.UnsafeEnabled && x != nil {
  1247. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1248. if ms.LoadMessageInfo() == nil {
  1249. ms.StoreMessageInfo(mi)
  1250. }
  1251. return ms
  1252. }
  1253. return mi.MessageOf(x)
  1254. }
  1255. // Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.
  1256. func (*ReplayRequest) Descriptor() ([]byte, []int) {
  1257. return file_v1_request_command_proto_rawDescGZIP(), []int{20}
  1258. }
  1259. func (x *ReplayRequest) GetDatabaseID() string {
  1260. if x != nil {
  1261. return x.DatabaseID
  1262. }
  1263. return ""
  1264. }
  1265. func (x *ReplayRequest) GetTablePrefixWithSchema() string {
  1266. if x != nil {
  1267. return x.TablePrefixWithSchema
  1268. }
  1269. return ""
  1270. }
  1271. func (x *ReplayRequest) GetVersion() string {
  1272. if x != nil {
  1273. return x.Version
  1274. }
  1275. return ""
  1276. }
  1277. func (x *ReplayRequest) GetKeyValues() map[string]string {
  1278. if x != nil {
  1279. return x.KeyValues
  1280. }
  1281. return nil
  1282. }
  1283. func (x *ReplayRequest) GetUserID() string {
  1284. if x != nil {
  1285. return x.UserID
  1286. }
  1287. return ""
  1288. }
  1289. type TableRow struct {
  1290. state protoimpl.MessageState
  1291. sizeCache protoimpl.SizeCache
  1292. unknownFields protoimpl.UnknownFields
  1293. Columns []*Column `protobuf:"bytes,1,rep,name=Columns,proto3" json:"Columns,omitempty"`
  1294. }
  1295. func (x *TableRow) Reset() {
  1296. *x = TableRow{}
  1297. if protoimpl.UnsafeEnabled {
  1298. mi := &file_v1_request_command_proto_msgTypes[21]
  1299. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1300. ms.StoreMessageInfo(mi)
  1301. }
  1302. }
  1303. func (x *TableRow) String() string {
  1304. return protoimpl.X.MessageStringOf(x)
  1305. }
  1306. func (*TableRow) ProtoMessage() {}
  1307. func (x *TableRow) ProtoReflect() protoreflect.Message {
  1308. mi := &file_v1_request_command_proto_msgTypes[21]
  1309. if protoimpl.UnsafeEnabled && x != nil {
  1310. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1311. if ms.LoadMessageInfo() == nil {
  1312. ms.StoreMessageInfo(mi)
  1313. }
  1314. return ms
  1315. }
  1316. return mi.MessageOf(x)
  1317. }
  1318. // Deprecated: Use TableRow.ProtoReflect.Descriptor instead.
  1319. func (*TableRow) Descriptor() ([]byte, []int) {
  1320. return file_v1_request_command_proto_rawDescGZIP(), []int{21}
  1321. }
  1322. func (x *TableRow) GetColumns() []*Column {
  1323. if x != nil {
  1324. return x.Columns
  1325. }
  1326. return nil
  1327. }
  1328. type Column struct {
  1329. state protoimpl.MessageState
  1330. sizeCache protoimpl.SizeCache
  1331. unknownFields protoimpl.UnknownFields
  1332. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
  1333. Value *ColumnValue `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
  1334. }
  1335. func (x *Column) Reset() {
  1336. *x = Column{}
  1337. if protoimpl.UnsafeEnabled {
  1338. mi := &file_v1_request_command_proto_msgTypes[22]
  1339. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1340. ms.StoreMessageInfo(mi)
  1341. }
  1342. }
  1343. func (x *Column) String() string {
  1344. return protoimpl.X.MessageStringOf(x)
  1345. }
  1346. func (*Column) ProtoMessage() {}
  1347. func (x *Column) ProtoReflect() protoreflect.Message {
  1348. mi := &file_v1_request_command_proto_msgTypes[22]
  1349. if protoimpl.UnsafeEnabled && x != nil {
  1350. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1351. if ms.LoadMessageInfo() == nil {
  1352. ms.StoreMessageInfo(mi)
  1353. }
  1354. return ms
  1355. }
  1356. return mi.MessageOf(x)
  1357. }
  1358. // Deprecated: Use Column.ProtoReflect.Descriptor instead.
  1359. func (*Column) Descriptor() ([]byte, []int) {
  1360. return file_v1_request_command_proto_rawDescGZIP(), []int{22}
  1361. }
  1362. func (x *Column) GetName() string {
  1363. if x != nil {
  1364. return x.Name
  1365. }
  1366. return ""
  1367. }
  1368. func (x *Column) GetValue() *ColumnValue {
  1369. if x != nil {
  1370. return x.Value
  1371. }
  1372. return nil
  1373. }
  1374. type ColumnValue struct {
  1375. state protoimpl.MessageState
  1376. sizeCache protoimpl.SizeCache
  1377. unknownFields protoimpl.UnknownFields
  1378. Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
  1379. // Types that are assignable to TypedValue:
  1380. //
  1381. // *ColumnValue_StringValue
  1382. // *ColumnValue_Uint64Value
  1383. // *ColumnValue_Float64Value
  1384. // *ColumnValue_BoolValue
  1385. TypedValue isColumnValue_TypedValue `protobuf_oneof:"TypedValue"`
  1386. }
  1387. func (x *ColumnValue) Reset() {
  1388. *x = ColumnValue{}
  1389. if protoimpl.UnsafeEnabled {
  1390. mi := &file_v1_request_command_proto_msgTypes[23]
  1391. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1392. ms.StoreMessageInfo(mi)
  1393. }
  1394. }
  1395. func (x *ColumnValue) String() string {
  1396. return protoimpl.X.MessageStringOf(x)
  1397. }
  1398. func (*ColumnValue) ProtoMessage() {}
  1399. func (x *ColumnValue) ProtoReflect() protoreflect.Message {
  1400. mi := &file_v1_request_command_proto_msgTypes[23]
  1401. if protoimpl.UnsafeEnabled && x != nil {
  1402. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1403. if ms.LoadMessageInfo() == nil {
  1404. ms.StoreMessageInfo(mi)
  1405. }
  1406. return ms
  1407. }
  1408. return mi.MessageOf(x)
  1409. }
  1410. // Deprecated: Use ColumnValue.ProtoReflect.Descriptor instead.
  1411. func (*ColumnValue) Descriptor() ([]byte, []int) {
  1412. return file_v1_request_command_proto_rawDescGZIP(), []int{23}
  1413. }
  1414. func (x *ColumnValue) GetType() string {
  1415. if x != nil {
  1416. return x.Type
  1417. }
  1418. return ""
  1419. }
  1420. func (m *ColumnValue) GetTypedValue() isColumnValue_TypedValue {
  1421. if m != nil {
  1422. return m.TypedValue
  1423. }
  1424. return nil
  1425. }
  1426. func (x *ColumnValue) GetStringValue() string {
  1427. if x, ok := x.GetTypedValue().(*ColumnValue_StringValue); ok {
  1428. return x.StringValue
  1429. }
  1430. return ""
  1431. }
  1432. func (x *ColumnValue) GetUint64Value() uint64 {
  1433. if x, ok := x.GetTypedValue().(*ColumnValue_Uint64Value); ok {
  1434. return x.Uint64Value
  1435. }
  1436. return 0
  1437. }
  1438. func (x *ColumnValue) GetFloat64Value() float64 {
  1439. if x, ok := x.GetTypedValue().(*ColumnValue_Float64Value); ok {
  1440. return x.Float64Value
  1441. }
  1442. return 0
  1443. }
  1444. func (x *ColumnValue) GetBoolValue() bool {
  1445. if x, ok := x.GetTypedValue().(*ColumnValue_BoolValue); ok {
  1446. return x.BoolValue
  1447. }
  1448. return false
  1449. }
  1450. type isColumnValue_TypedValue interface {
  1451. isColumnValue_TypedValue()
  1452. }
  1453. type ColumnValue_StringValue struct {
  1454. StringValue string `protobuf:"bytes,2,opt,name=StringValue,proto3,oneof"`
  1455. }
  1456. type ColumnValue_Uint64Value struct {
  1457. Uint64Value uint64 `protobuf:"varint,3,opt,name=Uint64Value,proto3,oneof"`
  1458. }
  1459. type ColumnValue_Float64Value struct {
  1460. Float64Value float64 `protobuf:"fixed64,4,opt,name=Float64Value,proto3,oneof"`
  1461. }
  1462. type ColumnValue_BoolValue struct {
  1463. BoolValue bool `protobuf:"varint,5,opt,name=BoolValue,proto3,oneof"`
  1464. }
  1465. func (*ColumnValue_StringValue) isColumnValue_TypedValue() {}
  1466. func (*ColumnValue_Uint64Value) isColumnValue_TypedValue() {}
  1467. func (*ColumnValue_Float64Value) isColumnValue_TypedValue() {}
  1468. func (*ColumnValue_BoolValue) isColumnValue_TypedValue() {}
  1469. var File_v1_request_command_proto protoreflect.FileDescriptor
  1470. var file_v1_request_command_proto_rawDesc = []byte{
  1471. 0x0a, 0x18, 0x76, 0x31, 0x2f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2f, 0x63, 0x6f, 0x6d,
  1472. 0x6d, 0x61, 0x6e, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x72, 0x65, 0x71, 0x75,
  1473. 0x65, 0x73, 0x74, 0x1a, 0x36, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
  1474. 0x6d, 0x77, 0x69, 0x74, 0x6b, 0x6f, 0x77, 0x2f, 0x67, 0x6f, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1475. 0x2d, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x6f, 0x72, 0x73, 0x2f, 0x76, 0x61, 0x6c, 0x69,
  1476. 0x64, 0x61, 0x74, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x74, 0x0a, 0x12, 0x41,
  1477. 0x75, 0x74, 0x6f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  1478. 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x18,
  1479. 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44,
  1480. 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x36, 0x0a, 0x05, 0x49, 0x74, 0x65,
  1481. 0x6d, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65,
  1482. 0x73, 0x74, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x49, 0x74,
  1483. 0x65, 0x6d, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d,
  1484. 0x73, 0x22, 0xa9, 0x01, 0x0a, 0x0f, 0x41, 0x75, 0x74, 0x6f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74,
  1485. 0x65, 0x49, 0x74, 0x65, 0x6d, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72,
  1486. 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01,
  1487. 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61,
  1488. 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68,
  1489. 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02,
  1490. 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65,
  1491. 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x36, 0x0a, 0x12, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f,
  1492. 0x64, 0x65, 0x6c, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28,
  1493. 0x0c, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x12, 0x54, 0x61, 0x62, 0x6c, 0x65,
  1494. 0x4d, 0x6f, 0x64, 0x65, 0x6c, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x22, 0x41, 0x0a,
  1495. 0x17, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x65, 0x67, 0x69,
  1496. 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61,
  1497. 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1498. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44,
  1499. 0x22, 0xe8, 0x01, 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x54, 0x78, 0x52, 0x65, 0x71,
  1500. 0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65,
  1501. 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20,
  1502. 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61, 0x62,
  1503. 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65,
  1504. 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20,
  1505. 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65, 0x72,
  1506. 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d,
  1507. 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00,
  1508. 0x52, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x35, 0x0a, 0x08,
  1509. 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11,
  1510. 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f,
  1511. 0x77, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x08, 0x54, 0x61, 0x62, 0x6c, 0x65,
  1512. 0x52, 0x6f, 0x77, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x05, 0x20,
  1513. 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x22, 0x69, 0x0a, 0x14, 0x49,
  1514. 0x6e, 0x73, 0x65, 0x72, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75,
  1515. 0x65, 0x73, 0x74, 0x12, 0x39, 0x0a, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03,
  1516. 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x6e, 0x73,
  1517. 0x65, 0x72, 0x74, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74, 0x65, 0x6d, 0x42,
  1518. 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x12, 0x16,
  1519. 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
  1520. 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x22, 0x96, 0x02, 0x0a, 0x0f, 0x44, 0x65, 0x6c, 0x65, 0x74,
  1521. 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61,
  1522. 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68,
  1523. 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1524. 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69,
  1525. 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73,
  1526. 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1527. 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4d, 0x0a, 0x09, 0x4b, 0x65,
  1528. 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x27, 0x2e,
  1529. 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x78,
  1530. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65,
  1531. 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x00, 0x52, 0x09,
  1532. 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65,
  1533. 0x72, 0x49, 0x44, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49,
  1534. 0x44, 0x1a, 0x3c, 0x0a, 0x0e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e,
  1535. 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
  1536. 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02,
  1537. 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22,
  1538. 0xcc, 0x01, 0x0a, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57, 0x68, 0x65, 0x72, 0x65, 0x54,
  1539. 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62, 0x6c,
  1540. 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1541. 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52,
  1542. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1543. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f,
  1544. 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52,
  1545. 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a, 0x0a, 0x4b, 0x65, 0x79, 0x43,
  1546. 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1547. 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73,
  1548. 0x12, 0x14, 0x0a, 0x05, 0x57, 0x68, 0x65, 0x72, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52,
  1549. 0x05, 0x57, 0x68, 0x65, 0x72, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44,
  1550. 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x22, 0x69,
  1551. 0x0a, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52,
  1552. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x39, 0x0a, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x18,
  1553. 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e,
  1554. 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74,
  1555. 0x65, 0x6d, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d,
  1556. 0x73, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28,
  1557. 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x22, 0xd3, 0x02, 0x0a, 0x0f, 0x55, 0x70,
  1558. 0x64, 0x61, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a,
  1559. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1560. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1561. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69,
  1562. 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56,
  1563. 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1564. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4d, 0x0a,
  1565. 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b,
  1566. 0x32, 0x27, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74,
  1567. 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61,
  1568. 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20,
  1569. 0x00, 0x52, 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x3b, 0x0a, 0x0b,
  1570. 0x4e, 0x65, 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x18, 0x04, 0x20, 0x01, 0x28,
  1571. 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x61, 0x62, 0x6c,
  1572. 0x65, 0x52, 0x6f, 0x77, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0b, 0x4e, 0x65,
  1573. 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65,
  1574. 0x72, 0x49, 0x44, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49,
  1575. 0x44, 0x1a, 0x3c, 0x0a, 0x0e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e,
  1576. 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
  1577. 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02,
  1578. 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22,
  1579. 0x17, 0x0a, 0x15, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x6e,
  1580. 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xa8, 0x05, 0x0a, 0x14, 0x54, 0x72, 0x61,
  1581. 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f,
  1582. 0x6e, 0x12, 0x5c, 0x0a, 0x17, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e,
  1583. 0x42, 0x65, 0x67, 0x69, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x01, 0x20, 0x01,
  1584. 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x72, 0x61,
  1585. 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x52, 0x65, 0x71,
  1586. 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52, 0x17, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74,
  1587. 0x69, 0x6f, 0x6e, 0x42, 0x65, 0x67, 0x69, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
  1588. 0x44, 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65,
  1589. 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65,
  1590. 0x73, 0x74, 0x2e, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65,
  1591. 0x73, 0x74, 0x48, 0x00, 0x52, 0x0f, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x54, 0x78, 0x52, 0x65,
  1592. 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x53, 0x0a, 0x14, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x42,
  1593. 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x03, 0x20,
  1594. 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x6e,
  1595. 0x73, 0x65, 0x72, 0x74, 0x42, 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65,
  1596. 0x73, 0x74, 0x48, 0x00, 0x52, 0x14, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x42, 0x61, 0x74, 0x63,
  1597. 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x0f, 0x44, 0x65,
  1598. 0x6c, 0x65, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x04, 0x20,
  1599. 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65,
  1600. 0x6c, 0x65, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52,
  1601. 0x0f, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1602. 0x12, 0x53, 0x0a, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57, 0x68, 0x65, 0x72, 0x65, 0x54,
  1603. 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d,
  1604. 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57,
  1605. 0x68, 0x65, 0x72, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52,
  1606. 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57, 0x68, 0x65, 0x72, 0x65, 0x54, 0x78, 0x52, 0x65,
  1607. 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x53, 0x0a, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x42,
  1608. 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x06, 0x20,
  1609. 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65,
  1610. 0x6c, 0x65, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65,
  1611. 0x73, 0x74, 0x48, 0x00, 0x52, 0x14, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63,
  1612. 0x68, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x0f, 0x55, 0x70,
  1613. 0x64, 0x61, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x07, 0x20,
  1614. 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x55, 0x70,
  1615. 0x64, 0x61, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x00, 0x52,
  1616. 0x0f, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1617. 0x12, 0x56, 0x0a, 0x15, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45,
  1618. 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1619. 0x1e, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61,
  1620. 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48,
  1621. 0x00, 0x52, 0x15, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x6e,
  1622. 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x42, 0x09, 0x0a, 0x07, 0x52, 0x65, 0x71, 0x75,
  1623. 0x65, 0x73, 0x74, 0x22, 0x8e, 0x02, 0x0a, 0x0d, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x52, 0x65,
  1624. 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73,
  1625. 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1626. 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x3c, 0x0a,
  1627. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1628. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1629. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69,
  1630. 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56,
  1631. 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1632. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a,
  1633. 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28,
  1634. 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f,
  1635. 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x35, 0x0a, 0x08, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f,
  1636. 0x77, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73,
  1637. 0x74, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02,
  1638. 0x70, 0x00, 0x52, 0x08, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x16, 0x0a, 0x06,
  1639. 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73,
  1640. 0x65, 0x72, 0x49, 0x44, 0x22, 0x8f, 0x01, 0x0a, 0x12, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x42,
  1641. 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44,
  1642. 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42,
  1643. 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73,
  1644. 0x65, 0x49, 0x44, 0x12, 0x39, 0x0a, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x03,
  1645. 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x6e, 0x73,
  1646. 0x65, 0x72, 0x74, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74, 0x65, 0x6d, 0x42,
  1647. 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x12, 0x16,
  1648. 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
  1649. 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x22, 0xd5, 0x01, 0x0a, 0x12, 0x49, 0x6e, 0x73, 0x65, 0x72,
  1650. 0x74, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74, 0x65, 0x6d, 0x12, 0x3c, 0x0a,
  1651. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1652. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1653. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69,
  1654. 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56,
  1655. 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1656. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a,
  1657. 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28,
  1658. 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f,
  1659. 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x09, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f,
  1660. 0x77, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65,
  1661. 0x73, 0x74, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x42, 0x06, 0xe2, 0xdf, 0x1f,
  1662. 0x02, 0x70, 0x00, 0x52, 0x09, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x73, 0x22, 0xba,
  1663. 0x02, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1664. 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x18, 0x01,
  1665. 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44, 0x61,
  1666. 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62, 0x6c,
  1667. 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d,
  1668. 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52,
  1669. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1670. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f,
  1671. 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52,
  1672. 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4b, 0x0a, 0x09, 0x4b, 0x65, 0x79, 0x56,
  1673. 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x72, 0x65,
  1674. 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75,
  1675. 0x65, 0x73, 0x74, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74,
  1676. 0x72, 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x00, 0x52, 0x09, 0x4b, 0x65, 0x79, 0x56,
  1677. 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18,
  1678. 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x1a, 0x3c, 0x0a,
  1679. 0x0e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12,
  1680. 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65,
  1681. 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
  1682. 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xf2, 0x01, 0x0a, 0x12,
  1683. 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57, 0x68, 0x65, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
  1684. 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44,
  1685. 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a,
  1686. 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61,
  1687. 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68,
  1688. 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1689. 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69,
  1690. 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73,
  1691. 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1692. 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a, 0x0a, 0x4b, 0x65,
  1693. 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x42, 0x06,
  1694. 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0a, 0x4b, 0x65, 0x79, 0x43, 0x6f, 0x6c, 0x75, 0x6d,
  1695. 0x6e, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x57, 0x68, 0x65, 0x72, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28,
  1696. 0x0c, 0x52, 0x05, 0x57, 0x68, 0x65, 0x72, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72,
  1697. 0x49, 0x44, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44,
  1698. 0x22, 0x8f, 0x01, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68,
  1699. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62,
  1700. 0x61, 0x73, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f,
  1701. 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12,
  1702. 0x39, 0x0a, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1b,
  1703. 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54,
  1704. 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74, 0x65, 0x6d, 0x42, 0x06, 0xe2, 0xdf, 0x1f,
  1705. 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73,
  1706. 0x65, 0x72, 0x49, 0x44, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72,
  1707. 0x49, 0x44, 0x22, 0xa7, 0x01, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x62,
  1708. 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x49, 0x74, 0x65, 0x6d, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62,
  1709. 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65,
  1710. 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01,
  1711. 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74,
  1712. 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69,
  1713. 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01,
  1714. 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x31, 0x0a, 0x05, 0x49, 0x74, 0x65,
  1715. 0x6d, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65,
  1716. 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x42, 0x06, 0xe2,
  1717. 0xdf, 0x1f, 0x02, 0x60, 0x01, 0x52, 0x05, 0x49, 0x74, 0x65, 0x6d, 0x73, 0x22, 0x94, 0x01, 0x0a,
  1718. 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x12, 0x48, 0x0a, 0x09, 0x4b,
  1719. 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22,
  1720. 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49,
  1721. 0x74, 0x65, 0x6d, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74,
  1722. 0x72, 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x00, 0x52, 0x09, 0x4b, 0x65, 0x79, 0x56,
  1723. 0x61, 0x6c, 0x75, 0x65, 0x73, 0x1a, 0x3c, 0x0a, 0x0e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75,
  1724. 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01,
  1725. 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c,
  1726. 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a,
  1727. 0x02, 0x38, 0x01, 0x22, 0xf7, 0x02, 0x0a, 0x0d, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65,
  1728. 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73,
  1729. 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58,
  1730. 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x3c, 0x0a,
  1731. 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68,
  1732. 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1733. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69,
  1734. 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56,
  1735. 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf,
  1736. 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4b, 0x0a,
  1737. 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b,
  1738. 0x32, 0x25, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74,
  1739. 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75,
  1740. 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x00, 0x52,
  1741. 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x3b, 0x0a, 0x0b, 0x4e, 0x65,
  1742. 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1743. 0x11, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52,
  1744. 0x6f, 0x77, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x70, 0x00, 0x52, 0x0b, 0x4e, 0x65, 0x77, 0x54,
  1745. 0x61, 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49,
  1746. 0x44, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x1a,
  1747. 0x3c, 0x0a, 0x0e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72,
  1748. 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
  1749. 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01,
  1750. 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xba, 0x02,
  1751. 0x0a, 0x0d, 0x52, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
  1752. 0x26, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20,
  1753. 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x0a, 0x44, 0x61, 0x74,
  1754. 0x61, 0x62, 0x61, 0x73, 0x65, 0x49, 0x44, 0x12, 0x3c, 0x0a, 0x15, 0x54, 0x61, 0x62, 0x6c, 0x65,
  1755. 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1756. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x15,
  1757. 0x54, 0x61, 0x62, 0x6c, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x57, 0x69, 0x74, 0x68, 0x53,
  1758. 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x20, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
  1759. 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x58, 0x01, 0x52, 0x07,
  1760. 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x4b, 0x0a, 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61,
  1761. 0x6c, 0x75, 0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x72, 0x65, 0x71,
  1762. 0x75, 0x65, 0x73, 0x74, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65,
  1763. 0x73, 0x74, 0x2e, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72,
  1764. 0x79, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x00, 0x52, 0x09, 0x4b, 0x65, 0x79, 0x56, 0x61,
  1765. 0x6c, 0x75, 0x65, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x18, 0x05,
  1766. 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x55, 0x73, 0x65, 0x72, 0x49, 0x44, 0x1a, 0x3c, 0x0a, 0x0e,
  1767. 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10,
  1768. 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79,
  1769. 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
  1770. 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x35, 0x0a, 0x08, 0x54, 0x61,
  1771. 0x62, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x29, 0x0a, 0x07, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e,
  1772. 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73,
  1773. 0x74, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x07, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e,
  1774. 0x73, 0x22, 0x48, 0x0a, 0x06, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x4e,
  1775. 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x12,
  1776. 0x2a, 0x0a, 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14,
  1777. 0x2e, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x56,
  1778. 0x61, 0x6c, 0x75, 0x65, 0x52, 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x22, 0xbd, 0x01, 0x0a, 0x0b,
  1779. 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x54,
  1780. 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12,
  1781. 0x22, 0x0a, 0x0b, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02,
  1782. 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0b, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 0x61,
  1783. 0x6c, 0x75, 0x65, 0x12, 0x22, 0x0a, 0x0b, 0x55, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c,
  1784. 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x0b, 0x55, 0x69, 0x6e, 0x74,
  1785. 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x24, 0x0a, 0x0c, 0x46, 0x6c, 0x6f, 0x61, 0x74,
  1786. 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x01, 0x48, 0x00, 0x52,
  1787. 0x0c, 0x46, 0x6c, 0x6f, 0x61, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1e, 0x0a,
  1788. 0x09, 0x42, 0x6f, 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08,
  1789. 0x48, 0x00, 0x52, 0x09, 0x42, 0x6f, 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x0c, 0x0a,
  1790. 0x0a, 0x54, 0x79, 0x70, 0x65, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x20, 0x5a, 0x1e, 0x64,
  1791. 0x70, 0x73, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x61, 0x70, 0x69, 0x2f,
  1792. 0x70, 0x62, 0x2f, 0x76, 0x31, 0x2f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x62, 0x06, 0x70,
  1793. 0x72, 0x6f, 0x74, 0x6f, 0x33,
  1794. }
  1795. var (
  1796. file_v1_request_command_proto_rawDescOnce sync.Once
  1797. file_v1_request_command_proto_rawDescData = file_v1_request_command_proto_rawDesc
  1798. )
  1799. func file_v1_request_command_proto_rawDescGZIP() []byte {
  1800. file_v1_request_command_proto_rawDescOnce.Do(func() {
  1801. file_v1_request_command_proto_rawDescData = protoimpl.X.CompressGZIP(file_v1_request_command_proto_rawDescData)
  1802. })
  1803. return file_v1_request_command_proto_rawDescData
  1804. }
  1805. var file_v1_request_command_proto_msgTypes = make([]protoimpl.MessageInfo, 30)
  1806. var file_v1_request_command_proto_goTypes = []interface{}{
  1807. (*AutoMigrateRequest)(nil), // 0: request.AutoMigrateRequest
  1808. (*AutoMigrateItem)(nil), // 1: request.AutoMigrateItem
  1809. (*TransactionBeginRequest)(nil), // 2: request.TransactionBeginRequest
  1810. (*InsertTxRequest)(nil), // 3: request.InsertTxRequest
  1811. (*InsertBatchTxRequest)(nil), // 4: request.InsertBatchTxRequest
  1812. (*DeleteTxRequest)(nil), // 5: request.DeleteTxRequest
  1813. (*DeleteWhereTxRequest)(nil), // 6: request.DeleteWhereTxRequest
  1814. (*DeleteBatchTxRequest)(nil), // 7: request.DeleteBatchTxRequest
  1815. (*UpdateTxRequest)(nil), // 8: request.UpdateTxRequest
  1816. (*TransactionEndRequest)(nil), // 9: request.TransactionEndRequest
  1817. (*TransactionOperation)(nil), // 10: request.TransactionOperation
  1818. (*InsertRequest)(nil), // 11: request.InsertRequest
  1819. (*InsertBatchRequest)(nil), // 12: request.InsertBatchRequest
  1820. (*InsertTableRowItem)(nil), // 13: request.InsertTableRowItem
  1821. (*DeleteRequest)(nil), // 14: request.DeleteRequest
  1822. (*DeleteWhereRequest)(nil), // 15: request.DeleteWhereRequest
  1823. (*DeleteBatchRequest)(nil), // 16: request.DeleteBatchRequest
  1824. (*DeleteTableRowItem)(nil), // 17: request.DeleteTableRowItem
  1825. (*DeleteItem)(nil), // 18: request.DeleteItem
  1826. (*UpdateRequest)(nil), // 19: request.UpdateRequest
  1827. (*ReplayRequest)(nil), // 20: request.ReplayRequest
  1828. (*TableRow)(nil), // 21: request.TableRow
  1829. (*Column)(nil), // 22: request.Column
  1830. (*ColumnValue)(nil), // 23: request.ColumnValue
  1831. nil, // 24: request.DeleteTxRequest.KeyValuesEntry
  1832. nil, // 25: request.UpdateTxRequest.KeyValuesEntry
  1833. nil, // 26: request.DeleteRequest.KeyValuesEntry
  1834. nil, // 27: request.DeleteItem.KeyValuesEntry
  1835. nil, // 28: request.UpdateRequest.KeyValuesEntry
  1836. nil, // 29: request.ReplayRequest.KeyValuesEntry
  1837. }
  1838. var file_v1_request_command_proto_depIdxs = []int32{
  1839. 1, // 0: request.AutoMigrateRequest.Items:type_name -> request.AutoMigrateItem
  1840. 21, // 1: request.InsertTxRequest.TableRow:type_name -> request.TableRow
  1841. 13, // 2: request.InsertBatchTxRequest.Items:type_name -> request.InsertTableRowItem
  1842. 24, // 3: request.DeleteTxRequest.KeyValues:type_name -> request.DeleteTxRequest.KeyValuesEntry
  1843. 17, // 4: request.DeleteBatchTxRequest.Items:type_name -> request.DeleteTableRowItem
  1844. 25, // 5: request.UpdateTxRequest.KeyValues:type_name -> request.UpdateTxRequest.KeyValuesEntry
  1845. 21, // 6: request.UpdateTxRequest.NewTableRow:type_name -> request.TableRow
  1846. 2, // 7: request.TransactionOperation.TransactionBeginRequest:type_name -> request.TransactionBeginRequest
  1847. 3, // 8: request.TransactionOperation.InsertTxRequest:type_name -> request.InsertTxRequest
  1848. 4, // 9: request.TransactionOperation.InsertBatchTxRequest:type_name -> request.InsertBatchTxRequest
  1849. 5, // 10: request.TransactionOperation.DeleteTxRequest:type_name -> request.DeleteTxRequest
  1850. 6, // 11: request.TransactionOperation.DeleteWhereTxRequest:type_name -> request.DeleteWhereTxRequest
  1851. 7, // 12: request.TransactionOperation.DeleteBatchTxRequest:type_name -> request.DeleteBatchTxRequest
  1852. 8, // 13: request.TransactionOperation.UpdateTxRequest:type_name -> request.UpdateTxRequest
  1853. 9, // 14: request.TransactionOperation.TransactionEndRequest:type_name -> request.TransactionEndRequest
  1854. 21, // 15: request.InsertRequest.TableRow:type_name -> request.TableRow
  1855. 13, // 16: request.InsertBatchRequest.Items:type_name -> request.InsertTableRowItem
  1856. 21, // 17: request.InsertTableRowItem.TableRows:type_name -> request.TableRow
  1857. 26, // 18: request.DeleteRequest.KeyValues:type_name -> request.DeleteRequest.KeyValuesEntry
  1858. 17, // 19: request.DeleteBatchRequest.Items:type_name -> request.DeleteTableRowItem
  1859. 18, // 20: request.DeleteTableRowItem.Items:type_name -> request.DeleteItem
  1860. 27, // 21: request.DeleteItem.KeyValues:type_name -> request.DeleteItem.KeyValuesEntry
  1861. 28, // 22: request.UpdateRequest.KeyValues:type_name -> request.UpdateRequest.KeyValuesEntry
  1862. 21, // 23: request.UpdateRequest.NewTableRow:type_name -> request.TableRow
  1863. 29, // 24: request.ReplayRequest.KeyValues:type_name -> request.ReplayRequest.KeyValuesEntry
  1864. 22, // 25: request.TableRow.Columns:type_name -> request.Column
  1865. 23, // 26: request.Column.Value:type_name -> request.ColumnValue
  1866. 27, // [27:27] is the sub-list for method output_type
  1867. 27, // [27:27] is the sub-list for method input_type
  1868. 27, // [27:27] is the sub-list for extension type_name
  1869. 27, // [27:27] is the sub-list for extension extendee
  1870. 0, // [0:27] is the sub-list for field type_name
  1871. }
  1872. func init() { file_v1_request_command_proto_init() }
  1873. func file_v1_request_command_proto_init() {
  1874. if File_v1_request_command_proto != nil {
  1875. return
  1876. }
  1877. if !protoimpl.UnsafeEnabled {
  1878. file_v1_request_command_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1879. switch v := v.(*AutoMigrateRequest); i {
  1880. case 0:
  1881. return &v.state
  1882. case 1:
  1883. return &v.sizeCache
  1884. case 2:
  1885. return &v.unknownFields
  1886. default:
  1887. return nil
  1888. }
  1889. }
  1890. file_v1_request_command_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1891. switch v := v.(*AutoMigrateItem); i {
  1892. case 0:
  1893. return &v.state
  1894. case 1:
  1895. return &v.sizeCache
  1896. case 2:
  1897. return &v.unknownFields
  1898. default:
  1899. return nil
  1900. }
  1901. }
  1902. file_v1_request_command_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1903. switch v := v.(*TransactionBeginRequest); i {
  1904. case 0:
  1905. return &v.state
  1906. case 1:
  1907. return &v.sizeCache
  1908. case 2:
  1909. return &v.unknownFields
  1910. default:
  1911. return nil
  1912. }
  1913. }
  1914. file_v1_request_command_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1915. switch v := v.(*InsertTxRequest); i {
  1916. case 0:
  1917. return &v.state
  1918. case 1:
  1919. return &v.sizeCache
  1920. case 2:
  1921. return &v.unknownFields
  1922. default:
  1923. return nil
  1924. }
  1925. }
  1926. file_v1_request_command_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1927. switch v := v.(*InsertBatchTxRequest); i {
  1928. case 0:
  1929. return &v.state
  1930. case 1:
  1931. return &v.sizeCache
  1932. case 2:
  1933. return &v.unknownFields
  1934. default:
  1935. return nil
  1936. }
  1937. }
  1938. file_v1_request_command_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1939. switch v := v.(*DeleteTxRequest); i {
  1940. case 0:
  1941. return &v.state
  1942. case 1:
  1943. return &v.sizeCache
  1944. case 2:
  1945. return &v.unknownFields
  1946. default:
  1947. return nil
  1948. }
  1949. }
  1950. file_v1_request_command_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1951. switch v := v.(*DeleteWhereTxRequest); i {
  1952. case 0:
  1953. return &v.state
  1954. case 1:
  1955. return &v.sizeCache
  1956. case 2:
  1957. return &v.unknownFields
  1958. default:
  1959. return nil
  1960. }
  1961. }
  1962. file_v1_request_command_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1963. switch v := v.(*DeleteBatchTxRequest); i {
  1964. case 0:
  1965. return &v.state
  1966. case 1:
  1967. return &v.sizeCache
  1968. case 2:
  1969. return &v.unknownFields
  1970. default:
  1971. return nil
  1972. }
  1973. }
  1974. file_v1_request_command_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1975. switch v := v.(*UpdateTxRequest); i {
  1976. case 0:
  1977. return &v.state
  1978. case 1:
  1979. return &v.sizeCache
  1980. case 2:
  1981. return &v.unknownFields
  1982. default:
  1983. return nil
  1984. }
  1985. }
  1986. file_v1_request_command_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1987. switch v := v.(*TransactionEndRequest); i {
  1988. case 0:
  1989. return &v.state
  1990. case 1:
  1991. return &v.sizeCache
  1992. case 2:
  1993. return &v.unknownFields
  1994. default:
  1995. return nil
  1996. }
  1997. }
  1998. file_v1_request_command_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1999. switch v := v.(*TransactionOperation); i {
  2000. case 0:
  2001. return &v.state
  2002. case 1:
  2003. return &v.sizeCache
  2004. case 2:
  2005. return &v.unknownFields
  2006. default:
  2007. return nil
  2008. }
  2009. }
  2010. file_v1_request_command_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  2011. switch v := v.(*InsertRequest); i {
  2012. case 0:
  2013. return &v.state
  2014. case 1:
  2015. return &v.sizeCache
  2016. case 2:
  2017. return &v.unknownFields
  2018. default:
  2019. return nil
  2020. }
  2021. }
  2022. file_v1_request_command_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  2023. switch v := v.(*InsertBatchRequest); i {
  2024. case 0:
  2025. return &v.state
  2026. case 1:
  2027. return &v.sizeCache
  2028. case 2:
  2029. return &v.unknownFields
  2030. default:
  2031. return nil
  2032. }
  2033. }
  2034. file_v1_request_command_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  2035. switch v := v.(*InsertTableRowItem); i {
  2036. case 0:
  2037. return &v.state
  2038. case 1:
  2039. return &v.sizeCache
  2040. case 2:
  2041. return &v.unknownFields
  2042. default:
  2043. return nil
  2044. }
  2045. }
  2046. file_v1_request_command_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  2047. switch v := v.(*DeleteRequest); i {
  2048. case 0:
  2049. return &v.state
  2050. case 1:
  2051. return &v.sizeCache
  2052. case 2:
  2053. return &v.unknownFields
  2054. default:
  2055. return nil
  2056. }
  2057. }
  2058. file_v1_request_command_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  2059. switch v := v.(*DeleteWhereRequest); i {
  2060. case 0:
  2061. return &v.state
  2062. case 1:
  2063. return &v.sizeCache
  2064. case 2:
  2065. return &v.unknownFields
  2066. default:
  2067. return nil
  2068. }
  2069. }
  2070. file_v1_request_command_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
  2071. switch v := v.(*DeleteBatchRequest); i {
  2072. case 0:
  2073. return &v.state
  2074. case 1:
  2075. return &v.sizeCache
  2076. case 2:
  2077. return &v.unknownFields
  2078. default:
  2079. return nil
  2080. }
  2081. }
  2082. file_v1_request_command_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
  2083. switch v := v.(*DeleteTableRowItem); i {
  2084. case 0:
  2085. return &v.state
  2086. case 1:
  2087. return &v.sizeCache
  2088. case 2:
  2089. return &v.unknownFields
  2090. default:
  2091. return nil
  2092. }
  2093. }
  2094. file_v1_request_command_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
  2095. switch v := v.(*DeleteItem); i {
  2096. case 0:
  2097. return &v.state
  2098. case 1:
  2099. return &v.sizeCache
  2100. case 2:
  2101. return &v.unknownFields
  2102. default:
  2103. return nil
  2104. }
  2105. }
  2106. file_v1_request_command_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
  2107. switch v := v.(*UpdateRequest); i {
  2108. case 0:
  2109. return &v.state
  2110. case 1:
  2111. return &v.sizeCache
  2112. case 2:
  2113. return &v.unknownFields
  2114. default:
  2115. return nil
  2116. }
  2117. }
  2118. file_v1_request_command_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
  2119. switch v := v.(*ReplayRequest); i {
  2120. case 0:
  2121. return &v.state
  2122. case 1:
  2123. return &v.sizeCache
  2124. case 2:
  2125. return &v.unknownFields
  2126. default:
  2127. return nil
  2128. }
  2129. }
  2130. file_v1_request_command_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
  2131. switch v := v.(*TableRow); i {
  2132. case 0:
  2133. return &v.state
  2134. case 1:
  2135. return &v.sizeCache
  2136. case 2:
  2137. return &v.unknownFields
  2138. default:
  2139. return nil
  2140. }
  2141. }
  2142. file_v1_request_command_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
  2143. switch v := v.(*Column); i {
  2144. case 0:
  2145. return &v.state
  2146. case 1:
  2147. return &v.sizeCache
  2148. case 2:
  2149. return &v.unknownFields
  2150. default:
  2151. return nil
  2152. }
  2153. }
  2154. file_v1_request_command_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
  2155. switch v := v.(*ColumnValue); i {
  2156. case 0:
  2157. return &v.state
  2158. case 1:
  2159. return &v.sizeCache
  2160. case 2:
  2161. return &v.unknownFields
  2162. default:
  2163. return nil
  2164. }
  2165. }
  2166. }
  2167. file_v1_request_command_proto_msgTypes[10].OneofWrappers = []interface{}{
  2168. (*TransactionOperation_TransactionBeginRequest)(nil),
  2169. (*TransactionOperation_InsertTxRequest)(nil),
  2170. (*TransactionOperation_InsertBatchTxRequest)(nil),
  2171. (*TransactionOperation_DeleteTxRequest)(nil),
  2172. (*TransactionOperation_DeleteWhereTxRequest)(nil),
  2173. (*TransactionOperation_DeleteBatchTxRequest)(nil),
  2174. (*TransactionOperation_UpdateTxRequest)(nil),
  2175. (*TransactionOperation_TransactionEndRequest)(nil),
  2176. }
  2177. file_v1_request_command_proto_msgTypes[23].OneofWrappers = []interface{}{
  2178. (*ColumnValue_StringValue)(nil),
  2179. (*ColumnValue_Uint64Value)(nil),
  2180. (*ColumnValue_Float64Value)(nil),
  2181. (*ColumnValue_BoolValue)(nil),
  2182. }
  2183. type x struct{}
  2184. out := protoimpl.TypeBuilder{
  2185. File: protoimpl.DescBuilder{
  2186. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  2187. RawDescriptor: file_v1_request_command_proto_rawDesc,
  2188. NumEnums: 0,
  2189. NumMessages: 30,
  2190. NumExtensions: 0,
  2191. NumServices: 0,
  2192. },
  2193. GoTypes: file_v1_request_command_proto_goTypes,
  2194. DependencyIndexes: file_v1_request_command_proto_depIdxs,
  2195. MessageInfos: file_v1_request_command_proto_msgTypes,
  2196. }.Build()
  2197. File_v1_request_command_proto = out.File
  2198. file_v1_request_command_proto_rawDesc = nil
  2199. file_v1_request_command_proto_goTypes = nil
  2200. file_v1_request_command_proto_depIdxs = nil
  2201. }