SentryPolicyService.py 67 KB

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