SentryGenericPolicyService.py 73 KB

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