SentryPolicyService.py 79 KB

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