SentryGenericPolicyService.py 73 KB

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