SentryPolicyService.py 62 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921
  1. #
  2. # Autogenerated by Thrift Compiler (0.9.0)
  3. #
  4. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5. #
  6. # options string: py:new_style
  7. #
  8. from thrift.Thrift import TType, TMessageType, TException, TApplicationException
  9. from ttypes import *
  10. from thrift.Thrift import TProcessor
  11. from thrift.transport import TTransport
  12. from thrift.protocol import TBinaryProtocol, TProtocol
  13. try:
  14. from thrift.protocol import fastbinary
  15. except:
  16. fastbinary = None
  17. class Iface(object):
  18. def create_sentry_role(self, request):
  19. """
  20. Parameters:
  21. - request
  22. """
  23. pass
  24. def drop_sentry_role(self, request):
  25. """
  26. Parameters:
  27. - request
  28. """
  29. pass
  30. def alter_sentry_role_grant_privilege(self, request):
  31. """
  32. Parameters:
  33. - request
  34. """
  35. pass
  36. def alter_sentry_role_revoke_privilege(self, request):
  37. """
  38. Parameters:
  39. - request
  40. """
  41. pass
  42. def alter_sentry_role_add_groups(self, request):
  43. """
  44. Parameters:
  45. - request
  46. """
  47. pass
  48. def alter_sentry_role_delete_groups(self, request):
  49. """
  50. Parameters:
  51. - request
  52. """
  53. pass
  54. def list_sentry_roles_by_group(self, request):
  55. """
  56. Parameters:
  57. - request
  58. """
  59. pass
  60. def list_sentry_privileges_by_role(self, request):
  61. """
  62. Parameters:
  63. - request
  64. """
  65. pass
  66. def list_sentry_privileges_for_provider(self, request):
  67. """
  68. Parameters:
  69. - request
  70. """
  71. pass
  72. def drop_sentry_privilege(self, request):
  73. """
  74. Parameters:
  75. - request
  76. """
  77. pass
  78. def rename_sentry_privilege(self, request):
  79. """
  80. Parameters:
  81. - request
  82. """
  83. pass
  84. class Client(Iface):
  85. def __init__(self, iprot, oprot=None):
  86. self._iprot = self._oprot = iprot
  87. if oprot is not None:
  88. self._oprot = oprot
  89. self._seqid = 0
  90. def create_sentry_role(self, request):
  91. """
  92. Parameters:
  93. - request
  94. """
  95. self.send_create_sentry_role(request)
  96. return self.recv_create_sentry_role()
  97. def send_create_sentry_role(self, request):
  98. self._oprot.writeMessageBegin('create_sentry_role', TMessageType.CALL, self._seqid)
  99. args = create_sentry_role_args()
  100. args.request = request
  101. args.write(self._oprot)
  102. self._oprot.writeMessageEnd()
  103. self._oprot.trans.flush()
  104. def recv_create_sentry_role(self, ):
  105. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  106. if mtype == TMessageType.EXCEPTION:
  107. x = TApplicationException()
  108. x.read(self._iprot)
  109. self._iprot.readMessageEnd()
  110. raise x
  111. result = create_sentry_role_result()
  112. result.read(self._iprot)
  113. self._iprot.readMessageEnd()
  114. if result.success is not None:
  115. return result.success
  116. raise TApplicationException(TApplicationException.MISSING_RESULT, "create_sentry_role failed: unknown result");
  117. def drop_sentry_role(self, request):
  118. """
  119. Parameters:
  120. - request
  121. """
  122. self.send_drop_sentry_role(request)
  123. return self.recv_drop_sentry_role()
  124. def send_drop_sentry_role(self, request):
  125. self._oprot.writeMessageBegin('drop_sentry_role', TMessageType.CALL, self._seqid)
  126. args = drop_sentry_role_args()
  127. args.request = request
  128. args.write(self._oprot)
  129. self._oprot.writeMessageEnd()
  130. self._oprot.trans.flush()
  131. def recv_drop_sentry_role(self, ):
  132. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  133. if mtype == TMessageType.EXCEPTION:
  134. x = TApplicationException()
  135. x.read(self._iprot)
  136. self._iprot.readMessageEnd()
  137. raise x
  138. result = drop_sentry_role_result()
  139. result.read(self._iprot)
  140. self._iprot.readMessageEnd()
  141. if result.success is not None:
  142. return result.success
  143. raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_sentry_role failed: unknown result");
  144. def alter_sentry_role_grant_privilege(self, request):
  145. """
  146. Parameters:
  147. - request
  148. """
  149. self.send_alter_sentry_role_grant_privilege(request)
  150. return self.recv_alter_sentry_role_grant_privilege()
  151. def send_alter_sentry_role_grant_privilege(self, request):
  152. self._oprot.writeMessageBegin('alter_sentry_role_grant_privilege', TMessageType.CALL, self._seqid)
  153. args = alter_sentry_role_grant_privilege_args()
  154. args.request = request
  155. args.write(self._oprot)
  156. self._oprot.writeMessageEnd()
  157. self._oprot.trans.flush()
  158. def recv_alter_sentry_role_grant_privilege(self, ):
  159. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  160. if mtype == TMessageType.EXCEPTION:
  161. x = TApplicationException()
  162. x.read(self._iprot)
  163. self._iprot.readMessageEnd()
  164. raise x
  165. result = alter_sentry_role_grant_privilege_result()
  166. result.read(self._iprot)
  167. self._iprot.readMessageEnd()
  168. if result.success is not None:
  169. return result.success
  170. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_grant_privilege failed: unknown result");
  171. def alter_sentry_role_revoke_privilege(self, request):
  172. """
  173. Parameters:
  174. - request
  175. """
  176. self.send_alter_sentry_role_revoke_privilege(request)
  177. return self.recv_alter_sentry_role_revoke_privilege()
  178. def send_alter_sentry_role_revoke_privilege(self, request):
  179. self._oprot.writeMessageBegin('alter_sentry_role_revoke_privilege', TMessageType.CALL, self._seqid)
  180. args = alter_sentry_role_revoke_privilege_args()
  181. args.request = request
  182. args.write(self._oprot)
  183. self._oprot.writeMessageEnd()
  184. self._oprot.trans.flush()
  185. def recv_alter_sentry_role_revoke_privilege(self, ):
  186. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  187. if mtype == TMessageType.EXCEPTION:
  188. x = TApplicationException()
  189. x.read(self._iprot)
  190. self._iprot.readMessageEnd()
  191. raise x
  192. result = alter_sentry_role_revoke_privilege_result()
  193. result.read(self._iprot)
  194. self._iprot.readMessageEnd()
  195. if result.success is not None:
  196. return result.success
  197. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_revoke_privilege failed: unknown result");
  198. def alter_sentry_role_add_groups(self, request):
  199. """
  200. Parameters:
  201. - request
  202. """
  203. self.send_alter_sentry_role_add_groups(request)
  204. return self.recv_alter_sentry_role_add_groups()
  205. def send_alter_sentry_role_add_groups(self, request):
  206. self._oprot.writeMessageBegin('alter_sentry_role_add_groups', TMessageType.CALL, self._seqid)
  207. args = alter_sentry_role_add_groups_args()
  208. args.request = request
  209. args.write(self._oprot)
  210. self._oprot.writeMessageEnd()
  211. self._oprot.trans.flush()
  212. def recv_alter_sentry_role_add_groups(self, ):
  213. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  214. if mtype == TMessageType.EXCEPTION:
  215. x = TApplicationException()
  216. x.read(self._iprot)
  217. self._iprot.readMessageEnd()
  218. raise x
  219. result = alter_sentry_role_add_groups_result()
  220. result.read(self._iprot)
  221. self._iprot.readMessageEnd()
  222. if result.success is not None:
  223. return result.success
  224. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_add_groups failed: unknown result");
  225. def alter_sentry_role_delete_groups(self, request):
  226. """
  227. Parameters:
  228. - request
  229. """
  230. self.send_alter_sentry_role_delete_groups(request)
  231. return self.recv_alter_sentry_role_delete_groups()
  232. def send_alter_sentry_role_delete_groups(self, request):
  233. self._oprot.writeMessageBegin('alter_sentry_role_delete_groups', TMessageType.CALL, self._seqid)
  234. args = alter_sentry_role_delete_groups_args()
  235. args.request = request
  236. args.write(self._oprot)
  237. self._oprot.writeMessageEnd()
  238. self._oprot.trans.flush()
  239. def recv_alter_sentry_role_delete_groups(self, ):
  240. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  241. if mtype == TMessageType.EXCEPTION:
  242. x = TApplicationException()
  243. x.read(self._iprot)
  244. self._iprot.readMessageEnd()
  245. raise x
  246. result = alter_sentry_role_delete_groups_result()
  247. result.read(self._iprot)
  248. self._iprot.readMessageEnd()
  249. if result.success is not None:
  250. return result.success
  251. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_delete_groups failed: unknown result");
  252. def list_sentry_roles_by_group(self, request):
  253. """
  254. Parameters:
  255. - request
  256. """
  257. self.send_list_sentry_roles_by_group(request)
  258. return self.recv_list_sentry_roles_by_group()
  259. def send_list_sentry_roles_by_group(self, request):
  260. self._oprot.writeMessageBegin('list_sentry_roles_by_group', TMessageType.CALL, self._seqid)
  261. args = list_sentry_roles_by_group_args()
  262. args.request = request
  263. args.write(self._oprot)
  264. self._oprot.writeMessageEnd()
  265. self._oprot.trans.flush()
  266. def recv_list_sentry_roles_by_group(self, ):
  267. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  268. if mtype == TMessageType.EXCEPTION:
  269. x = TApplicationException()
  270. x.read(self._iprot)
  271. self._iprot.readMessageEnd()
  272. raise x
  273. result = list_sentry_roles_by_group_result()
  274. result.read(self._iprot)
  275. self._iprot.readMessageEnd()
  276. if result.success is not None:
  277. return result.success
  278. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_roles_by_group failed: unknown result");
  279. def list_sentry_privileges_by_role(self, request):
  280. """
  281. Parameters:
  282. - request
  283. """
  284. self.send_list_sentry_privileges_by_role(request)
  285. return self.recv_list_sentry_privileges_by_role()
  286. def send_list_sentry_privileges_by_role(self, request):
  287. self._oprot.writeMessageBegin('list_sentry_privileges_by_role', TMessageType.CALL, self._seqid)
  288. args = list_sentry_privileges_by_role_args()
  289. args.request = request
  290. args.write(self._oprot)
  291. self._oprot.writeMessageEnd()
  292. self._oprot.trans.flush()
  293. def recv_list_sentry_privileges_by_role(self, ):
  294. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  295. if mtype == TMessageType.EXCEPTION:
  296. x = TApplicationException()
  297. x.read(self._iprot)
  298. self._iprot.readMessageEnd()
  299. raise x
  300. result = list_sentry_privileges_by_role_result()
  301. result.read(self._iprot)
  302. self._iprot.readMessageEnd()
  303. if result.success is not None:
  304. return result.success
  305. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_by_role failed: unknown result");
  306. def list_sentry_privileges_for_provider(self, request):
  307. """
  308. Parameters:
  309. - request
  310. """
  311. self.send_list_sentry_privileges_for_provider(request)
  312. return self.recv_list_sentry_privileges_for_provider()
  313. def send_list_sentry_privileges_for_provider(self, request):
  314. self._oprot.writeMessageBegin('list_sentry_privileges_for_provider', TMessageType.CALL, self._seqid)
  315. args = list_sentry_privileges_for_provider_args()
  316. args.request = request
  317. args.write(self._oprot)
  318. self._oprot.writeMessageEnd()
  319. self._oprot.trans.flush()
  320. def recv_list_sentry_privileges_for_provider(self, ):
  321. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  322. if mtype == TMessageType.EXCEPTION:
  323. x = TApplicationException()
  324. x.read(self._iprot)
  325. self._iprot.readMessageEnd()
  326. raise x
  327. result = list_sentry_privileges_for_provider_result()
  328. result.read(self._iprot)
  329. self._iprot.readMessageEnd()
  330. if result.success is not None:
  331. return result.success
  332. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_for_provider failed: unknown result");
  333. def drop_sentry_privilege(self, request):
  334. """
  335. Parameters:
  336. - request
  337. """
  338. self.send_drop_sentry_privilege(request)
  339. return self.recv_drop_sentry_privilege()
  340. def send_drop_sentry_privilege(self, request):
  341. self._oprot.writeMessageBegin('drop_sentry_privilege', TMessageType.CALL, self._seqid)
  342. args = drop_sentry_privilege_args()
  343. args.request = request
  344. args.write(self._oprot)
  345. self._oprot.writeMessageEnd()
  346. self._oprot.trans.flush()
  347. def recv_drop_sentry_privilege(self, ):
  348. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  349. if mtype == TMessageType.EXCEPTION:
  350. x = TApplicationException()
  351. x.read(self._iprot)
  352. self._iprot.readMessageEnd()
  353. raise x
  354. result = drop_sentry_privilege_result()
  355. result.read(self._iprot)
  356. self._iprot.readMessageEnd()
  357. if result.success is not None:
  358. return result.success
  359. raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_sentry_privilege failed: unknown result");
  360. def rename_sentry_privilege(self, request):
  361. """
  362. Parameters:
  363. - request
  364. """
  365. self.send_rename_sentry_privilege(request)
  366. return self.recv_rename_sentry_privilege()
  367. def send_rename_sentry_privilege(self, request):
  368. self._oprot.writeMessageBegin('rename_sentry_privilege', TMessageType.CALL, self._seqid)
  369. args = rename_sentry_privilege_args()
  370. args.request = request
  371. args.write(self._oprot)
  372. self._oprot.writeMessageEnd()
  373. self._oprot.trans.flush()
  374. def recv_rename_sentry_privilege(self, ):
  375. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  376. if mtype == TMessageType.EXCEPTION:
  377. x = TApplicationException()
  378. x.read(self._iprot)
  379. self._iprot.readMessageEnd()
  380. raise x
  381. result = rename_sentry_privilege_result()
  382. result.read(self._iprot)
  383. self._iprot.readMessageEnd()
  384. if result.success is not None:
  385. return result.success
  386. raise TApplicationException(TApplicationException.MISSING_RESULT, "rename_sentry_privilege failed: unknown result");
  387. class Processor(Iface, TProcessor):
  388. def __init__(self, handler):
  389. self._handler = handler
  390. self._processMap = {}
  391. self._processMap["create_sentry_role"] = Processor.process_create_sentry_role
  392. self._processMap["drop_sentry_role"] = Processor.process_drop_sentry_role
  393. self._processMap["alter_sentry_role_grant_privilege"] = Processor.process_alter_sentry_role_grant_privilege
  394. self._processMap["alter_sentry_role_revoke_privilege"] = Processor.process_alter_sentry_role_revoke_privilege
  395. self._processMap["alter_sentry_role_add_groups"] = Processor.process_alter_sentry_role_add_groups
  396. self._processMap["alter_sentry_role_delete_groups"] = Processor.process_alter_sentry_role_delete_groups
  397. self._processMap["list_sentry_roles_by_group"] = Processor.process_list_sentry_roles_by_group
  398. self._processMap["list_sentry_privileges_by_role"] = Processor.process_list_sentry_privileges_by_role
  399. self._processMap["list_sentry_privileges_for_provider"] = Processor.process_list_sentry_privileges_for_provider
  400. self._processMap["drop_sentry_privilege"] = Processor.process_drop_sentry_privilege
  401. self._processMap["rename_sentry_privilege"] = Processor.process_rename_sentry_privilege
  402. def process(self, iprot, oprot):
  403. (name, type, seqid) = iprot.readMessageBegin()
  404. if name not in self._processMap:
  405. iprot.skip(TType.STRUCT)
  406. iprot.readMessageEnd()
  407. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  408. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  409. x.write(oprot)
  410. oprot.writeMessageEnd()
  411. oprot.trans.flush()
  412. return
  413. else:
  414. self._processMap[name](self, seqid, iprot, oprot)
  415. return True
  416. def process_create_sentry_role(self, seqid, iprot, oprot):
  417. args = create_sentry_role_args()
  418. args.read(iprot)
  419. iprot.readMessageEnd()
  420. result = create_sentry_role_result()
  421. result.success = self._handler.create_sentry_role(args.request)
  422. oprot.writeMessageBegin("create_sentry_role", TMessageType.REPLY, seqid)
  423. result.write(oprot)
  424. oprot.writeMessageEnd()
  425. oprot.trans.flush()
  426. def process_drop_sentry_role(self, seqid, iprot, oprot):
  427. args = drop_sentry_role_args()
  428. args.read(iprot)
  429. iprot.readMessageEnd()
  430. result = drop_sentry_role_result()
  431. result.success = self._handler.drop_sentry_role(args.request)
  432. oprot.writeMessageBegin("drop_sentry_role", TMessageType.REPLY, seqid)
  433. result.write(oprot)
  434. oprot.writeMessageEnd()
  435. oprot.trans.flush()
  436. def process_alter_sentry_role_grant_privilege(self, seqid, iprot, oprot):
  437. args = alter_sentry_role_grant_privilege_args()
  438. args.read(iprot)
  439. iprot.readMessageEnd()
  440. result = alter_sentry_role_grant_privilege_result()
  441. result.success = self._handler.alter_sentry_role_grant_privilege(args.request)
  442. oprot.writeMessageBegin("alter_sentry_role_grant_privilege", TMessageType.REPLY, seqid)
  443. result.write(oprot)
  444. oprot.writeMessageEnd()
  445. oprot.trans.flush()
  446. def process_alter_sentry_role_revoke_privilege(self, seqid, iprot, oprot):
  447. args = alter_sentry_role_revoke_privilege_args()
  448. args.read(iprot)
  449. iprot.readMessageEnd()
  450. result = alter_sentry_role_revoke_privilege_result()
  451. result.success = self._handler.alter_sentry_role_revoke_privilege(args.request)
  452. oprot.writeMessageBegin("alter_sentry_role_revoke_privilege", TMessageType.REPLY, seqid)
  453. result.write(oprot)
  454. oprot.writeMessageEnd()
  455. oprot.trans.flush()
  456. def process_alter_sentry_role_add_groups(self, seqid, iprot, oprot):
  457. args = alter_sentry_role_add_groups_args()
  458. args.read(iprot)
  459. iprot.readMessageEnd()
  460. result = alter_sentry_role_add_groups_result()
  461. result.success = self._handler.alter_sentry_role_add_groups(args.request)
  462. oprot.writeMessageBegin("alter_sentry_role_add_groups", TMessageType.REPLY, seqid)
  463. result.write(oprot)
  464. oprot.writeMessageEnd()
  465. oprot.trans.flush()
  466. def process_alter_sentry_role_delete_groups(self, seqid, iprot, oprot):
  467. args = alter_sentry_role_delete_groups_args()
  468. args.read(iprot)
  469. iprot.readMessageEnd()
  470. result = alter_sentry_role_delete_groups_result()
  471. result.success = self._handler.alter_sentry_role_delete_groups(args.request)
  472. oprot.writeMessageBegin("alter_sentry_role_delete_groups", TMessageType.REPLY, seqid)
  473. result.write(oprot)
  474. oprot.writeMessageEnd()
  475. oprot.trans.flush()
  476. def process_list_sentry_roles_by_group(self, seqid, iprot, oprot):
  477. args = list_sentry_roles_by_group_args()
  478. args.read(iprot)
  479. iprot.readMessageEnd()
  480. result = list_sentry_roles_by_group_result()
  481. result.success = self._handler.list_sentry_roles_by_group(args.request)
  482. oprot.writeMessageBegin("list_sentry_roles_by_group", TMessageType.REPLY, seqid)
  483. result.write(oprot)
  484. oprot.writeMessageEnd()
  485. oprot.trans.flush()
  486. def process_list_sentry_privileges_by_role(self, seqid, iprot, oprot):
  487. args = list_sentry_privileges_by_role_args()
  488. args.read(iprot)
  489. iprot.readMessageEnd()
  490. result = list_sentry_privileges_by_role_result()
  491. result.success = self._handler.list_sentry_privileges_by_role(args.request)
  492. oprot.writeMessageBegin("list_sentry_privileges_by_role", TMessageType.REPLY, seqid)
  493. result.write(oprot)
  494. oprot.writeMessageEnd()
  495. oprot.trans.flush()
  496. def process_list_sentry_privileges_for_provider(self, seqid, iprot, oprot):
  497. args = list_sentry_privileges_for_provider_args()
  498. args.read(iprot)
  499. iprot.readMessageEnd()
  500. result = list_sentry_privileges_for_provider_result()
  501. result.success = self._handler.list_sentry_privileges_for_provider(args.request)
  502. oprot.writeMessageBegin("list_sentry_privileges_for_provider", TMessageType.REPLY, seqid)
  503. result.write(oprot)
  504. oprot.writeMessageEnd()
  505. oprot.trans.flush()
  506. def process_drop_sentry_privilege(self, seqid, iprot, oprot):
  507. args = drop_sentry_privilege_args()
  508. args.read(iprot)
  509. iprot.readMessageEnd()
  510. result = drop_sentry_privilege_result()
  511. result.success = self._handler.drop_sentry_privilege(args.request)
  512. oprot.writeMessageBegin("drop_sentry_privilege", TMessageType.REPLY, seqid)
  513. result.write(oprot)
  514. oprot.writeMessageEnd()
  515. oprot.trans.flush()
  516. def process_rename_sentry_privilege(self, seqid, iprot, oprot):
  517. args = rename_sentry_privilege_args()
  518. args.read(iprot)
  519. iprot.readMessageEnd()
  520. result = rename_sentry_privilege_result()
  521. result.success = self._handler.rename_sentry_privilege(args.request)
  522. oprot.writeMessageBegin("rename_sentry_privilege", TMessageType.REPLY, seqid)
  523. result.write(oprot)
  524. oprot.writeMessageEnd()
  525. oprot.trans.flush()
  526. # HELPER FUNCTIONS AND STRUCTURES
  527. class create_sentry_role_args(object):
  528. """
  529. Attributes:
  530. - request
  531. """
  532. thrift_spec = (
  533. None, # 0
  534. (1, TType.STRUCT, 'request', (TCreateSentryRoleRequest, TCreateSentryRoleRequest.thrift_spec), None, ), # 1
  535. )
  536. def __init__(self, request=None,):
  537. self.request = request
  538. def read(self, iprot):
  539. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  540. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  541. return
  542. iprot.readStructBegin()
  543. while True:
  544. (fname, ftype, fid) = iprot.readFieldBegin()
  545. if ftype == TType.STOP:
  546. break
  547. if fid == 1:
  548. if ftype == TType.STRUCT:
  549. self.request = TCreateSentryRoleRequest()
  550. self.request.read(iprot)
  551. else:
  552. iprot.skip(ftype)
  553. else:
  554. iprot.skip(ftype)
  555. iprot.readFieldEnd()
  556. iprot.readStructEnd()
  557. def write(self, oprot):
  558. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  559. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  560. return
  561. oprot.writeStructBegin('create_sentry_role_args')
  562. if self.request is not None:
  563. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  564. self.request.write(oprot)
  565. oprot.writeFieldEnd()
  566. oprot.writeFieldStop()
  567. oprot.writeStructEnd()
  568. def validate(self):
  569. return
  570. def __repr__(self):
  571. L = ['%s=%r' % (key, value)
  572. for key, value in self.__dict__.iteritems()]
  573. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  574. def __eq__(self, other):
  575. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  576. def __ne__(self, other):
  577. return not (self == other)
  578. class create_sentry_role_result(object):
  579. """
  580. Attributes:
  581. - success
  582. """
  583. thrift_spec = (
  584. (0, TType.STRUCT, 'success', (TCreateSentryRoleResponse, TCreateSentryRoleResponse.thrift_spec), None, ), # 0
  585. )
  586. def __init__(self, success=None,):
  587. self.success = success
  588. def read(self, iprot):
  589. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  590. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  591. return
  592. iprot.readStructBegin()
  593. while True:
  594. (fname, ftype, fid) = iprot.readFieldBegin()
  595. if ftype == TType.STOP:
  596. break
  597. if fid == 0:
  598. if ftype == TType.STRUCT:
  599. self.success = TCreateSentryRoleResponse()
  600. self.success.read(iprot)
  601. else:
  602. iprot.skip(ftype)
  603. else:
  604. iprot.skip(ftype)
  605. iprot.readFieldEnd()
  606. iprot.readStructEnd()
  607. def write(self, oprot):
  608. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  609. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  610. return
  611. oprot.writeStructBegin('create_sentry_role_result')
  612. if self.success is not None:
  613. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  614. self.success.write(oprot)
  615. oprot.writeFieldEnd()
  616. oprot.writeFieldStop()
  617. oprot.writeStructEnd()
  618. def validate(self):
  619. return
  620. def __repr__(self):
  621. L = ['%s=%r' % (key, value)
  622. for key, value in self.__dict__.iteritems()]
  623. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  624. def __eq__(self, other):
  625. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  626. def __ne__(self, other):
  627. return not (self == other)
  628. class drop_sentry_role_args(object):
  629. """
  630. Attributes:
  631. - request
  632. """
  633. thrift_spec = (
  634. None, # 0
  635. (1, TType.STRUCT, 'request', (TDropSentryRoleRequest, TDropSentryRoleRequest.thrift_spec), None, ), # 1
  636. )
  637. def __init__(self, request=None,):
  638. self.request = request
  639. def read(self, iprot):
  640. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  641. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  642. return
  643. iprot.readStructBegin()
  644. while True:
  645. (fname, ftype, fid) = iprot.readFieldBegin()
  646. if ftype == TType.STOP:
  647. break
  648. if fid == 1:
  649. if ftype == TType.STRUCT:
  650. self.request = TDropSentryRoleRequest()
  651. self.request.read(iprot)
  652. else:
  653. iprot.skip(ftype)
  654. else:
  655. iprot.skip(ftype)
  656. iprot.readFieldEnd()
  657. iprot.readStructEnd()
  658. def write(self, oprot):
  659. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  660. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  661. return
  662. oprot.writeStructBegin('drop_sentry_role_args')
  663. if self.request is not None:
  664. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  665. self.request.write(oprot)
  666. oprot.writeFieldEnd()
  667. oprot.writeFieldStop()
  668. oprot.writeStructEnd()
  669. def validate(self):
  670. return
  671. def __repr__(self):
  672. L = ['%s=%r' % (key, value)
  673. for key, value in self.__dict__.iteritems()]
  674. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  675. def __eq__(self, other):
  676. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  677. def __ne__(self, other):
  678. return not (self == other)
  679. class drop_sentry_role_result(object):
  680. """
  681. Attributes:
  682. - success
  683. """
  684. thrift_spec = (
  685. (0, TType.STRUCT, 'success', (TDropSentryRoleResponse, TDropSentryRoleResponse.thrift_spec), None, ), # 0
  686. )
  687. def __init__(self, success=None,):
  688. self.success = success
  689. def read(self, iprot):
  690. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  691. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  692. return
  693. iprot.readStructBegin()
  694. while True:
  695. (fname, ftype, fid) = iprot.readFieldBegin()
  696. if ftype == TType.STOP:
  697. break
  698. if fid == 0:
  699. if ftype == TType.STRUCT:
  700. self.success = TDropSentryRoleResponse()
  701. self.success.read(iprot)
  702. else:
  703. iprot.skip(ftype)
  704. else:
  705. iprot.skip(ftype)
  706. iprot.readFieldEnd()
  707. iprot.readStructEnd()
  708. def write(self, oprot):
  709. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  710. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  711. return
  712. oprot.writeStructBegin('drop_sentry_role_result')
  713. if self.success is not None:
  714. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  715. self.success.write(oprot)
  716. oprot.writeFieldEnd()
  717. oprot.writeFieldStop()
  718. oprot.writeStructEnd()
  719. def validate(self):
  720. return
  721. def __repr__(self):
  722. L = ['%s=%r' % (key, value)
  723. for key, value in self.__dict__.iteritems()]
  724. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  725. def __eq__(self, other):
  726. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  727. def __ne__(self, other):
  728. return not (self == other)
  729. class alter_sentry_role_grant_privilege_args(object):
  730. """
  731. Attributes:
  732. - request
  733. """
  734. thrift_spec = (
  735. None, # 0
  736. (1, TType.STRUCT, 'request', (TAlterSentryRoleGrantPrivilegeRequest, TAlterSentryRoleGrantPrivilegeRequest.thrift_spec), None, ), # 1
  737. )
  738. def __init__(self, request=None,):
  739. self.request = request
  740. def read(self, iprot):
  741. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  742. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  743. return
  744. iprot.readStructBegin()
  745. while True:
  746. (fname, ftype, fid) = iprot.readFieldBegin()
  747. if ftype == TType.STOP:
  748. break
  749. if fid == 1:
  750. if ftype == TType.STRUCT:
  751. self.request = TAlterSentryRoleGrantPrivilegeRequest()
  752. self.request.read(iprot)
  753. else:
  754. iprot.skip(ftype)
  755. else:
  756. iprot.skip(ftype)
  757. iprot.readFieldEnd()
  758. iprot.readStructEnd()
  759. def write(self, oprot):
  760. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  761. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  762. return
  763. oprot.writeStructBegin('alter_sentry_role_grant_privilege_args')
  764. if self.request is not None:
  765. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  766. self.request.write(oprot)
  767. oprot.writeFieldEnd()
  768. oprot.writeFieldStop()
  769. oprot.writeStructEnd()
  770. def validate(self):
  771. return
  772. def __repr__(self):
  773. L = ['%s=%r' % (key, value)
  774. for key, value in self.__dict__.iteritems()]
  775. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  776. def __eq__(self, other):
  777. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  778. def __ne__(self, other):
  779. return not (self == other)
  780. class alter_sentry_role_grant_privilege_result(object):
  781. """
  782. Attributes:
  783. - success
  784. """
  785. thrift_spec = (
  786. (0, TType.STRUCT, 'success', (TAlterSentryRoleGrantPrivilegeResponse, TAlterSentryRoleGrantPrivilegeResponse.thrift_spec), None, ), # 0
  787. )
  788. def __init__(self, success=None,):
  789. self.success = success
  790. def read(self, iprot):
  791. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  792. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  793. return
  794. iprot.readStructBegin()
  795. while True:
  796. (fname, ftype, fid) = iprot.readFieldBegin()
  797. if ftype == TType.STOP:
  798. break
  799. if fid == 0:
  800. if ftype == TType.STRUCT:
  801. self.success = TAlterSentryRoleGrantPrivilegeResponse()
  802. self.success.read(iprot)
  803. else:
  804. iprot.skip(ftype)
  805. else:
  806. iprot.skip(ftype)
  807. iprot.readFieldEnd()
  808. iprot.readStructEnd()
  809. def write(self, oprot):
  810. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  811. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  812. return
  813. oprot.writeStructBegin('alter_sentry_role_grant_privilege_result')
  814. if self.success is not None:
  815. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  816. self.success.write(oprot)
  817. oprot.writeFieldEnd()
  818. oprot.writeFieldStop()
  819. oprot.writeStructEnd()
  820. def validate(self):
  821. return
  822. def __repr__(self):
  823. L = ['%s=%r' % (key, value)
  824. for key, value in self.__dict__.iteritems()]
  825. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  826. def __eq__(self, other):
  827. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  828. def __ne__(self, other):
  829. return not (self == other)
  830. class alter_sentry_role_revoke_privilege_args(object):
  831. """
  832. Attributes:
  833. - request
  834. """
  835. thrift_spec = (
  836. None, # 0
  837. (1, TType.STRUCT, 'request', (TAlterSentryRoleRevokePrivilegeRequest, TAlterSentryRoleRevokePrivilegeRequest.thrift_spec), None, ), # 1
  838. )
  839. def __init__(self, request=None,):
  840. self.request = request
  841. def read(self, iprot):
  842. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  843. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  844. return
  845. iprot.readStructBegin()
  846. while True:
  847. (fname, ftype, fid) = iprot.readFieldBegin()
  848. if ftype == TType.STOP:
  849. break
  850. if fid == 1:
  851. if ftype == TType.STRUCT:
  852. self.request = TAlterSentryRoleRevokePrivilegeRequest()
  853. self.request.read(iprot)
  854. else:
  855. iprot.skip(ftype)
  856. else:
  857. iprot.skip(ftype)
  858. iprot.readFieldEnd()
  859. iprot.readStructEnd()
  860. def write(self, oprot):
  861. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  862. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  863. return
  864. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_args')
  865. if self.request is not None:
  866. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  867. self.request.write(oprot)
  868. oprot.writeFieldEnd()
  869. oprot.writeFieldStop()
  870. oprot.writeStructEnd()
  871. def validate(self):
  872. return
  873. def __repr__(self):
  874. L = ['%s=%r' % (key, value)
  875. for key, value in self.__dict__.iteritems()]
  876. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  877. def __eq__(self, other):
  878. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  879. def __ne__(self, other):
  880. return not (self == other)
  881. class alter_sentry_role_revoke_privilege_result(object):
  882. """
  883. Attributes:
  884. - success
  885. """
  886. thrift_spec = (
  887. (0, TType.STRUCT, 'success', (TAlterSentryRoleRevokePrivilegeResponse, TAlterSentryRoleRevokePrivilegeResponse.thrift_spec), None, ), # 0
  888. )
  889. def __init__(self, success=None,):
  890. self.success = success
  891. def read(self, iprot):
  892. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  893. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  894. return
  895. iprot.readStructBegin()
  896. while True:
  897. (fname, ftype, fid) = iprot.readFieldBegin()
  898. if ftype == TType.STOP:
  899. break
  900. if fid == 0:
  901. if ftype == TType.STRUCT:
  902. self.success = TAlterSentryRoleRevokePrivilegeResponse()
  903. self.success.read(iprot)
  904. else:
  905. iprot.skip(ftype)
  906. else:
  907. iprot.skip(ftype)
  908. iprot.readFieldEnd()
  909. iprot.readStructEnd()
  910. def write(self, oprot):
  911. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  912. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  913. return
  914. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_result')
  915. if self.success is not None:
  916. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  917. self.success.write(oprot)
  918. oprot.writeFieldEnd()
  919. oprot.writeFieldStop()
  920. oprot.writeStructEnd()
  921. def validate(self):
  922. return
  923. def __repr__(self):
  924. L = ['%s=%r' % (key, value)
  925. for key, value in self.__dict__.iteritems()]
  926. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  927. def __eq__(self, other):
  928. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  929. def __ne__(self, other):
  930. return not (self == other)
  931. class alter_sentry_role_add_groups_args(object):
  932. """
  933. Attributes:
  934. - request
  935. """
  936. thrift_spec = (
  937. None, # 0
  938. (1, TType.STRUCT, 'request', (TAlterSentryRoleAddGroupsRequest, TAlterSentryRoleAddGroupsRequest.thrift_spec), None, ), # 1
  939. )
  940. def __init__(self, request=None,):
  941. self.request = request
  942. def read(self, iprot):
  943. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  944. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  945. return
  946. iprot.readStructBegin()
  947. while True:
  948. (fname, ftype, fid) = iprot.readFieldBegin()
  949. if ftype == TType.STOP:
  950. break
  951. if fid == 1:
  952. if ftype == TType.STRUCT:
  953. self.request = TAlterSentryRoleAddGroupsRequest()
  954. self.request.read(iprot)
  955. else:
  956. iprot.skip(ftype)
  957. else:
  958. iprot.skip(ftype)
  959. iprot.readFieldEnd()
  960. iprot.readStructEnd()
  961. def write(self, oprot):
  962. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  963. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  964. return
  965. oprot.writeStructBegin('alter_sentry_role_add_groups_args')
  966. if self.request is not None:
  967. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  968. self.request.write(oprot)
  969. oprot.writeFieldEnd()
  970. oprot.writeFieldStop()
  971. oprot.writeStructEnd()
  972. def validate(self):
  973. return
  974. def __repr__(self):
  975. L = ['%s=%r' % (key, value)
  976. for key, value in self.__dict__.iteritems()]
  977. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  978. def __eq__(self, other):
  979. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  980. def __ne__(self, other):
  981. return not (self == other)
  982. class alter_sentry_role_add_groups_result(object):
  983. """
  984. Attributes:
  985. - success
  986. """
  987. thrift_spec = (
  988. (0, TType.STRUCT, 'success', (TAlterSentryRoleAddGroupsResponse, TAlterSentryRoleAddGroupsResponse.thrift_spec), None, ), # 0
  989. )
  990. def __init__(self, success=None,):
  991. self.success = success
  992. def read(self, iprot):
  993. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  994. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  995. return
  996. iprot.readStructBegin()
  997. while True:
  998. (fname, ftype, fid) = iprot.readFieldBegin()
  999. if ftype == TType.STOP:
  1000. break
  1001. if fid == 0:
  1002. if ftype == TType.STRUCT:
  1003. self.success = TAlterSentryRoleAddGroupsResponse()
  1004. self.success.read(iprot)
  1005. else:
  1006. iprot.skip(ftype)
  1007. else:
  1008. iprot.skip(ftype)
  1009. iprot.readFieldEnd()
  1010. iprot.readStructEnd()
  1011. def write(self, oprot):
  1012. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1013. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1014. return
  1015. oprot.writeStructBegin('alter_sentry_role_add_groups_result')
  1016. if self.success is not None:
  1017. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1018. self.success.write(oprot)
  1019. oprot.writeFieldEnd()
  1020. oprot.writeFieldStop()
  1021. oprot.writeStructEnd()
  1022. def validate(self):
  1023. return
  1024. def __repr__(self):
  1025. L = ['%s=%r' % (key, value)
  1026. for key, value in self.__dict__.iteritems()]
  1027. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1028. def __eq__(self, other):
  1029. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1030. def __ne__(self, other):
  1031. return not (self == other)
  1032. class alter_sentry_role_delete_groups_args(object):
  1033. """
  1034. Attributes:
  1035. - request
  1036. """
  1037. thrift_spec = (
  1038. None, # 0
  1039. (1, TType.STRUCT, 'request', (TAlterSentryRoleDeleteGroupsRequest, TAlterSentryRoleDeleteGroupsRequest.thrift_spec), None, ), # 1
  1040. )
  1041. def __init__(self, request=None,):
  1042. self.request = request
  1043. def read(self, iprot):
  1044. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1045. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1046. return
  1047. iprot.readStructBegin()
  1048. while True:
  1049. (fname, ftype, fid) = iprot.readFieldBegin()
  1050. if ftype == TType.STOP:
  1051. break
  1052. if fid == 1:
  1053. if ftype == TType.STRUCT:
  1054. self.request = TAlterSentryRoleDeleteGroupsRequest()
  1055. self.request.read(iprot)
  1056. else:
  1057. iprot.skip(ftype)
  1058. else:
  1059. iprot.skip(ftype)
  1060. iprot.readFieldEnd()
  1061. iprot.readStructEnd()
  1062. def write(self, oprot):
  1063. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1064. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1065. return
  1066. oprot.writeStructBegin('alter_sentry_role_delete_groups_args')
  1067. if self.request is not None:
  1068. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1069. self.request.write(oprot)
  1070. oprot.writeFieldEnd()
  1071. oprot.writeFieldStop()
  1072. oprot.writeStructEnd()
  1073. def validate(self):
  1074. return
  1075. def __repr__(self):
  1076. L = ['%s=%r' % (key, value)
  1077. for key, value in self.__dict__.iteritems()]
  1078. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1079. def __eq__(self, other):
  1080. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1081. def __ne__(self, other):
  1082. return not (self == other)
  1083. class alter_sentry_role_delete_groups_result(object):
  1084. """
  1085. Attributes:
  1086. - success
  1087. """
  1088. thrift_spec = (
  1089. (0, TType.STRUCT, 'success', (TAlterSentryRoleDeleteGroupsResponse, TAlterSentryRoleDeleteGroupsResponse.thrift_spec), None, ), # 0
  1090. )
  1091. def __init__(self, success=None,):
  1092. self.success = success
  1093. def read(self, iprot):
  1094. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1095. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1096. return
  1097. iprot.readStructBegin()
  1098. while True:
  1099. (fname, ftype, fid) = iprot.readFieldBegin()
  1100. if ftype == TType.STOP:
  1101. break
  1102. if fid == 0:
  1103. if ftype == TType.STRUCT:
  1104. self.success = TAlterSentryRoleDeleteGroupsResponse()
  1105. self.success.read(iprot)
  1106. else:
  1107. iprot.skip(ftype)
  1108. else:
  1109. iprot.skip(ftype)
  1110. iprot.readFieldEnd()
  1111. iprot.readStructEnd()
  1112. def write(self, oprot):
  1113. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1114. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1115. return
  1116. oprot.writeStructBegin('alter_sentry_role_delete_groups_result')
  1117. if self.success is not None:
  1118. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1119. self.success.write(oprot)
  1120. oprot.writeFieldEnd()
  1121. oprot.writeFieldStop()
  1122. oprot.writeStructEnd()
  1123. def validate(self):
  1124. return
  1125. def __repr__(self):
  1126. L = ['%s=%r' % (key, value)
  1127. for key, value in self.__dict__.iteritems()]
  1128. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1129. def __eq__(self, other):
  1130. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1131. def __ne__(self, other):
  1132. return not (self == other)
  1133. class list_sentry_roles_by_group_args(object):
  1134. """
  1135. Attributes:
  1136. - request
  1137. """
  1138. thrift_spec = (
  1139. None, # 0
  1140. (1, TType.STRUCT, 'request', (TListSentryRolesRequest, TListSentryRolesRequest.thrift_spec), None, ), # 1
  1141. )
  1142. def __init__(self, request=None,):
  1143. self.request = request
  1144. def read(self, iprot):
  1145. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1146. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1147. return
  1148. iprot.readStructBegin()
  1149. while True:
  1150. (fname, ftype, fid) = iprot.readFieldBegin()
  1151. if ftype == TType.STOP:
  1152. break
  1153. if fid == 1:
  1154. if ftype == TType.STRUCT:
  1155. self.request = TListSentryRolesRequest()
  1156. self.request.read(iprot)
  1157. else:
  1158. iprot.skip(ftype)
  1159. else:
  1160. iprot.skip(ftype)
  1161. iprot.readFieldEnd()
  1162. iprot.readStructEnd()
  1163. def write(self, oprot):
  1164. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1165. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1166. return
  1167. oprot.writeStructBegin('list_sentry_roles_by_group_args')
  1168. if self.request is not None:
  1169. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1170. self.request.write(oprot)
  1171. oprot.writeFieldEnd()
  1172. oprot.writeFieldStop()
  1173. oprot.writeStructEnd()
  1174. def validate(self):
  1175. return
  1176. def __repr__(self):
  1177. L = ['%s=%r' % (key, value)
  1178. for key, value in self.__dict__.iteritems()]
  1179. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1180. def __eq__(self, other):
  1181. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1182. def __ne__(self, other):
  1183. return not (self == other)
  1184. class list_sentry_roles_by_group_result(object):
  1185. """
  1186. Attributes:
  1187. - success
  1188. """
  1189. thrift_spec = (
  1190. (0, TType.STRUCT, 'success', (TListSentryRolesResponse, TListSentryRolesResponse.thrift_spec), None, ), # 0
  1191. )
  1192. def __init__(self, success=None,):
  1193. self.success = success
  1194. def read(self, iprot):
  1195. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1196. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1197. return
  1198. iprot.readStructBegin()
  1199. while True:
  1200. (fname, ftype, fid) = iprot.readFieldBegin()
  1201. if ftype == TType.STOP:
  1202. break
  1203. if fid == 0:
  1204. if ftype == TType.STRUCT:
  1205. self.success = TListSentryRolesResponse()
  1206. self.success.read(iprot)
  1207. else:
  1208. iprot.skip(ftype)
  1209. else:
  1210. iprot.skip(ftype)
  1211. iprot.readFieldEnd()
  1212. iprot.readStructEnd()
  1213. def write(self, oprot):
  1214. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1215. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1216. return
  1217. oprot.writeStructBegin('list_sentry_roles_by_group_result')
  1218. if self.success is not None:
  1219. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1220. self.success.write(oprot)
  1221. oprot.writeFieldEnd()
  1222. oprot.writeFieldStop()
  1223. oprot.writeStructEnd()
  1224. def validate(self):
  1225. return
  1226. def __repr__(self):
  1227. L = ['%s=%r' % (key, value)
  1228. for key, value in self.__dict__.iteritems()]
  1229. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1230. def __eq__(self, other):
  1231. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1232. def __ne__(self, other):
  1233. return not (self == other)
  1234. class list_sentry_privileges_by_role_args(object):
  1235. """
  1236. Attributes:
  1237. - request
  1238. """
  1239. thrift_spec = (
  1240. None, # 0
  1241. (1, TType.STRUCT, 'request', (TListSentryPrivilegesRequest, TListSentryPrivilegesRequest.thrift_spec), None, ), # 1
  1242. )
  1243. def __init__(self, request=None,):
  1244. self.request = request
  1245. def read(self, iprot):
  1246. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1247. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1248. return
  1249. iprot.readStructBegin()
  1250. while True:
  1251. (fname, ftype, fid) = iprot.readFieldBegin()
  1252. if ftype == TType.STOP:
  1253. break
  1254. if fid == 1:
  1255. if ftype == TType.STRUCT:
  1256. self.request = TListSentryPrivilegesRequest()
  1257. self.request.read(iprot)
  1258. else:
  1259. iprot.skip(ftype)
  1260. else:
  1261. iprot.skip(ftype)
  1262. iprot.readFieldEnd()
  1263. iprot.readStructEnd()
  1264. def write(self, oprot):
  1265. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1266. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1267. return
  1268. oprot.writeStructBegin('list_sentry_privileges_by_role_args')
  1269. if self.request is not None:
  1270. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1271. self.request.write(oprot)
  1272. oprot.writeFieldEnd()
  1273. oprot.writeFieldStop()
  1274. oprot.writeStructEnd()
  1275. def validate(self):
  1276. return
  1277. def __repr__(self):
  1278. L = ['%s=%r' % (key, value)
  1279. for key, value in self.__dict__.iteritems()]
  1280. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1281. def __eq__(self, other):
  1282. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1283. def __ne__(self, other):
  1284. return not (self == other)
  1285. class list_sentry_privileges_by_role_result(object):
  1286. """
  1287. Attributes:
  1288. - success
  1289. """
  1290. thrift_spec = (
  1291. (0, TType.STRUCT, 'success', (TListSentryPrivilegesResponse, TListSentryPrivilegesResponse.thrift_spec), None, ), # 0
  1292. )
  1293. def __init__(self, success=None,):
  1294. self.success = success
  1295. def read(self, iprot):
  1296. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1297. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1298. return
  1299. iprot.readStructBegin()
  1300. while True:
  1301. (fname, ftype, fid) = iprot.readFieldBegin()
  1302. if ftype == TType.STOP:
  1303. break
  1304. if fid == 0:
  1305. if ftype == TType.STRUCT:
  1306. self.success = TListSentryPrivilegesResponse()
  1307. self.success.read(iprot)
  1308. else:
  1309. iprot.skip(ftype)
  1310. else:
  1311. iprot.skip(ftype)
  1312. iprot.readFieldEnd()
  1313. iprot.readStructEnd()
  1314. def write(self, oprot):
  1315. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1316. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1317. return
  1318. oprot.writeStructBegin('list_sentry_privileges_by_role_result')
  1319. if self.success is not None:
  1320. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1321. self.success.write(oprot)
  1322. oprot.writeFieldEnd()
  1323. oprot.writeFieldStop()
  1324. oprot.writeStructEnd()
  1325. def validate(self):
  1326. return
  1327. def __repr__(self):
  1328. L = ['%s=%r' % (key, value)
  1329. for key, value in self.__dict__.iteritems()]
  1330. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1331. def __eq__(self, other):
  1332. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1333. def __ne__(self, other):
  1334. return not (self == other)
  1335. class list_sentry_privileges_for_provider_args(object):
  1336. """
  1337. Attributes:
  1338. - request
  1339. """
  1340. thrift_spec = (
  1341. None, # 0
  1342. (1, TType.STRUCT, 'request', (TListSentryPrivilegesForProviderRequest, TListSentryPrivilegesForProviderRequest.thrift_spec), None, ), # 1
  1343. )
  1344. def __init__(self, request=None,):
  1345. self.request = request
  1346. def read(self, iprot):
  1347. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1348. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1349. return
  1350. iprot.readStructBegin()
  1351. while True:
  1352. (fname, ftype, fid) = iprot.readFieldBegin()
  1353. if ftype == TType.STOP:
  1354. break
  1355. if fid == 1:
  1356. if ftype == TType.STRUCT:
  1357. self.request = TListSentryPrivilegesForProviderRequest()
  1358. self.request.read(iprot)
  1359. else:
  1360. iprot.skip(ftype)
  1361. else:
  1362. iprot.skip(ftype)
  1363. iprot.readFieldEnd()
  1364. iprot.readStructEnd()
  1365. def write(self, oprot):
  1366. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1367. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1368. return
  1369. oprot.writeStructBegin('list_sentry_privileges_for_provider_args')
  1370. if self.request is not None:
  1371. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1372. self.request.write(oprot)
  1373. oprot.writeFieldEnd()
  1374. oprot.writeFieldStop()
  1375. oprot.writeStructEnd()
  1376. def validate(self):
  1377. return
  1378. def __repr__(self):
  1379. L = ['%s=%r' % (key, value)
  1380. for key, value in self.__dict__.iteritems()]
  1381. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1382. def __eq__(self, other):
  1383. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1384. def __ne__(self, other):
  1385. return not (self == other)
  1386. class list_sentry_privileges_for_provider_result(object):
  1387. """
  1388. Attributes:
  1389. - success
  1390. """
  1391. thrift_spec = (
  1392. (0, TType.STRUCT, 'success', (TListSentryPrivilegesForProviderResponse, TListSentryPrivilegesForProviderResponse.thrift_spec), None, ), # 0
  1393. )
  1394. def __init__(self, success=None,):
  1395. self.success = success
  1396. def read(self, iprot):
  1397. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1398. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1399. return
  1400. iprot.readStructBegin()
  1401. while True:
  1402. (fname, ftype, fid) = iprot.readFieldBegin()
  1403. if ftype == TType.STOP:
  1404. break
  1405. if fid == 0:
  1406. if ftype == TType.STRUCT:
  1407. self.success = TListSentryPrivilegesForProviderResponse()
  1408. self.success.read(iprot)
  1409. else:
  1410. iprot.skip(ftype)
  1411. else:
  1412. iprot.skip(ftype)
  1413. iprot.readFieldEnd()
  1414. iprot.readStructEnd()
  1415. def write(self, oprot):
  1416. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1417. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1418. return
  1419. oprot.writeStructBegin('list_sentry_privileges_for_provider_result')
  1420. if self.success is not None:
  1421. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1422. self.success.write(oprot)
  1423. oprot.writeFieldEnd()
  1424. oprot.writeFieldStop()
  1425. oprot.writeStructEnd()
  1426. def validate(self):
  1427. return
  1428. def __repr__(self):
  1429. L = ['%s=%r' % (key, value)
  1430. for key, value in self.__dict__.iteritems()]
  1431. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1432. def __eq__(self, other):
  1433. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1434. def __ne__(self, other):
  1435. return not (self == other)
  1436. class drop_sentry_privilege_args(object):
  1437. """
  1438. Attributes:
  1439. - request
  1440. """
  1441. thrift_spec = (
  1442. None, # 0
  1443. (1, TType.STRUCT, 'request', (TDropPrivilegesRequest, TDropPrivilegesRequest.thrift_spec), None, ), # 1
  1444. )
  1445. def __init__(self, request=None,):
  1446. self.request = request
  1447. def read(self, iprot):
  1448. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1449. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1450. return
  1451. iprot.readStructBegin()
  1452. while True:
  1453. (fname, ftype, fid) = iprot.readFieldBegin()
  1454. if ftype == TType.STOP:
  1455. break
  1456. if fid == 1:
  1457. if ftype == TType.STRUCT:
  1458. self.request = TDropPrivilegesRequest()
  1459. self.request.read(iprot)
  1460. else:
  1461. iprot.skip(ftype)
  1462. else:
  1463. iprot.skip(ftype)
  1464. iprot.readFieldEnd()
  1465. iprot.readStructEnd()
  1466. def write(self, oprot):
  1467. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1468. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1469. return
  1470. oprot.writeStructBegin('drop_sentry_privilege_args')
  1471. if self.request is not None:
  1472. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1473. self.request.write(oprot)
  1474. oprot.writeFieldEnd()
  1475. oprot.writeFieldStop()
  1476. oprot.writeStructEnd()
  1477. def validate(self):
  1478. return
  1479. def __repr__(self):
  1480. L = ['%s=%r' % (key, value)
  1481. for key, value in self.__dict__.iteritems()]
  1482. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1483. def __eq__(self, other):
  1484. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1485. def __ne__(self, other):
  1486. return not (self == other)
  1487. class drop_sentry_privilege_result(object):
  1488. """
  1489. Attributes:
  1490. - success
  1491. """
  1492. thrift_spec = (
  1493. (0, TType.STRUCT, 'success', (TDropPrivilegesResponse, TDropPrivilegesResponse.thrift_spec), None, ), # 0
  1494. )
  1495. def __init__(self, success=None,):
  1496. self.success = success
  1497. def read(self, iprot):
  1498. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1499. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1500. return
  1501. iprot.readStructBegin()
  1502. while True:
  1503. (fname, ftype, fid) = iprot.readFieldBegin()
  1504. if ftype == TType.STOP:
  1505. break
  1506. if fid == 0:
  1507. if ftype == TType.STRUCT:
  1508. self.success = TDropPrivilegesResponse()
  1509. self.success.read(iprot)
  1510. else:
  1511. iprot.skip(ftype)
  1512. else:
  1513. iprot.skip(ftype)
  1514. iprot.readFieldEnd()
  1515. iprot.readStructEnd()
  1516. def write(self, oprot):
  1517. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1518. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1519. return
  1520. oprot.writeStructBegin('drop_sentry_privilege_result')
  1521. if self.success is not None:
  1522. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1523. self.success.write(oprot)
  1524. oprot.writeFieldEnd()
  1525. oprot.writeFieldStop()
  1526. oprot.writeStructEnd()
  1527. def validate(self):
  1528. return
  1529. def __repr__(self):
  1530. L = ['%s=%r' % (key, value)
  1531. for key, value in self.__dict__.iteritems()]
  1532. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1533. def __eq__(self, other):
  1534. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1535. def __ne__(self, other):
  1536. return not (self == other)
  1537. class rename_sentry_privilege_args(object):
  1538. """
  1539. Attributes:
  1540. - request
  1541. """
  1542. thrift_spec = (
  1543. None, # 0
  1544. (1, TType.STRUCT, 'request', (TRenamePrivilegesRequest, TRenamePrivilegesRequest.thrift_spec), None, ), # 1
  1545. )
  1546. def __init__(self, request=None,):
  1547. self.request = request
  1548. def read(self, iprot):
  1549. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1550. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1551. return
  1552. iprot.readStructBegin()
  1553. while True:
  1554. (fname, ftype, fid) = iprot.readFieldBegin()
  1555. if ftype == TType.STOP:
  1556. break
  1557. if fid == 1:
  1558. if ftype == TType.STRUCT:
  1559. self.request = TRenamePrivilegesRequest()
  1560. self.request.read(iprot)
  1561. else:
  1562. iprot.skip(ftype)
  1563. else:
  1564. iprot.skip(ftype)
  1565. iprot.readFieldEnd()
  1566. iprot.readStructEnd()
  1567. def write(self, oprot):
  1568. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1569. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1570. return
  1571. oprot.writeStructBegin('rename_sentry_privilege_args')
  1572. if self.request is not None:
  1573. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1574. self.request.write(oprot)
  1575. oprot.writeFieldEnd()
  1576. oprot.writeFieldStop()
  1577. oprot.writeStructEnd()
  1578. def validate(self):
  1579. return
  1580. def __repr__(self):
  1581. L = ['%s=%r' % (key, value)
  1582. for key, value in self.__dict__.iteritems()]
  1583. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1584. def __eq__(self, other):
  1585. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1586. def __ne__(self, other):
  1587. return not (self == other)
  1588. class rename_sentry_privilege_result(object):
  1589. """
  1590. Attributes:
  1591. - success
  1592. """
  1593. thrift_spec = (
  1594. (0, TType.STRUCT, 'success', (TRenamePrivilegesResponse, TRenamePrivilegesResponse.thrift_spec), None, ), # 0
  1595. )
  1596. def __init__(self, success=None,):
  1597. self.success = success
  1598. def read(self, iprot):
  1599. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1600. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1601. return
  1602. iprot.readStructBegin()
  1603. while True:
  1604. (fname, ftype, fid) = iprot.readFieldBegin()
  1605. if ftype == TType.STOP:
  1606. break
  1607. if fid == 0:
  1608. if ftype == TType.STRUCT:
  1609. self.success = TRenamePrivilegesResponse()
  1610. self.success.read(iprot)
  1611. else:
  1612. iprot.skip(ftype)
  1613. else:
  1614. iprot.skip(ftype)
  1615. iprot.readFieldEnd()
  1616. iprot.readStructEnd()
  1617. def write(self, oprot):
  1618. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1619. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1620. return
  1621. oprot.writeStructBegin('rename_sentry_privilege_result')
  1622. if self.success is not None:
  1623. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1624. self.success.write(oprot)
  1625. oprot.writeFieldEnd()
  1626. oprot.writeFieldStop()
  1627. oprot.writeStructEnd()
  1628. def validate(self):
  1629. return
  1630. def __repr__(self):
  1631. L = ['%s=%r' % (key, value)
  1632. for key, value in self.__dict__.iteritems()]
  1633. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1634. def __eq__(self, other):
  1635. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1636. def __ne__(self, other):
  1637. return not (self == other)