SentryPolicyService.py 79 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509
  1. #
  2. # Autogenerated by Thrift Compiler (0.9.3)
  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. import logging
  10. from ttypes import *
  11. from thrift.Thrift import TProcessor
  12. from thrift.transport import TTransport
  13. from thrift.protocol import TBinaryProtocol, TProtocol
  14. try:
  15. from thrift.protocol import fastbinary
  16. except:
  17. fastbinary = None
  18. class Iface(object):
  19. def create_sentry_role(self, request):
  20. """
  21. Parameters:
  22. - request
  23. """
  24. pass
  25. def drop_sentry_role(self, request):
  26. """
  27. Parameters:
  28. - request
  29. """
  30. pass
  31. def alter_sentry_role_grant_privilege(self, request):
  32. """
  33. Parameters:
  34. - request
  35. """
  36. pass
  37. def alter_sentry_role_revoke_privilege(self, request):
  38. """
  39. Parameters:
  40. - request
  41. """
  42. pass
  43. def alter_sentry_role_add_groups(self, request):
  44. """
  45. Parameters:
  46. - request
  47. """
  48. pass
  49. def alter_sentry_role_delete_groups(self, request):
  50. """
  51. Parameters:
  52. - request
  53. """
  54. pass
  55. def list_sentry_roles_by_group(self, request):
  56. """
  57. Parameters:
  58. - request
  59. """
  60. pass
  61. def list_sentry_privileges_by_role(self, request):
  62. """
  63. Parameters:
  64. - request
  65. """
  66. pass
  67. def list_sentry_privileges_for_provider(self, request):
  68. """
  69. Parameters:
  70. - request
  71. """
  72. pass
  73. def drop_sentry_privilege(self, request):
  74. """
  75. Parameters:
  76. - request
  77. """
  78. pass
  79. def rename_sentry_privilege(self, request):
  80. """
  81. Parameters:
  82. - request
  83. """
  84. pass
  85. def list_sentry_privileges_by_authorizable(self, request):
  86. """
  87. Parameters:
  88. - request
  89. """
  90. pass
  91. def get_sentry_config_value(self, request):
  92. """
  93. Parameters:
  94. - request
  95. """
  96. pass
  97. class Client(Iface):
  98. def __init__(self, iprot, oprot=None):
  99. self._iprot = self._oprot = iprot
  100. if oprot is not None:
  101. self._oprot = oprot
  102. self._seqid = 0
  103. def create_sentry_role(self, request):
  104. """
  105. Parameters:
  106. - request
  107. """
  108. self.send_create_sentry_role(request)
  109. return self.recv_create_sentry_role()
  110. def send_create_sentry_role(self, request):
  111. self._oprot.writeMessageBegin('create_sentry_role', TMessageType.CALL, self._seqid)
  112. args = create_sentry_role_args()
  113. args.request = request
  114. args.write(self._oprot)
  115. self._oprot.writeMessageEnd()
  116. self._oprot.trans.flush()
  117. def recv_create_sentry_role(self):
  118. iprot = self._iprot
  119. (fname, mtype, rseqid) = iprot.readMessageBegin()
  120. if mtype == TMessageType.EXCEPTION:
  121. x = TApplicationException()
  122. x.read(iprot)
  123. iprot.readMessageEnd()
  124. raise x
  125. result = create_sentry_role_result()
  126. result.read(iprot)
  127. iprot.readMessageEnd()
  128. if result.success is not None:
  129. return result.success
  130. raise TApplicationException(TApplicationException.MISSING_RESULT, "create_sentry_role failed: unknown result")
  131. def drop_sentry_role(self, request):
  132. """
  133. Parameters:
  134. - request
  135. """
  136. self.send_drop_sentry_role(request)
  137. return self.recv_drop_sentry_role()
  138. def send_drop_sentry_role(self, request):
  139. self._oprot.writeMessageBegin('drop_sentry_role', TMessageType.CALL, self._seqid)
  140. args = drop_sentry_role_args()
  141. args.request = request
  142. args.write(self._oprot)
  143. self._oprot.writeMessageEnd()
  144. self._oprot.trans.flush()
  145. def recv_drop_sentry_role(self):
  146. iprot = self._iprot
  147. (fname, mtype, rseqid) = iprot.readMessageBegin()
  148. if mtype == TMessageType.EXCEPTION:
  149. x = TApplicationException()
  150. x.read(iprot)
  151. iprot.readMessageEnd()
  152. raise x
  153. result = drop_sentry_role_result()
  154. result.read(iprot)
  155. iprot.readMessageEnd()
  156. if result.success is not None:
  157. return result.success
  158. raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_sentry_role failed: unknown result")
  159. def alter_sentry_role_grant_privilege(self, request):
  160. """
  161. Parameters:
  162. - request
  163. """
  164. self.send_alter_sentry_role_grant_privilege(request)
  165. return self.recv_alter_sentry_role_grant_privilege()
  166. def send_alter_sentry_role_grant_privilege(self, request):
  167. self._oprot.writeMessageBegin('alter_sentry_role_grant_privilege', TMessageType.CALL, self._seqid)
  168. args = alter_sentry_role_grant_privilege_args()
  169. args.request = request
  170. args.write(self._oprot)
  171. self._oprot.writeMessageEnd()
  172. self._oprot.trans.flush()
  173. def recv_alter_sentry_role_grant_privilege(self):
  174. iprot = self._iprot
  175. (fname, mtype, rseqid) = iprot.readMessageBegin()
  176. if mtype == TMessageType.EXCEPTION:
  177. x = TApplicationException()
  178. x.read(iprot)
  179. iprot.readMessageEnd()
  180. raise x
  181. result = alter_sentry_role_grant_privilege_result()
  182. result.read(iprot)
  183. iprot.readMessageEnd()
  184. if result.success is not None:
  185. return result.success
  186. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_grant_privilege failed: unknown result")
  187. def alter_sentry_role_revoke_privilege(self, request):
  188. """
  189. Parameters:
  190. - request
  191. """
  192. self.send_alter_sentry_role_revoke_privilege(request)
  193. return self.recv_alter_sentry_role_revoke_privilege()
  194. def send_alter_sentry_role_revoke_privilege(self, request):
  195. self._oprot.writeMessageBegin('alter_sentry_role_revoke_privilege', TMessageType.CALL, self._seqid)
  196. args = alter_sentry_role_revoke_privilege_args()
  197. args.request = request
  198. args.write(self._oprot)
  199. self._oprot.writeMessageEnd()
  200. self._oprot.trans.flush()
  201. def recv_alter_sentry_role_revoke_privilege(self):
  202. iprot = self._iprot
  203. (fname, mtype, rseqid) = iprot.readMessageBegin()
  204. if mtype == TMessageType.EXCEPTION:
  205. x = TApplicationException()
  206. x.read(iprot)
  207. iprot.readMessageEnd()
  208. raise x
  209. result = alter_sentry_role_revoke_privilege_result()
  210. result.read(iprot)
  211. iprot.readMessageEnd()
  212. if result.success is not None:
  213. return result.success
  214. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_revoke_privilege failed: unknown result")
  215. def alter_sentry_role_add_groups(self, request):
  216. """
  217. Parameters:
  218. - request
  219. """
  220. self.send_alter_sentry_role_add_groups(request)
  221. return self.recv_alter_sentry_role_add_groups()
  222. def send_alter_sentry_role_add_groups(self, request):
  223. self._oprot.writeMessageBegin('alter_sentry_role_add_groups', TMessageType.CALL, self._seqid)
  224. args = alter_sentry_role_add_groups_args()
  225. args.request = request
  226. args.write(self._oprot)
  227. self._oprot.writeMessageEnd()
  228. self._oprot.trans.flush()
  229. def recv_alter_sentry_role_add_groups(self):
  230. iprot = self._iprot
  231. (fname, mtype, rseqid) = iprot.readMessageBegin()
  232. if mtype == TMessageType.EXCEPTION:
  233. x = TApplicationException()
  234. x.read(iprot)
  235. iprot.readMessageEnd()
  236. raise x
  237. result = alter_sentry_role_add_groups_result()
  238. result.read(iprot)
  239. iprot.readMessageEnd()
  240. if result.success is not None:
  241. return result.success
  242. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_add_groups failed: unknown result")
  243. def alter_sentry_role_delete_groups(self, request):
  244. """
  245. Parameters:
  246. - request
  247. """
  248. self.send_alter_sentry_role_delete_groups(request)
  249. return self.recv_alter_sentry_role_delete_groups()
  250. def send_alter_sentry_role_delete_groups(self, request):
  251. self._oprot.writeMessageBegin('alter_sentry_role_delete_groups', TMessageType.CALL, self._seqid)
  252. args = alter_sentry_role_delete_groups_args()
  253. args.request = request
  254. args.write(self._oprot)
  255. self._oprot.writeMessageEnd()
  256. self._oprot.trans.flush()
  257. def recv_alter_sentry_role_delete_groups(self):
  258. iprot = self._iprot
  259. (fname, mtype, rseqid) = iprot.readMessageBegin()
  260. if mtype == TMessageType.EXCEPTION:
  261. x = TApplicationException()
  262. x.read(iprot)
  263. iprot.readMessageEnd()
  264. raise x
  265. result = alter_sentry_role_delete_groups_result()
  266. result.read(iprot)
  267. iprot.readMessageEnd()
  268. if result.success is not None:
  269. return result.success
  270. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_delete_groups failed: unknown result")
  271. def list_sentry_roles_by_group(self, request):
  272. """
  273. Parameters:
  274. - request
  275. """
  276. self.send_list_sentry_roles_by_group(request)
  277. return self.recv_list_sentry_roles_by_group()
  278. def send_list_sentry_roles_by_group(self, request):
  279. self._oprot.writeMessageBegin('list_sentry_roles_by_group', TMessageType.CALL, self._seqid)
  280. args = list_sentry_roles_by_group_args()
  281. args.request = request
  282. args.write(self._oprot)
  283. self._oprot.writeMessageEnd()
  284. self._oprot.trans.flush()
  285. def recv_list_sentry_roles_by_group(self):
  286. iprot = self._iprot
  287. (fname, mtype, rseqid) = iprot.readMessageBegin()
  288. if mtype == TMessageType.EXCEPTION:
  289. x = TApplicationException()
  290. x.read(iprot)
  291. iprot.readMessageEnd()
  292. raise x
  293. result = list_sentry_roles_by_group_result()
  294. result.read(iprot)
  295. iprot.readMessageEnd()
  296. if result.success is not None:
  297. return result.success
  298. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_roles_by_group failed: unknown result")
  299. def list_sentry_privileges_by_role(self, request):
  300. """
  301. Parameters:
  302. - request
  303. """
  304. self.send_list_sentry_privileges_by_role(request)
  305. return self.recv_list_sentry_privileges_by_role()
  306. def send_list_sentry_privileges_by_role(self, request):
  307. self._oprot.writeMessageBegin('list_sentry_privileges_by_role', TMessageType.CALL, self._seqid)
  308. args = list_sentry_privileges_by_role_args()
  309. args.request = request
  310. args.write(self._oprot)
  311. self._oprot.writeMessageEnd()
  312. self._oprot.trans.flush()
  313. def recv_list_sentry_privileges_by_role(self):
  314. iprot = self._iprot
  315. (fname, mtype, rseqid) = iprot.readMessageBegin()
  316. if mtype == TMessageType.EXCEPTION:
  317. x = TApplicationException()
  318. x.read(iprot)
  319. iprot.readMessageEnd()
  320. raise x
  321. result = list_sentry_privileges_by_role_result()
  322. result.read(iprot)
  323. iprot.readMessageEnd()
  324. if result.success is not None:
  325. return result.success
  326. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_by_role failed: unknown result")
  327. def list_sentry_privileges_for_provider(self, request):
  328. """
  329. Parameters:
  330. - request
  331. """
  332. self.send_list_sentry_privileges_for_provider(request)
  333. return self.recv_list_sentry_privileges_for_provider()
  334. def send_list_sentry_privileges_for_provider(self, request):
  335. self._oprot.writeMessageBegin('list_sentry_privileges_for_provider', TMessageType.CALL, self._seqid)
  336. args = list_sentry_privileges_for_provider_args()
  337. args.request = request
  338. args.write(self._oprot)
  339. self._oprot.writeMessageEnd()
  340. self._oprot.trans.flush()
  341. def recv_list_sentry_privileges_for_provider(self):
  342. iprot = self._iprot
  343. (fname, mtype, rseqid) = iprot.readMessageBegin()
  344. if mtype == TMessageType.EXCEPTION:
  345. x = TApplicationException()
  346. x.read(iprot)
  347. iprot.readMessageEnd()
  348. raise x
  349. result = list_sentry_privileges_for_provider_result()
  350. result.read(iprot)
  351. iprot.readMessageEnd()
  352. if result.success is not None:
  353. return result.success
  354. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_for_provider failed: unknown result")
  355. def drop_sentry_privilege(self, request):
  356. """
  357. Parameters:
  358. - request
  359. """
  360. self.send_drop_sentry_privilege(request)
  361. return self.recv_drop_sentry_privilege()
  362. def send_drop_sentry_privilege(self, request):
  363. self._oprot.writeMessageBegin('drop_sentry_privilege', TMessageType.CALL, self._seqid)
  364. args = drop_sentry_privilege_args()
  365. args.request = request
  366. args.write(self._oprot)
  367. self._oprot.writeMessageEnd()
  368. self._oprot.trans.flush()
  369. def recv_drop_sentry_privilege(self):
  370. iprot = self._iprot
  371. (fname, mtype, rseqid) = iprot.readMessageBegin()
  372. if mtype == TMessageType.EXCEPTION:
  373. x = TApplicationException()
  374. x.read(iprot)
  375. iprot.readMessageEnd()
  376. raise x
  377. result = drop_sentry_privilege_result()
  378. result.read(iprot)
  379. iprot.readMessageEnd()
  380. if result.success is not None:
  381. return result.success
  382. raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_sentry_privilege failed: unknown result")
  383. def rename_sentry_privilege(self, request):
  384. """
  385. Parameters:
  386. - request
  387. """
  388. self.send_rename_sentry_privilege(request)
  389. return self.recv_rename_sentry_privilege()
  390. def send_rename_sentry_privilege(self, request):
  391. self._oprot.writeMessageBegin('rename_sentry_privilege', TMessageType.CALL, self._seqid)
  392. args = rename_sentry_privilege_args()
  393. args.request = request
  394. args.write(self._oprot)
  395. self._oprot.writeMessageEnd()
  396. self._oprot.trans.flush()
  397. def recv_rename_sentry_privilege(self):
  398. iprot = self._iprot
  399. (fname, mtype, rseqid) = iprot.readMessageBegin()
  400. if mtype == TMessageType.EXCEPTION:
  401. x = TApplicationException()
  402. x.read(iprot)
  403. iprot.readMessageEnd()
  404. raise x
  405. result = rename_sentry_privilege_result()
  406. result.read(iprot)
  407. iprot.readMessageEnd()
  408. if result.success is not None:
  409. return result.success
  410. raise TApplicationException(TApplicationException.MISSING_RESULT, "rename_sentry_privilege failed: unknown result")
  411. def list_sentry_privileges_by_authorizable(self, request):
  412. """
  413. Parameters:
  414. - request
  415. """
  416. self.send_list_sentry_privileges_by_authorizable(request)
  417. return self.recv_list_sentry_privileges_by_authorizable()
  418. def send_list_sentry_privileges_by_authorizable(self, request):
  419. self._oprot.writeMessageBegin('list_sentry_privileges_by_authorizable', TMessageType.CALL, self._seqid)
  420. args = list_sentry_privileges_by_authorizable_args()
  421. args.request = request
  422. args.write(self._oprot)
  423. self._oprot.writeMessageEnd()
  424. self._oprot.trans.flush()
  425. def recv_list_sentry_privileges_by_authorizable(self):
  426. iprot = self._iprot
  427. (fname, mtype, rseqid) = iprot.readMessageBegin()
  428. if mtype == TMessageType.EXCEPTION:
  429. x = TApplicationException()
  430. x.read(iprot)
  431. iprot.readMessageEnd()
  432. raise x
  433. result = list_sentry_privileges_by_authorizable_result()
  434. result.read(iprot)
  435. iprot.readMessageEnd()
  436. if result.success is not None:
  437. return result.success
  438. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_by_authorizable failed: unknown result")
  439. def get_sentry_config_value(self, request):
  440. """
  441. Parameters:
  442. - request
  443. """
  444. self.send_get_sentry_config_value(request)
  445. return self.recv_get_sentry_config_value()
  446. def send_get_sentry_config_value(self, request):
  447. self._oprot.writeMessageBegin('get_sentry_config_value', TMessageType.CALL, self._seqid)
  448. args = get_sentry_config_value_args()
  449. args.request = request
  450. args.write(self._oprot)
  451. self._oprot.writeMessageEnd()
  452. self._oprot.trans.flush()
  453. def recv_get_sentry_config_value(self):
  454. iprot = self._iprot
  455. (fname, mtype, rseqid) = iprot.readMessageBegin()
  456. if mtype == TMessageType.EXCEPTION:
  457. x = TApplicationException()
  458. x.read(iprot)
  459. iprot.readMessageEnd()
  460. raise x
  461. result = get_sentry_config_value_result()
  462. result.read(iprot)
  463. iprot.readMessageEnd()
  464. if result.success is not None:
  465. return result.success
  466. raise TApplicationException(TApplicationException.MISSING_RESULT, "get_sentry_config_value failed: unknown result")
  467. class Processor(Iface, TProcessor):
  468. def __init__(self, handler):
  469. self._handler = handler
  470. self._processMap = {}
  471. self._processMap["create_sentry_role"] = Processor.process_create_sentry_role
  472. self._processMap["drop_sentry_role"] = Processor.process_drop_sentry_role
  473. self._processMap["alter_sentry_role_grant_privilege"] = Processor.process_alter_sentry_role_grant_privilege
  474. self._processMap["alter_sentry_role_revoke_privilege"] = Processor.process_alter_sentry_role_revoke_privilege
  475. self._processMap["alter_sentry_role_add_groups"] = Processor.process_alter_sentry_role_add_groups
  476. self._processMap["alter_sentry_role_delete_groups"] = Processor.process_alter_sentry_role_delete_groups
  477. self._processMap["list_sentry_roles_by_group"] = Processor.process_list_sentry_roles_by_group
  478. self._processMap["list_sentry_privileges_by_role"] = Processor.process_list_sentry_privileges_by_role
  479. self._processMap["list_sentry_privileges_for_provider"] = Processor.process_list_sentry_privileges_for_provider
  480. self._processMap["drop_sentry_privilege"] = Processor.process_drop_sentry_privilege
  481. self._processMap["rename_sentry_privilege"] = Processor.process_rename_sentry_privilege
  482. self._processMap["list_sentry_privileges_by_authorizable"] = Processor.process_list_sentry_privileges_by_authorizable
  483. self._processMap["get_sentry_config_value"] = Processor.process_get_sentry_config_value
  484. def process(self, iprot, oprot):
  485. (name, type, seqid) = iprot.readMessageBegin()
  486. if name not in self._processMap:
  487. iprot.skip(TType.STRUCT)
  488. iprot.readMessageEnd()
  489. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  490. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  491. x.write(oprot)
  492. oprot.writeMessageEnd()
  493. oprot.trans.flush()
  494. return
  495. else:
  496. self._processMap[name](self, seqid, iprot, oprot)
  497. return True
  498. def process_create_sentry_role(self, seqid, iprot, oprot):
  499. args = create_sentry_role_args()
  500. args.read(iprot)
  501. iprot.readMessageEnd()
  502. result = create_sentry_role_result()
  503. try:
  504. result.success = self._handler.create_sentry_role(args.request)
  505. msg_type = TMessageType.REPLY
  506. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  507. raise
  508. except Exception as ex:
  509. msg_type = TMessageType.EXCEPTION
  510. logging.exception(ex)
  511. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  512. oprot.writeMessageBegin("create_sentry_role", msg_type, seqid)
  513. result.write(oprot)
  514. oprot.writeMessageEnd()
  515. oprot.trans.flush()
  516. def process_drop_sentry_role(self, seqid, iprot, oprot):
  517. args = drop_sentry_role_args()
  518. args.read(iprot)
  519. iprot.readMessageEnd()
  520. result = drop_sentry_role_result()
  521. try:
  522. result.success = self._handler.drop_sentry_role(args.request)
  523. msg_type = TMessageType.REPLY
  524. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  525. raise
  526. except Exception as ex:
  527. msg_type = TMessageType.EXCEPTION
  528. logging.exception(ex)
  529. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  530. oprot.writeMessageBegin("drop_sentry_role", msg_type, seqid)
  531. result.write(oprot)
  532. oprot.writeMessageEnd()
  533. oprot.trans.flush()
  534. def process_alter_sentry_role_grant_privilege(self, seqid, iprot, oprot):
  535. args = alter_sentry_role_grant_privilege_args()
  536. args.read(iprot)
  537. iprot.readMessageEnd()
  538. result = alter_sentry_role_grant_privilege_result()
  539. try:
  540. result.success = self._handler.alter_sentry_role_grant_privilege(args.request)
  541. msg_type = TMessageType.REPLY
  542. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  543. raise
  544. except Exception as ex:
  545. msg_type = TMessageType.EXCEPTION
  546. logging.exception(ex)
  547. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  548. oprot.writeMessageBegin("alter_sentry_role_grant_privilege", msg_type, seqid)
  549. result.write(oprot)
  550. oprot.writeMessageEnd()
  551. oprot.trans.flush()
  552. def process_alter_sentry_role_revoke_privilege(self, seqid, iprot, oprot):
  553. args = alter_sentry_role_revoke_privilege_args()
  554. args.read(iprot)
  555. iprot.readMessageEnd()
  556. result = alter_sentry_role_revoke_privilege_result()
  557. try:
  558. result.success = self._handler.alter_sentry_role_revoke_privilege(args.request)
  559. msg_type = TMessageType.REPLY
  560. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  561. raise
  562. except Exception as ex:
  563. msg_type = TMessageType.EXCEPTION
  564. logging.exception(ex)
  565. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  566. oprot.writeMessageBegin("alter_sentry_role_revoke_privilege", msg_type, seqid)
  567. result.write(oprot)
  568. oprot.writeMessageEnd()
  569. oprot.trans.flush()
  570. def process_alter_sentry_role_add_groups(self, seqid, iprot, oprot):
  571. args = alter_sentry_role_add_groups_args()
  572. args.read(iprot)
  573. iprot.readMessageEnd()
  574. result = alter_sentry_role_add_groups_result()
  575. try:
  576. result.success = self._handler.alter_sentry_role_add_groups(args.request)
  577. msg_type = TMessageType.REPLY
  578. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  579. raise
  580. except Exception as ex:
  581. msg_type = TMessageType.EXCEPTION
  582. logging.exception(ex)
  583. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  584. oprot.writeMessageBegin("alter_sentry_role_add_groups", msg_type, seqid)
  585. result.write(oprot)
  586. oprot.writeMessageEnd()
  587. oprot.trans.flush()
  588. def process_alter_sentry_role_delete_groups(self, seqid, iprot, oprot):
  589. args = alter_sentry_role_delete_groups_args()
  590. args.read(iprot)
  591. iprot.readMessageEnd()
  592. result = alter_sentry_role_delete_groups_result()
  593. try:
  594. result.success = self._handler.alter_sentry_role_delete_groups(args.request)
  595. msg_type = TMessageType.REPLY
  596. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  597. raise
  598. except Exception as ex:
  599. msg_type = TMessageType.EXCEPTION
  600. logging.exception(ex)
  601. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  602. oprot.writeMessageBegin("alter_sentry_role_delete_groups", msg_type, seqid)
  603. result.write(oprot)
  604. oprot.writeMessageEnd()
  605. oprot.trans.flush()
  606. def process_list_sentry_roles_by_group(self, seqid, iprot, oprot):
  607. args = list_sentry_roles_by_group_args()
  608. args.read(iprot)
  609. iprot.readMessageEnd()
  610. result = list_sentry_roles_by_group_result()
  611. try:
  612. result.success = self._handler.list_sentry_roles_by_group(args.request)
  613. msg_type = TMessageType.REPLY
  614. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  615. raise
  616. except Exception as ex:
  617. msg_type = TMessageType.EXCEPTION
  618. logging.exception(ex)
  619. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  620. oprot.writeMessageBegin("list_sentry_roles_by_group", msg_type, seqid)
  621. result.write(oprot)
  622. oprot.writeMessageEnd()
  623. oprot.trans.flush()
  624. def process_list_sentry_privileges_by_role(self, seqid, iprot, oprot):
  625. args = list_sentry_privileges_by_role_args()
  626. args.read(iprot)
  627. iprot.readMessageEnd()
  628. result = list_sentry_privileges_by_role_result()
  629. try:
  630. result.success = self._handler.list_sentry_privileges_by_role(args.request)
  631. msg_type = TMessageType.REPLY
  632. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  633. raise
  634. except Exception as ex:
  635. msg_type = TMessageType.EXCEPTION
  636. logging.exception(ex)
  637. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  638. oprot.writeMessageBegin("list_sentry_privileges_by_role", msg_type, seqid)
  639. result.write(oprot)
  640. oprot.writeMessageEnd()
  641. oprot.trans.flush()
  642. def process_list_sentry_privileges_for_provider(self, seqid, iprot, oprot):
  643. args = list_sentry_privileges_for_provider_args()
  644. args.read(iprot)
  645. iprot.readMessageEnd()
  646. result = list_sentry_privileges_for_provider_result()
  647. try:
  648. result.success = self._handler.list_sentry_privileges_for_provider(args.request)
  649. msg_type = TMessageType.REPLY
  650. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  651. raise
  652. except Exception as ex:
  653. msg_type = TMessageType.EXCEPTION
  654. logging.exception(ex)
  655. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  656. oprot.writeMessageBegin("list_sentry_privileges_for_provider", msg_type, seqid)
  657. result.write(oprot)
  658. oprot.writeMessageEnd()
  659. oprot.trans.flush()
  660. def process_drop_sentry_privilege(self, seqid, iprot, oprot):
  661. args = drop_sentry_privilege_args()
  662. args.read(iprot)
  663. iprot.readMessageEnd()
  664. result = drop_sentry_privilege_result()
  665. try:
  666. result.success = self._handler.drop_sentry_privilege(args.request)
  667. msg_type = TMessageType.REPLY
  668. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  669. raise
  670. except Exception as ex:
  671. msg_type = TMessageType.EXCEPTION
  672. logging.exception(ex)
  673. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  674. oprot.writeMessageBegin("drop_sentry_privilege", msg_type, seqid)
  675. result.write(oprot)
  676. oprot.writeMessageEnd()
  677. oprot.trans.flush()
  678. def process_rename_sentry_privilege(self, seqid, iprot, oprot):
  679. args = rename_sentry_privilege_args()
  680. args.read(iprot)
  681. iprot.readMessageEnd()
  682. result = rename_sentry_privilege_result()
  683. try:
  684. result.success = self._handler.rename_sentry_privilege(args.request)
  685. msg_type = TMessageType.REPLY
  686. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  687. raise
  688. except Exception as ex:
  689. msg_type = TMessageType.EXCEPTION
  690. logging.exception(ex)
  691. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  692. oprot.writeMessageBegin("rename_sentry_privilege", msg_type, seqid)
  693. result.write(oprot)
  694. oprot.writeMessageEnd()
  695. oprot.trans.flush()
  696. def process_list_sentry_privileges_by_authorizable(self, seqid, iprot, oprot):
  697. args = list_sentry_privileges_by_authorizable_args()
  698. args.read(iprot)
  699. iprot.readMessageEnd()
  700. result = list_sentry_privileges_by_authorizable_result()
  701. try:
  702. result.success = self._handler.list_sentry_privileges_by_authorizable(args.request)
  703. msg_type = TMessageType.REPLY
  704. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  705. raise
  706. except Exception as ex:
  707. msg_type = TMessageType.EXCEPTION
  708. logging.exception(ex)
  709. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  710. oprot.writeMessageBegin("list_sentry_privileges_by_authorizable", msg_type, seqid)
  711. result.write(oprot)
  712. oprot.writeMessageEnd()
  713. oprot.trans.flush()
  714. def process_get_sentry_config_value(self, seqid, iprot, oprot):
  715. args = get_sentry_config_value_args()
  716. args.read(iprot)
  717. iprot.readMessageEnd()
  718. result = get_sentry_config_value_result()
  719. try:
  720. result.success = self._handler.get_sentry_config_value(args.request)
  721. msg_type = TMessageType.REPLY
  722. except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
  723. raise
  724. except Exception as ex:
  725. msg_type = TMessageType.EXCEPTION
  726. logging.exception(ex)
  727. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  728. oprot.writeMessageBegin("get_sentry_config_value", msg_type, seqid)
  729. result.write(oprot)
  730. oprot.writeMessageEnd()
  731. oprot.trans.flush()
  732. # HELPER FUNCTIONS AND STRUCTURES
  733. class create_sentry_role_args(object):
  734. """
  735. Attributes:
  736. - request
  737. """
  738. thrift_spec = (
  739. None, # 0
  740. (1, TType.STRUCT, 'request', (TCreateSentryRoleRequest, TCreateSentryRoleRequest.thrift_spec), None, ), # 1
  741. )
  742. def __init__(self, request=None,):
  743. self.request = request
  744. def read(self, iprot):
  745. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  746. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  747. return
  748. iprot.readStructBegin()
  749. while True:
  750. (fname, ftype, fid) = iprot.readFieldBegin()
  751. if ftype == TType.STOP:
  752. break
  753. if fid == 1:
  754. if ftype == TType.STRUCT:
  755. self.request = TCreateSentryRoleRequest()
  756. self.request.read(iprot)
  757. else:
  758. iprot.skip(ftype)
  759. else:
  760. iprot.skip(ftype)
  761. iprot.readFieldEnd()
  762. iprot.readStructEnd()
  763. def write(self, oprot):
  764. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  765. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  766. return
  767. oprot.writeStructBegin('create_sentry_role_args')
  768. if self.request is not None:
  769. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  770. self.request.write(oprot)
  771. oprot.writeFieldEnd()
  772. oprot.writeFieldStop()
  773. oprot.writeStructEnd()
  774. def validate(self):
  775. return
  776. def __hash__(self):
  777. value = 17
  778. value = (value * 31) ^ hash(self.request)
  779. return value
  780. def __repr__(self):
  781. L = ['%s=%r' % (key, value)
  782. for key, value in self.__dict__.iteritems()]
  783. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  784. def __eq__(self, other):
  785. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  786. def __ne__(self, other):
  787. return not (self == other)
  788. class create_sentry_role_result(object):
  789. """
  790. Attributes:
  791. - success
  792. """
  793. thrift_spec = (
  794. (0, TType.STRUCT, 'success', (TCreateSentryRoleResponse, TCreateSentryRoleResponse.thrift_spec), None, ), # 0
  795. )
  796. def __init__(self, success=None,):
  797. self.success = success
  798. def read(self, iprot):
  799. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  800. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  801. return
  802. iprot.readStructBegin()
  803. while True:
  804. (fname, ftype, fid) = iprot.readFieldBegin()
  805. if ftype == TType.STOP:
  806. break
  807. if fid == 0:
  808. if ftype == TType.STRUCT:
  809. self.success = TCreateSentryRoleResponse()
  810. self.success.read(iprot)
  811. else:
  812. iprot.skip(ftype)
  813. else:
  814. iprot.skip(ftype)
  815. iprot.readFieldEnd()
  816. iprot.readStructEnd()
  817. def write(self, oprot):
  818. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  819. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  820. return
  821. oprot.writeStructBegin('create_sentry_role_result')
  822. if self.success is not None:
  823. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  824. self.success.write(oprot)
  825. oprot.writeFieldEnd()
  826. oprot.writeFieldStop()
  827. oprot.writeStructEnd()
  828. def validate(self):
  829. return
  830. def __hash__(self):
  831. value = 17
  832. value = (value * 31) ^ hash(self.success)
  833. return value
  834. def __repr__(self):
  835. L = ['%s=%r' % (key, value)
  836. for key, value in self.__dict__.iteritems()]
  837. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  838. def __eq__(self, other):
  839. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  840. def __ne__(self, other):
  841. return not (self == other)
  842. class drop_sentry_role_args(object):
  843. """
  844. Attributes:
  845. - request
  846. """
  847. thrift_spec = (
  848. None, # 0
  849. (1, TType.STRUCT, 'request', (TDropSentryRoleRequest, TDropSentryRoleRequest.thrift_spec), None, ), # 1
  850. )
  851. def __init__(self, request=None,):
  852. self.request = request
  853. def read(self, iprot):
  854. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  855. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  856. return
  857. iprot.readStructBegin()
  858. while True:
  859. (fname, ftype, fid) = iprot.readFieldBegin()
  860. if ftype == TType.STOP:
  861. break
  862. if fid == 1:
  863. if ftype == TType.STRUCT:
  864. self.request = TDropSentryRoleRequest()
  865. self.request.read(iprot)
  866. else:
  867. iprot.skip(ftype)
  868. else:
  869. iprot.skip(ftype)
  870. iprot.readFieldEnd()
  871. iprot.readStructEnd()
  872. def write(self, oprot):
  873. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  874. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  875. return
  876. oprot.writeStructBegin('drop_sentry_role_args')
  877. if self.request is not None:
  878. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  879. self.request.write(oprot)
  880. oprot.writeFieldEnd()
  881. oprot.writeFieldStop()
  882. oprot.writeStructEnd()
  883. def validate(self):
  884. return
  885. def __hash__(self):
  886. value = 17
  887. value = (value * 31) ^ hash(self.request)
  888. return value
  889. def __repr__(self):
  890. L = ['%s=%r' % (key, value)
  891. for key, value in self.__dict__.iteritems()]
  892. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  893. def __eq__(self, other):
  894. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  895. def __ne__(self, other):
  896. return not (self == other)
  897. class drop_sentry_role_result(object):
  898. """
  899. Attributes:
  900. - success
  901. """
  902. thrift_spec = (
  903. (0, TType.STRUCT, 'success', (TDropSentryRoleResponse, TDropSentryRoleResponse.thrift_spec), None, ), # 0
  904. )
  905. def __init__(self, success=None,):
  906. self.success = success
  907. def read(self, iprot):
  908. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  909. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  910. return
  911. iprot.readStructBegin()
  912. while True:
  913. (fname, ftype, fid) = iprot.readFieldBegin()
  914. if ftype == TType.STOP:
  915. break
  916. if fid == 0:
  917. if ftype == TType.STRUCT:
  918. self.success = TDropSentryRoleResponse()
  919. self.success.read(iprot)
  920. else:
  921. iprot.skip(ftype)
  922. else:
  923. iprot.skip(ftype)
  924. iprot.readFieldEnd()
  925. iprot.readStructEnd()
  926. def write(self, oprot):
  927. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  928. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  929. return
  930. oprot.writeStructBegin('drop_sentry_role_result')
  931. if self.success is not None:
  932. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  933. self.success.write(oprot)
  934. oprot.writeFieldEnd()
  935. oprot.writeFieldStop()
  936. oprot.writeStructEnd()
  937. def validate(self):
  938. return
  939. def __hash__(self):
  940. value = 17
  941. value = (value * 31) ^ hash(self.success)
  942. return value
  943. def __repr__(self):
  944. L = ['%s=%r' % (key, value)
  945. for key, value in self.__dict__.iteritems()]
  946. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  947. def __eq__(self, other):
  948. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  949. def __ne__(self, other):
  950. return not (self == other)
  951. class alter_sentry_role_grant_privilege_args(object):
  952. """
  953. Attributes:
  954. - request
  955. """
  956. thrift_spec = (
  957. None, # 0
  958. (1, TType.STRUCT, 'request', (TAlterSentryRoleGrantPrivilegeRequest, TAlterSentryRoleGrantPrivilegeRequest.thrift_spec), None, ), # 1
  959. )
  960. def __init__(self, request=None,):
  961. self.request = request
  962. def read(self, iprot):
  963. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  964. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  965. return
  966. iprot.readStructBegin()
  967. while True:
  968. (fname, ftype, fid) = iprot.readFieldBegin()
  969. if ftype == TType.STOP:
  970. break
  971. if fid == 1:
  972. if ftype == TType.STRUCT:
  973. self.request = TAlterSentryRoleGrantPrivilegeRequest()
  974. self.request.read(iprot)
  975. else:
  976. iprot.skip(ftype)
  977. else:
  978. iprot.skip(ftype)
  979. iprot.readFieldEnd()
  980. iprot.readStructEnd()
  981. def write(self, oprot):
  982. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  983. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  984. return
  985. oprot.writeStructBegin('alter_sentry_role_grant_privilege_args')
  986. if self.request is not None:
  987. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  988. self.request.write(oprot)
  989. oprot.writeFieldEnd()
  990. oprot.writeFieldStop()
  991. oprot.writeStructEnd()
  992. def validate(self):
  993. return
  994. def __hash__(self):
  995. value = 17
  996. value = (value * 31) ^ hash(self.request)
  997. return value
  998. def __repr__(self):
  999. L = ['%s=%r' % (key, value)
  1000. for key, value in self.__dict__.iteritems()]
  1001. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1002. def __eq__(self, other):
  1003. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1004. def __ne__(self, other):
  1005. return not (self == other)
  1006. class alter_sentry_role_grant_privilege_result(object):
  1007. """
  1008. Attributes:
  1009. - success
  1010. """
  1011. thrift_spec = (
  1012. (0, TType.STRUCT, 'success', (TAlterSentryRoleGrantPrivilegeResponse, TAlterSentryRoleGrantPrivilegeResponse.thrift_spec), None, ), # 0
  1013. )
  1014. def __init__(self, success=None,):
  1015. self.success = success
  1016. def read(self, iprot):
  1017. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1018. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1019. return
  1020. iprot.readStructBegin()
  1021. while True:
  1022. (fname, ftype, fid) = iprot.readFieldBegin()
  1023. if ftype == TType.STOP:
  1024. break
  1025. if fid == 0:
  1026. if ftype == TType.STRUCT:
  1027. self.success = TAlterSentryRoleGrantPrivilegeResponse()
  1028. self.success.read(iprot)
  1029. else:
  1030. iprot.skip(ftype)
  1031. else:
  1032. iprot.skip(ftype)
  1033. iprot.readFieldEnd()
  1034. iprot.readStructEnd()
  1035. def write(self, oprot):
  1036. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1037. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1038. return
  1039. oprot.writeStructBegin('alter_sentry_role_grant_privilege_result')
  1040. if self.success is not None:
  1041. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1042. self.success.write(oprot)
  1043. oprot.writeFieldEnd()
  1044. oprot.writeFieldStop()
  1045. oprot.writeStructEnd()
  1046. def validate(self):
  1047. return
  1048. def __hash__(self):
  1049. value = 17
  1050. value = (value * 31) ^ hash(self.success)
  1051. return value
  1052. def __repr__(self):
  1053. L = ['%s=%r' % (key, value)
  1054. for key, value in self.__dict__.iteritems()]
  1055. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1056. def __eq__(self, other):
  1057. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1058. def __ne__(self, other):
  1059. return not (self == other)
  1060. class alter_sentry_role_revoke_privilege_args(object):
  1061. """
  1062. Attributes:
  1063. - request
  1064. """
  1065. thrift_spec = (
  1066. None, # 0
  1067. (1, TType.STRUCT, 'request', (TAlterSentryRoleRevokePrivilegeRequest, TAlterSentryRoleRevokePrivilegeRequest.thrift_spec), None, ), # 1
  1068. )
  1069. def __init__(self, request=None,):
  1070. self.request = request
  1071. def read(self, iprot):
  1072. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1073. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1074. return
  1075. iprot.readStructBegin()
  1076. while True:
  1077. (fname, ftype, fid) = iprot.readFieldBegin()
  1078. if ftype == TType.STOP:
  1079. break
  1080. if fid == 1:
  1081. if ftype == TType.STRUCT:
  1082. self.request = TAlterSentryRoleRevokePrivilegeRequest()
  1083. self.request.read(iprot)
  1084. else:
  1085. iprot.skip(ftype)
  1086. else:
  1087. iprot.skip(ftype)
  1088. iprot.readFieldEnd()
  1089. iprot.readStructEnd()
  1090. def write(self, oprot):
  1091. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1092. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1093. return
  1094. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_args')
  1095. if self.request is not None:
  1096. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1097. self.request.write(oprot)
  1098. oprot.writeFieldEnd()
  1099. oprot.writeFieldStop()
  1100. oprot.writeStructEnd()
  1101. def validate(self):
  1102. return
  1103. def __hash__(self):
  1104. value = 17
  1105. value = (value * 31) ^ hash(self.request)
  1106. return value
  1107. def __repr__(self):
  1108. L = ['%s=%r' % (key, value)
  1109. for key, value in self.__dict__.iteritems()]
  1110. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1111. def __eq__(self, other):
  1112. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1113. def __ne__(self, other):
  1114. return not (self == other)
  1115. class alter_sentry_role_revoke_privilege_result(object):
  1116. """
  1117. Attributes:
  1118. - success
  1119. """
  1120. thrift_spec = (
  1121. (0, TType.STRUCT, 'success', (TAlterSentryRoleRevokePrivilegeResponse, TAlterSentryRoleRevokePrivilegeResponse.thrift_spec), None, ), # 0
  1122. )
  1123. def __init__(self, success=None,):
  1124. self.success = success
  1125. def read(self, iprot):
  1126. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1127. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1128. return
  1129. iprot.readStructBegin()
  1130. while True:
  1131. (fname, ftype, fid) = iprot.readFieldBegin()
  1132. if ftype == TType.STOP:
  1133. break
  1134. if fid == 0:
  1135. if ftype == TType.STRUCT:
  1136. self.success = TAlterSentryRoleRevokePrivilegeResponse()
  1137. self.success.read(iprot)
  1138. else:
  1139. iprot.skip(ftype)
  1140. else:
  1141. iprot.skip(ftype)
  1142. iprot.readFieldEnd()
  1143. iprot.readStructEnd()
  1144. def write(self, oprot):
  1145. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1146. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1147. return
  1148. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_result')
  1149. if self.success is not None:
  1150. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1151. self.success.write(oprot)
  1152. oprot.writeFieldEnd()
  1153. oprot.writeFieldStop()
  1154. oprot.writeStructEnd()
  1155. def validate(self):
  1156. return
  1157. def __hash__(self):
  1158. value = 17
  1159. value = (value * 31) ^ hash(self.success)
  1160. return value
  1161. def __repr__(self):
  1162. L = ['%s=%r' % (key, value)
  1163. for key, value in self.__dict__.iteritems()]
  1164. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1165. def __eq__(self, other):
  1166. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1167. def __ne__(self, other):
  1168. return not (self == other)
  1169. class alter_sentry_role_add_groups_args(object):
  1170. """
  1171. Attributes:
  1172. - request
  1173. """
  1174. thrift_spec = (
  1175. None, # 0
  1176. (1, TType.STRUCT, 'request', (TAlterSentryRoleAddGroupsRequest, TAlterSentryRoleAddGroupsRequest.thrift_spec), None, ), # 1
  1177. )
  1178. def __init__(self, request=None,):
  1179. self.request = request
  1180. def read(self, iprot):
  1181. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1182. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1183. return
  1184. iprot.readStructBegin()
  1185. while True:
  1186. (fname, ftype, fid) = iprot.readFieldBegin()
  1187. if ftype == TType.STOP:
  1188. break
  1189. if fid == 1:
  1190. if ftype == TType.STRUCT:
  1191. self.request = TAlterSentryRoleAddGroupsRequest()
  1192. self.request.read(iprot)
  1193. else:
  1194. iprot.skip(ftype)
  1195. else:
  1196. iprot.skip(ftype)
  1197. iprot.readFieldEnd()
  1198. iprot.readStructEnd()
  1199. def write(self, oprot):
  1200. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1201. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1202. return
  1203. oprot.writeStructBegin('alter_sentry_role_add_groups_args')
  1204. if self.request is not None:
  1205. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1206. self.request.write(oprot)
  1207. oprot.writeFieldEnd()
  1208. oprot.writeFieldStop()
  1209. oprot.writeStructEnd()
  1210. def validate(self):
  1211. return
  1212. def __hash__(self):
  1213. value = 17
  1214. value = (value * 31) ^ hash(self.request)
  1215. return value
  1216. def __repr__(self):
  1217. L = ['%s=%r' % (key, value)
  1218. for key, value in self.__dict__.iteritems()]
  1219. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1220. def __eq__(self, other):
  1221. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1222. def __ne__(self, other):
  1223. return not (self == other)
  1224. class alter_sentry_role_add_groups_result(object):
  1225. """
  1226. Attributes:
  1227. - success
  1228. """
  1229. thrift_spec = (
  1230. (0, TType.STRUCT, 'success', (TAlterSentryRoleAddGroupsResponse, TAlterSentryRoleAddGroupsResponse.thrift_spec), None, ), # 0
  1231. )
  1232. def __init__(self, success=None,):
  1233. self.success = success
  1234. def read(self, iprot):
  1235. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1236. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1237. return
  1238. iprot.readStructBegin()
  1239. while True:
  1240. (fname, ftype, fid) = iprot.readFieldBegin()
  1241. if ftype == TType.STOP:
  1242. break
  1243. if fid == 0:
  1244. if ftype == TType.STRUCT:
  1245. self.success = TAlterSentryRoleAddGroupsResponse()
  1246. self.success.read(iprot)
  1247. else:
  1248. iprot.skip(ftype)
  1249. else:
  1250. iprot.skip(ftype)
  1251. iprot.readFieldEnd()
  1252. iprot.readStructEnd()
  1253. def write(self, oprot):
  1254. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1255. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1256. return
  1257. oprot.writeStructBegin('alter_sentry_role_add_groups_result')
  1258. if self.success is not None:
  1259. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1260. self.success.write(oprot)
  1261. oprot.writeFieldEnd()
  1262. oprot.writeFieldStop()
  1263. oprot.writeStructEnd()
  1264. def validate(self):
  1265. return
  1266. def __hash__(self):
  1267. value = 17
  1268. value = (value * 31) ^ hash(self.success)
  1269. return value
  1270. def __repr__(self):
  1271. L = ['%s=%r' % (key, value)
  1272. for key, value in self.__dict__.iteritems()]
  1273. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1274. def __eq__(self, other):
  1275. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1276. def __ne__(self, other):
  1277. return not (self == other)
  1278. class alter_sentry_role_delete_groups_args(object):
  1279. """
  1280. Attributes:
  1281. - request
  1282. """
  1283. thrift_spec = (
  1284. None, # 0
  1285. (1, TType.STRUCT, 'request', (TAlterSentryRoleDeleteGroupsRequest, TAlterSentryRoleDeleteGroupsRequest.thrift_spec), None, ), # 1
  1286. )
  1287. def __init__(self, request=None,):
  1288. self.request = request
  1289. def read(self, iprot):
  1290. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1291. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1292. return
  1293. iprot.readStructBegin()
  1294. while True:
  1295. (fname, ftype, fid) = iprot.readFieldBegin()
  1296. if ftype == TType.STOP:
  1297. break
  1298. if fid == 1:
  1299. if ftype == TType.STRUCT:
  1300. self.request = TAlterSentryRoleDeleteGroupsRequest()
  1301. self.request.read(iprot)
  1302. else:
  1303. iprot.skip(ftype)
  1304. else:
  1305. iprot.skip(ftype)
  1306. iprot.readFieldEnd()
  1307. iprot.readStructEnd()
  1308. def write(self, oprot):
  1309. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1310. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1311. return
  1312. oprot.writeStructBegin('alter_sentry_role_delete_groups_args')
  1313. if self.request is not None:
  1314. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1315. self.request.write(oprot)
  1316. oprot.writeFieldEnd()
  1317. oprot.writeFieldStop()
  1318. oprot.writeStructEnd()
  1319. def validate(self):
  1320. return
  1321. def __hash__(self):
  1322. value = 17
  1323. value = (value * 31) ^ hash(self.request)
  1324. return value
  1325. def __repr__(self):
  1326. L = ['%s=%r' % (key, value)
  1327. for key, value in self.__dict__.iteritems()]
  1328. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1329. def __eq__(self, other):
  1330. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1331. def __ne__(self, other):
  1332. return not (self == other)
  1333. class alter_sentry_role_delete_groups_result(object):
  1334. """
  1335. Attributes:
  1336. - success
  1337. """
  1338. thrift_spec = (
  1339. (0, TType.STRUCT, 'success', (TAlterSentryRoleDeleteGroupsResponse, TAlterSentryRoleDeleteGroupsResponse.thrift_spec), None, ), # 0
  1340. )
  1341. def __init__(self, success=None,):
  1342. self.success = success
  1343. def read(self, iprot):
  1344. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1345. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1346. return
  1347. iprot.readStructBegin()
  1348. while True:
  1349. (fname, ftype, fid) = iprot.readFieldBegin()
  1350. if ftype == TType.STOP:
  1351. break
  1352. if fid == 0:
  1353. if ftype == TType.STRUCT:
  1354. self.success = TAlterSentryRoleDeleteGroupsResponse()
  1355. self.success.read(iprot)
  1356. else:
  1357. iprot.skip(ftype)
  1358. else:
  1359. iprot.skip(ftype)
  1360. iprot.readFieldEnd()
  1361. iprot.readStructEnd()
  1362. def write(self, oprot):
  1363. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1364. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1365. return
  1366. oprot.writeStructBegin('alter_sentry_role_delete_groups_result')
  1367. if self.success is not None:
  1368. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1369. self.success.write(oprot)
  1370. oprot.writeFieldEnd()
  1371. oprot.writeFieldStop()
  1372. oprot.writeStructEnd()
  1373. def validate(self):
  1374. return
  1375. def __hash__(self):
  1376. value = 17
  1377. value = (value * 31) ^ hash(self.success)
  1378. return value
  1379. def __repr__(self):
  1380. L = ['%s=%r' % (key, value)
  1381. for key, value in self.__dict__.iteritems()]
  1382. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1383. def __eq__(self, other):
  1384. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1385. def __ne__(self, other):
  1386. return not (self == other)
  1387. class list_sentry_roles_by_group_args(object):
  1388. """
  1389. Attributes:
  1390. - request
  1391. """
  1392. thrift_spec = (
  1393. None, # 0
  1394. (1, TType.STRUCT, 'request', (TListSentryRolesRequest, TListSentryRolesRequest.thrift_spec), None, ), # 1
  1395. )
  1396. def __init__(self, request=None,):
  1397. self.request = request
  1398. def read(self, iprot):
  1399. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1400. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1401. return
  1402. iprot.readStructBegin()
  1403. while True:
  1404. (fname, ftype, fid) = iprot.readFieldBegin()
  1405. if ftype == TType.STOP:
  1406. break
  1407. if fid == 1:
  1408. if ftype == TType.STRUCT:
  1409. self.request = TListSentryRolesRequest()
  1410. self.request.read(iprot)
  1411. else:
  1412. iprot.skip(ftype)
  1413. else:
  1414. iprot.skip(ftype)
  1415. iprot.readFieldEnd()
  1416. iprot.readStructEnd()
  1417. def write(self, oprot):
  1418. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1419. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1420. return
  1421. oprot.writeStructBegin('list_sentry_roles_by_group_args')
  1422. if self.request is not None:
  1423. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1424. self.request.write(oprot)
  1425. oprot.writeFieldEnd()
  1426. oprot.writeFieldStop()
  1427. oprot.writeStructEnd()
  1428. def validate(self):
  1429. return
  1430. def __hash__(self):
  1431. value = 17
  1432. value = (value * 31) ^ hash(self.request)
  1433. return value
  1434. def __repr__(self):
  1435. L = ['%s=%r' % (key, value)
  1436. for key, value in self.__dict__.iteritems()]
  1437. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1438. def __eq__(self, other):
  1439. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1440. def __ne__(self, other):
  1441. return not (self == other)
  1442. class list_sentry_roles_by_group_result(object):
  1443. """
  1444. Attributes:
  1445. - success
  1446. """
  1447. thrift_spec = (
  1448. (0, TType.STRUCT, 'success', (TListSentryRolesResponse, TListSentryRolesResponse.thrift_spec), None, ), # 0
  1449. )
  1450. def __init__(self, success=None,):
  1451. self.success = success
  1452. def read(self, iprot):
  1453. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1454. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1455. return
  1456. iprot.readStructBegin()
  1457. while True:
  1458. (fname, ftype, fid) = iprot.readFieldBegin()
  1459. if ftype == TType.STOP:
  1460. break
  1461. if fid == 0:
  1462. if ftype == TType.STRUCT:
  1463. self.success = TListSentryRolesResponse()
  1464. self.success.read(iprot)
  1465. else:
  1466. iprot.skip(ftype)
  1467. else:
  1468. iprot.skip(ftype)
  1469. iprot.readFieldEnd()
  1470. iprot.readStructEnd()
  1471. def write(self, oprot):
  1472. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1473. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1474. return
  1475. oprot.writeStructBegin('list_sentry_roles_by_group_result')
  1476. if self.success is not None:
  1477. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1478. self.success.write(oprot)
  1479. oprot.writeFieldEnd()
  1480. oprot.writeFieldStop()
  1481. oprot.writeStructEnd()
  1482. def validate(self):
  1483. return
  1484. def __hash__(self):
  1485. value = 17
  1486. value = (value * 31) ^ hash(self.success)
  1487. return value
  1488. def __repr__(self):
  1489. L = ['%s=%r' % (key, value)
  1490. for key, value in self.__dict__.iteritems()]
  1491. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1492. def __eq__(self, other):
  1493. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1494. def __ne__(self, other):
  1495. return not (self == other)
  1496. class list_sentry_privileges_by_role_args(object):
  1497. """
  1498. Attributes:
  1499. - request
  1500. """
  1501. thrift_spec = (
  1502. None, # 0
  1503. (1, TType.STRUCT, 'request', (TListSentryPrivilegesRequest, TListSentryPrivilegesRequest.thrift_spec), None, ), # 1
  1504. )
  1505. def __init__(self, request=None,):
  1506. self.request = request
  1507. def read(self, iprot):
  1508. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1509. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1510. return
  1511. iprot.readStructBegin()
  1512. while True:
  1513. (fname, ftype, fid) = iprot.readFieldBegin()
  1514. if ftype == TType.STOP:
  1515. break
  1516. if fid == 1:
  1517. if ftype == TType.STRUCT:
  1518. self.request = TListSentryPrivilegesRequest()
  1519. self.request.read(iprot)
  1520. else:
  1521. iprot.skip(ftype)
  1522. else:
  1523. iprot.skip(ftype)
  1524. iprot.readFieldEnd()
  1525. iprot.readStructEnd()
  1526. def write(self, oprot):
  1527. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1528. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1529. return
  1530. oprot.writeStructBegin('list_sentry_privileges_by_role_args')
  1531. if self.request is not None:
  1532. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1533. self.request.write(oprot)
  1534. oprot.writeFieldEnd()
  1535. oprot.writeFieldStop()
  1536. oprot.writeStructEnd()
  1537. def validate(self):
  1538. return
  1539. def __hash__(self):
  1540. value = 17
  1541. value = (value * 31) ^ hash(self.request)
  1542. return value
  1543. def __repr__(self):
  1544. L = ['%s=%r' % (key, value)
  1545. for key, value in self.__dict__.iteritems()]
  1546. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1547. def __eq__(self, other):
  1548. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1549. def __ne__(self, other):
  1550. return not (self == other)
  1551. class list_sentry_privileges_by_role_result(object):
  1552. """
  1553. Attributes:
  1554. - success
  1555. """
  1556. thrift_spec = (
  1557. (0, TType.STRUCT, 'success', (TListSentryPrivilegesResponse, TListSentryPrivilegesResponse.thrift_spec), None, ), # 0
  1558. )
  1559. def __init__(self, success=None,):
  1560. self.success = success
  1561. def read(self, iprot):
  1562. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1563. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1564. return
  1565. iprot.readStructBegin()
  1566. while True:
  1567. (fname, ftype, fid) = iprot.readFieldBegin()
  1568. if ftype == TType.STOP:
  1569. break
  1570. if fid == 0:
  1571. if ftype == TType.STRUCT:
  1572. self.success = TListSentryPrivilegesResponse()
  1573. self.success.read(iprot)
  1574. else:
  1575. iprot.skip(ftype)
  1576. else:
  1577. iprot.skip(ftype)
  1578. iprot.readFieldEnd()
  1579. iprot.readStructEnd()
  1580. def write(self, oprot):
  1581. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1582. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1583. return
  1584. oprot.writeStructBegin('list_sentry_privileges_by_role_result')
  1585. if self.success is not None:
  1586. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1587. self.success.write(oprot)
  1588. oprot.writeFieldEnd()
  1589. oprot.writeFieldStop()
  1590. oprot.writeStructEnd()
  1591. def validate(self):
  1592. return
  1593. def __hash__(self):
  1594. value = 17
  1595. value = (value * 31) ^ hash(self.success)
  1596. return value
  1597. def __repr__(self):
  1598. L = ['%s=%r' % (key, value)
  1599. for key, value in self.__dict__.iteritems()]
  1600. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1601. def __eq__(self, other):
  1602. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1603. def __ne__(self, other):
  1604. return not (self == other)
  1605. class list_sentry_privileges_for_provider_args(object):
  1606. """
  1607. Attributes:
  1608. - request
  1609. """
  1610. thrift_spec = (
  1611. None, # 0
  1612. (1, TType.STRUCT, 'request', (TListSentryPrivilegesForProviderRequest, TListSentryPrivilegesForProviderRequest.thrift_spec), None, ), # 1
  1613. )
  1614. def __init__(self, request=None,):
  1615. self.request = request
  1616. def read(self, iprot):
  1617. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1618. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1619. return
  1620. iprot.readStructBegin()
  1621. while True:
  1622. (fname, ftype, fid) = iprot.readFieldBegin()
  1623. if ftype == TType.STOP:
  1624. break
  1625. if fid == 1:
  1626. if ftype == TType.STRUCT:
  1627. self.request = TListSentryPrivilegesForProviderRequest()
  1628. self.request.read(iprot)
  1629. else:
  1630. iprot.skip(ftype)
  1631. else:
  1632. iprot.skip(ftype)
  1633. iprot.readFieldEnd()
  1634. iprot.readStructEnd()
  1635. def write(self, oprot):
  1636. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1637. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1638. return
  1639. oprot.writeStructBegin('list_sentry_privileges_for_provider_args')
  1640. if self.request is not None:
  1641. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1642. self.request.write(oprot)
  1643. oprot.writeFieldEnd()
  1644. oprot.writeFieldStop()
  1645. oprot.writeStructEnd()
  1646. def validate(self):
  1647. return
  1648. def __hash__(self):
  1649. value = 17
  1650. value = (value * 31) ^ hash(self.request)
  1651. return value
  1652. def __repr__(self):
  1653. L = ['%s=%r' % (key, value)
  1654. for key, value in self.__dict__.iteritems()]
  1655. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1656. def __eq__(self, other):
  1657. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1658. def __ne__(self, other):
  1659. return not (self == other)
  1660. class list_sentry_privileges_for_provider_result(object):
  1661. """
  1662. Attributes:
  1663. - success
  1664. """
  1665. thrift_spec = (
  1666. (0, TType.STRUCT, 'success', (TListSentryPrivilegesForProviderResponse, TListSentryPrivilegesForProviderResponse.thrift_spec), None, ), # 0
  1667. )
  1668. def __init__(self, success=None,):
  1669. self.success = success
  1670. def read(self, iprot):
  1671. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1672. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1673. return
  1674. iprot.readStructBegin()
  1675. while True:
  1676. (fname, ftype, fid) = iprot.readFieldBegin()
  1677. if ftype == TType.STOP:
  1678. break
  1679. if fid == 0:
  1680. if ftype == TType.STRUCT:
  1681. self.success = TListSentryPrivilegesForProviderResponse()
  1682. self.success.read(iprot)
  1683. else:
  1684. iprot.skip(ftype)
  1685. else:
  1686. iprot.skip(ftype)
  1687. iprot.readFieldEnd()
  1688. iprot.readStructEnd()
  1689. def write(self, oprot):
  1690. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1691. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1692. return
  1693. oprot.writeStructBegin('list_sentry_privileges_for_provider_result')
  1694. if self.success is not None:
  1695. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1696. self.success.write(oprot)
  1697. oprot.writeFieldEnd()
  1698. oprot.writeFieldStop()
  1699. oprot.writeStructEnd()
  1700. def validate(self):
  1701. return
  1702. def __hash__(self):
  1703. value = 17
  1704. value = (value * 31) ^ hash(self.success)
  1705. return value
  1706. def __repr__(self):
  1707. L = ['%s=%r' % (key, value)
  1708. for key, value in self.__dict__.iteritems()]
  1709. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1710. def __eq__(self, other):
  1711. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1712. def __ne__(self, other):
  1713. return not (self == other)
  1714. class drop_sentry_privilege_args(object):
  1715. """
  1716. Attributes:
  1717. - request
  1718. """
  1719. thrift_spec = (
  1720. None, # 0
  1721. (1, TType.STRUCT, 'request', (TDropPrivilegesRequest, TDropPrivilegesRequest.thrift_spec), None, ), # 1
  1722. )
  1723. def __init__(self, request=None,):
  1724. self.request = request
  1725. def read(self, iprot):
  1726. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1727. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1728. return
  1729. iprot.readStructBegin()
  1730. while True:
  1731. (fname, ftype, fid) = iprot.readFieldBegin()
  1732. if ftype == TType.STOP:
  1733. break
  1734. if fid == 1:
  1735. if ftype == TType.STRUCT:
  1736. self.request = TDropPrivilegesRequest()
  1737. self.request.read(iprot)
  1738. else:
  1739. iprot.skip(ftype)
  1740. else:
  1741. iprot.skip(ftype)
  1742. iprot.readFieldEnd()
  1743. iprot.readStructEnd()
  1744. def write(self, oprot):
  1745. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1746. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1747. return
  1748. oprot.writeStructBegin('drop_sentry_privilege_args')
  1749. if self.request is not None:
  1750. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1751. self.request.write(oprot)
  1752. oprot.writeFieldEnd()
  1753. oprot.writeFieldStop()
  1754. oprot.writeStructEnd()
  1755. def validate(self):
  1756. return
  1757. def __hash__(self):
  1758. value = 17
  1759. value = (value * 31) ^ hash(self.request)
  1760. return value
  1761. def __repr__(self):
  1762. L = ['%s=%r' % (key, value)
  1763. for key, value in self.__dict__.iteritems()]
  1764. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1765. def __eq__(self, other):
  1766. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1767. def __ne__(self, other):
  1768. return not (self == other)
  1769. class drop_sentry_privilege_result(object):
  1770. """
  1771. Attributes:
  1772. - success
  1773. """
  1774. thrift_spec = (
  1775. (0, TType.STRUCT, 'success', (TDropPrivilegesResponse, TDropPrivilegesResponse.thrift_spec), None, ), # 0
  1776. )
  1777. def __init__(self, success=None,):
  1778. self.success = success
  1779. def read(self, iprot):
  1780. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1781. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1782. return
  1783. iprot.readStructBegin()
  1784. while True:
  1785. (fname, ftype, fid) = iprot.readFieldBegin()
  1786. if ftype == TType.STOP:
  1787. break
  1788. if fid == 0:
  1789. if ftype == TType.STRUCT:
  1790. self.success = TDropPrivilegesResponse()
  1791. self.success.read(iprot)
  1792. else:
  1793. iprot.skip(ftype)
  1794. else:
  1795. iprot.skip(ftype)
  1796. iprot.readFieldEnd()
  1797. iprot.readStructEnd()
  1798. def write(self, oprot):
  1799. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1800. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1801. return
  1802. oprot.writeStructBegin('drop_sentry_privilege_result')
  1803. if self.success is not None:
  1804. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1805. self.success.write(oprot)
  1806. oprot.writeFieldEnd()
  1807. oprot.writeFieldStop()
  1808. oprot.writeStructEnd()
  1809. def validate(self):
  1810. return
  1811. def __hash__(self):
  1812. value = 17
  1813. value = (value * 31) ^ hash(self.success)
  1814. return value
  1815. def __repr__(self):
  1816. L = ['%s=%r' % (key, value)
  1817. for key, value in self.__dict__.iteritems()]
  1818. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1819. def __eq__(self, other):
  1820. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1821. def __ne__(self, other):
  1822. return not (self == other)
  1823. class rename_sentry_privilege_args(object):
  1824. """
  1825. Attributes:
  1826. - request
  1827. """
  1828. thrift_spec = (
  1829. None, # 0
  1830. (1, TType.STRUCT, 'request', (TRenamePrivilegesRequest, TRenamePrivilegesRequest.thrift_spec), None, ), # 1
  1831. )
  1832. def __init__(self, request=None,):
  1833. self.request = request
  1834. def read(self, iprot):
  1835. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1836. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1837. return
  1838. iprot.readStructBegin()
  1839. while True:
  1840. (fname, ftype, fid) = iprot.readFieldBegin()
  1841. if ftype == TType.STOP:
  1842. break
  1843. if fid == 1:
  1844. if ftype == TType.STRUCT:
  1845. self.request = TRenamePrivilegesRequest()
  1846. self.request.read(iprot)
  1847. else:
  1848. iprot.skip(ftype)
  1849. else:
  1850. iprot.skip(ftype)
  1851. iprot.readFieldEnd()
  1852. iprot.readStructEnd()
  1853. def write(self, oprot):
  1854. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1855. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1856. return
  1857. oprot.writeStructBegin('rename_sentry_privilege_args')
  1858. if self.request is not None:
  1859. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1860. self.request.write(oprot)
  1861. oprot.writeFieldEnd()
  1862. oprot.writeFieldStop()
  1863. oprot.writeStructEnd()
  1864. def validate(self):
  1865. return
  1866. def __hash__(self):
  1867. value = 17
  1868. value = (value * 31) ^ hash(self.request)
  1869. return value
  1870. def __repr__(self):
  1871. L = ['%s=%r' % (key, value)
  1872. for key, value in self.__dict__.iteritems()]
  1873. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1874. def __eq__(self, other):
  1875. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1876. def __ne__(self, other):
  1877. return not (self == other)
  1878. class rename_sentry_privilege_result(object):
  1879. """
  1880. Attributes:
  1881. - success
  1882. """
  1883. thrift_spec = (
  1884. (0, TType.STRUCT, 'success', (TRenamePrivilegesResponse, TRenamePrivilegesResponse.thrift_spec), None, ), # 0
  1885. )
  1886. def __init__(self, success=None,):
  1887. self.success = success
  1888. def read(self, iprot):
  1889. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1890. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1891. return
  1892. iprot.readStructBegin()
  1893. while True:
  1894. (fname, ftype, fid) = iprot.readFieldBegin()
  1895. if ftype == TType.STOP:
  1896. break
  1897. if fid == 0:
  1898. if ftype == TType.STRUCT:
  1899. self.success = TRenamePrivilegesResponse()
  1900. self.success.read(iprot)
  1901. else:
  1902. iprot.skip(ftype)
  1903. else:
  1904. iprot.skip(ftype)
  1905. iprot.readFieldEnd()
  1906. iprot.readStructEnd()
  1907. def write(self, oprot):
  1908. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1909. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1910. return
  1911. oprot.writeStructBegin('rename_sentry_privilege_result')
  1912. if self.success is not None:
  1913. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1914. self.success.write(oprot)
  1915. oprot.writeFieldEnd()
  1916. oprot.writeFieldStop()
  1917. oprot.writeStructEnd()
  1918. def validate(self):
  1919. return
  1920. def __hash__(self):
  1921. value = 17
  1922. value = (value * 31) ^ hash(self.success)
  1923. return value
  1924. def __repr__(self):
  1925. L = ['%s=%r' % (key, value)
  1926. for key, value in self.__dict__.iteritems()]
  1927. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1928. def __eq__(self, other):
  1929. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1930. def __ne__(self, other):
  1931. return not (self == other)
  1932. class list_sentry_privileges_by_authorizable_args(object):
  1933. """
  1934. Attributes:
  1935. - request
  1936. """
  1937. thrift_spec = (
  1938. None, # 0
  1939. (1, TType.STRUCT, 'request', (TListSentryPrivilegesByAuthRequest, TListSentryPrivilegesByAuthRequest.thrift_spec), None, ), # 1
  1940. )
  1941. def __init__(self, request=None,):
  1942. self.request = request
  1943. def read(self, iprot):
  1944. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1945. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1946. return
  1947. iprot.readStructBegin()
  1948. while True:
  1949. (fname, ftype, fid) = iprot.readFieldBegin()
  1950. if ftype == TType.STOP:
  1951. break
  1952. if fid == 1:
  1953. if ftype == TType.STRUCT:
  1954. self.request = TListSentryPrivilegesByAuthRequest()
  1955. self.request.read(iprot)
  1956. else:
  1957. iprot.skip(ftype)
  1958. else:
  1959. iprot.skip(ftype)
  1960. iprot.readFieldEnd()
  1961. iprot.readStructEnd()
  1962. def write(self, oprot):
  1963. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1964. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1965. return
  1966. oprot.writeStructBegin('list_sentry_privileges_by_authorizable_args')
  1967. if self.request is not None:
  1968. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1969. self.request.write(oprot)
  1970. oprot.writeFieldEnd()
  1971. oprot.writeFieldStop()
  1972. oprot.writeStructEnd()
  1973. def validate(self):
  1974. return
  1975. def __hash__(self):
  1976. value = 17
  1977. value = (value * 31) ^ hash(self.request)
  1978. return value
  1979. def __repr__(self):
  1980. L = ['%s=%r' % (key, value)
  1981. for key, value in self.__dict__.iteritems()]
  1982. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1983. def __eq__(self, other):
  1984. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1985. def __ne__(self, other):
  1986. return not (self == other)
  1987. class list_sentry_privileges_by_authorizable_result(object):
  1988. """
  1989. Attributes:
  1990. - success
  1991. """
  1992. thrift_spec = (
  1993. (0, TType.STRUCT, 'success', (TListSentryPrivilegesByAuthResponse, TListSentryPrivilegesByAuthResponse.thrift_spec), None, ), # 0
  1994. )
  1995. def __init__(self, success=None,):
  1996. self.success = success
  1997. def read(self, iprot):
  1998. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1999. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2000. return
  2001. iprot.readStructBegin()
  2002. while True:
  2003. (fname, ftype, fid) = iprot.readFieldBegin()
  2004. if ftype == TType.STOP:
  2005. break
  2006. if fid == 0:
  2007. if ftype == TType.STRUCT:
  2008. self.success = TListSentryPrivilegesByAuthResponse()
  2009. self.success.read(iprot)
  2010. else:
  2011. iprot.skip(ftype)
  2012. else:
  2013. iprot.skip(ftype)
  2014. iprot.readFieldEnd()
  2015. iprot.readStructEnd()
  2016. def write(self, oprot):
  2017. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2018. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2019. return
  2020. oprot.writeStructBegin('list_sentry_privileges_by_authorizable_result')
  2021. if self.success is not None:
  2022. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2023. self.success.write(oprot)
  2024. oprot.writeFieldEnd()
  2025. oprot.writeFieldStop()
  2026. oprot.writeStructEnd()
  2027. def validate(self):
  2028. return
  2029. def __hash__(self):
  2030. value = 17
  2031. value = (value * 31) ^ hash(self.success)
  2032. return value
  2033. def __repr__(self):
  2034. L = ['%s=%r' % (key, value)
  2035. for key, value in self.__dict__.iteritems()]
  2036. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2037. def __eq__(self, other):
  2038. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2039. def __ne__(self, other):
  2040. return not (self == other)
  2041. class get_sentry_config_value_args(object):
  2042. """
  2043. Attributes:
  2044. - request
  2045. """
  2046. thrift_spec = (
  2047. None, # 0
  2048. (1, TType.STRUCT, 'request', (TSentryConfigValueRequest, TSentryConfigValueRequest.thrift_spec), None, ), # 1
  2049. )
  2050. def __init__(self, request=None,):
  2051. self.request = request
  2052. def read(self, iprot):
  2053. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2054. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2055. return
  2056. iprot.readStructBegin()
  2057. while True:
  2058. (fname, ftype, fid) = iprot.readFieldBegin()
  2059. if ftype == TType.STOP:
  2060. break
  2061. if fid == 1:
  2062. if ftype == TType.STRUCT:
  2063. self.request = TSentryConfigValueRequest()
  2064. self.request.read(iprot)
  2065. else:
  2066. iprot.skip(ftype)
  2067. else:
  2068. iprot.skip(ftype)
  2069. iprot.readFieldEnd()
  2070. iprot.readStructEnd()
  2071. def write(self, oprot):
  2072. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2073. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2074. return
  2075. oprot.writeStructBegin('get_sentry_config_value_args')
  2076. if self.request is not None:
  2077. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  2078. self.request.write(oprot)
  2079. oprot.writeFieldEnd()
  2080. oprot.writeFieldStop()
  2081. oprot.writeStructEnd()
  2082. def validate(self):
  2083. return
  2084. def __hash__(self):
  2085. value = 17
  2086. value = (value * 31) ^ hash(self.request)
  2087. return value
  2088. def __repr__(self):
  2089. L = ['%s=%r' % (key, value)
  2090. for key, value in self.__dict__.iteritems()]
  2091. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2092. def __eq__(self, other):
  2093. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2094. def __ne__(self, other):
  2095. return not (self == other)
  2096. class get_sentry_config_value_result(object):
  2097. """
  2098. Attributes:
  2099. - success
  2100. """
  2101. thrift_spec = (
  2102. (0, TType.STRUCT, 'success', (TSentryConfigValueResponse, TSentryConfigValueResponse.thrift_spec), None, ), # 0
  2103. )
  2104. def __init__(self, success=None,):
  2105. self.success = success
  2106. def read(self, iprot):
  2107. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2108. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2109. return
  2110. iprot.readStructBegin()
  2111. while True:
  2112. (fname, ftype, fid) = iprot.readFieldBegin()
  2113. if ftype == TType.STOP:
  2114. break
  2115. if fid == 0:
  2116. if ftype == TType.STRUCT:
  2117. self.success = TSentryConfigValueResponse()
  2118. self.success.read(iprot)
  2119. else:
  2120. iprot.skip(ftype)
  2121. else:
  2122. iprot.skip(ftype)
  2123. iprot.readFieldEnd()
  2124. iprot.readStructEnd()
  2125. def write(self, oprot):
  2126. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2127. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2128. return
  2129. oprot.writeStructBegin('get_sentry_config_value_result')
  2130. if self.success is not None:
  2131. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2132. self.success.write(oprot)
  2133. oprot.writeFieldEnd()
  2134. oprot.writeFieldStop()
  2135. oprot.writeStructEnd()
  2136. def validate(self):
  2137. return
  2138. def __hash__(self):
  2139. value = 17
  2140. value = (value * 31) ^ hash(self.success)
  2141. return value
  2142. def __repr__(self):
  2143. L = ['%s=%r' % (key, value)
  2144. for key, value in self.__dict__.iteritems()]
  2145. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2146. def __eq__(self, other):
  2147. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2148. def __ne__(self, other):
  2149. return not (self == other)