SentryPolicyService.py 51 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581
  1. #
  2. # Autogenerated by Thrift Compiler (0.9.0)
  3. #
  4. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5. #
  6. # options string: py:new_style
  7. #
  8. from thrift.Thrift import TType, TMessageType, TException, TApplicationException
  9. from ttypes import *
  10. from thrift.Thrift import TProcessor
  11. from thrift.transport import TTransport
  12. from thrift.protocol import TBinaryProtocol, TProtocol
  13. try:
  14. from thrift.protocol import fastbinary
  15. except:
  16. fastbinary = None
  17. class Iface(object):
  18. def create_sentry_role(self, request):
  19. """
  20. Parameters:
  21. - request
  22. """
  23. pass
  24. def drop_sentry_role(self, request):
  25. """
  26. Parameters:
  27. - request
  28. """
  29. pass
  30. def alter_sentry_role_grant_privilege(self, request):
  31. """
  32. Parameters:
  33. - request
  34. """
  35. pass
  36. def alter_sentry_role_revoke_privilege(self, request):
  37. """
  38. Parameters:
  39. - request
  40. """
  41. pass
  42. def alter_sentry_role_add_groups(self, request):
  43. """
  44. Parameters:
  45. - request
  46. """
  47. pass
  48. def alter_sentry_role_delete_groups(self, request):
  49. """
  50. Parameters:
  51. - request
  52. """
  53. pass
  54. def list_sentry_roles_by_group(self, request):
  55. """
  56. Parameters:
  57. - request
  58. """
  59. pass
  60. def list_sentry_privileges_by_role(self, request):
  61. """
  62. Parameters:
  63. - request
  64. """
  65. pass
  66. def list_sentry_privileges_for_provider(self, request):
  67. """
  68. Parameters:
  69. - request
  70. """
  71. pass
  72. class Client(Iface):
  73. def __init__(self, iprot, oprot=None):
  74. self._iprot = self._oprot = iprot
  75. if oprot is not None:
  76. self._oprot = oprot
  77. self._seqid = 0
  78. def create_sentry_role(self, request):
  79. """
  80. Parameters:
  81. - request
  82. """
  83. self.send_create_sentry_role(request)
  84. return self.recv_create_sentry_role()
  85. def send_create_sentry_role(self, request):
  86. self._oprot.writeMessageBegin('create_sentry_role', TMessageType.CALL, self._seqid)
  87. args = create_sentry_role_args()
  88. args.request = request
  89. args.write(self._oprot)
  90. self._oprot.writeMessageEnd()
  91. self._oprot.trans.flush()
  92. def recv_create_sentry_role(self, ):
  93. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  94. if mtype == TMessageType.EXCEPTION:
  95. x = TApplicationException()
  96. x.read(self._iprot)
  97. self._iprot.readMessageEnd()
  98. raise x
  99. result = create_sentry_role_result()
  100. result.read(self._iprot)
  101. self._iprot.readMessageEnd()
  102. if result.success is not None:
  103. return result.success
  104. raise TApplicationException(TApplicationException.MISSING_RESULT, "create_sentry_role failed: unknown result");
  105. def drop_sentry_role(self, request):
  106. """
  107. Parameters:
  108. - request
  109. """
  110. self.send_drop_sentry_role(request)
  111. return self.recv_drop_sentry_role()
  112. def send_drop_sentry_role(self, request):
  113. self._oprot.writeMessageBegin('drop_sentry_role', TMessageType.CALL, self._seqid)
  114. args = drop_sentry_role_args()
  115. args.request = request
  116. args.write(self._oprot)
  117. self._oprot.writeMessageEnd()
  118. self._oprot.trans.flush()
  119. def recv_drop_sentry_role(self, ):
  120. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  121. if mtype == TMessageType.EXCEPTION:
  122. x = TApplicationException()
  123. x.read(self._iprot)
  124. self._iprot.readMessageEnd()
  125. raise x
  126. result = drop_sentry_role_result()
  127. result.read(self._iprot)
  128. self._iprot.readMessageEnd()
  129. if result.success is not None:
  130. return result.success
  131. raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_sentry_role failed: unknown result");
  132. def alter_sentry_role_grant_privilege(self, request):
  133. """
  134. Parameters:
  135. - request
  136. """
  137. self.send_alter_sentry_role_grant_privilege(request)
  138. return self.recv_alter_sentry_role_grant_privilege()
  139. def send_alter_sentry_role_grant_privilege(self, request):
  140. self._oprot.writeMessageBegin('alter_sentry_role_grant_privilege', TMessageType.CALL, self._seqid)
  141. args = alter_sentry_role_grant_privilege_args()
  142. args.request = request
  143. args.write(self._oprot)
  144. self._oprot.writeMessageEnd()
  145. self._oprot.trans.flush()
  146. def recv_alter_sentry_role_grant_privilege(self, ):
  147. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  148. if mtype == TMessageType.EXCEPTION:
  149. x = TApplicationException()
  150. x.read(self._iprot)
  151. self._iprot.readMessageEnd()
  152. raise x
  153. result = alter_sentry_role_grant_privilege_result()
  154. result.read(self._iprot)
  155. self._iprot.readMessageEnd()
  156. if result.success is not None:
  157. return result.success
  158. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_grant_privilege failed: unknown result");
  159. def alter_sentry_role_revoke_privilege(self, request):
  160. """
  161. Parameters:
  162. - request
  163. """
  164. self.send_alter_sentry_role_revoke_privilege(request)
  165. return self.recv_alter_sentry_role_revoke_privilege()
  166. def send_alter_sentry_role_revoke_privilege(self, request):
  167. self._oprot.writeMessageBegin('alter_sentry_role_revoke_privilege', TMessageType.CALL, self._seqid)
  168. args = alter_sentry_role_revoke_privilege_args()
  169. args.request = request
  170. args.write(self._oprot)
  171. self._oprot.writeMessageEnd()
  172. self._oprot.trans.flush()
  173. def recv_alter_sentry_role_revoke_privilege(self, ):
  174. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  175. if mtype == TMessageType.EXCEPTION:
  176. x = TApplicationException()
  177. x.read(self._iprot)
  178. self._iprot.readMessageEnd()
  179. raise x
  180. result = alter_sentry_role_revoke_privilege_result()
  181. result.read(self._iprot)
  182. self._iprot.readMessageEnd()
  183. if result.success is not None:
  184. return result.success
  185. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_revoke_privilege failed: unknown result");
  186. def alter_sentry_role_add_groups(self, request):
  187. """
  188. Parameters:
  189. - request
  190. """
  191. self.send_alter_sentry_role_add_groups(request)
  192. return self.recv_alter_sentry_role_add_groups()
  193. def send_alter_sentry_role_add_groups(self, request):
  194. self._oprot.writeMessageBegin('alter_sentry_role_add_groups', TMessageType.CALL, self._seqid)
  195. args = alter_sentry_role_add_groups_args()
  196. args.request = request
  197. args.write(self._oprot)
  198. self._oprot.writeMessageEnd()
  199. self._oprot.trans.flush()
  200. def recv_alter_sentry_role_add_groups(self, ):
  201. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  202. if mtype == TMessageType.EXCEPTION:
  203. x = TApplicationException()
  204. x.read(self._iprot)
  205. self._iprot.readMessageEnd()
  206. raise x
  207. result = alter_sentry_role_add_groups_result()
  208. result.read(self._iprot)
  209. self._iprot.readMessageEnd()
  210. if result.success is not None:
  211. return result.success
  212. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_add_groups failed: unknown result");
  213. def alter_sentry_role_delete_groups(self, request):
  214. """
  215. Parameters:
  216. - request
  217. """
  218. self.send_alter_sentry_role_delete_groups(request)
  219. return self.recv_alter_sentry_role_delete_groups()
  220. def send_alter_sentry_role_delete_groups(self, request):
  221. self._oprot.writeMessageBegin('alter_sentry_role_delete_groups', TMessageType.CALL, self._seqid)
  222. args = alter_sentry_role_delete_groups_args()
  223. args.request = request
  224. args.write(self._oprot)
  225. self._oprot.writeMessageEnd()
  226. self._oprot.trans.flush()
  227. def recv_alter_sentry_role_delete_groups(self, ):
  228. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  229. if mtype == TMessageType.EXCEPTION:
  230. x = TApplicationException()
  231. x.read(self._iprot)
  232. self._iprot.readMessageEnd()
  233. raise x
  234. result = alter_sentry_role_delete_groups_result()
  235. result.read(self._iprot)
  236. self._iprot.readMessageEnd()
  237. if result.success is not None:
  238. return result.success
  239. raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_sentry_role_delete_groups failed: unknown result");
  240. def list_sentry_roles_by_group(self, request):
  241. """
  242. Parameters:
  243. - request
  244. """
  245. self.send_list_sentry_roles_by_group(request)
  246. return self.recv_list_sentry_roles_by_group()
  247. def send_list_sentry_roles_by_group(self, request):
  248. self._oprot.writeMessageBegin('list_sentry_roles_by_group', TMessageType.CALL, self._seqid)
  249. args = list_sentry_roles_by_group_args()
  250. args.request = request
  251. args.write(self._oprot)
  252. self._oprot.writeMessageEnd()
  253. self._oprot.trans.flush()
  254. def recv_list_sentry_roles_by_group(self, ):
  255. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  256. if mtype == TMessageType.EXCEPTION:
  257. x = TApplicationException()
  258. x.read(self._iprot)
  259. self._iprot.readMessageEnd()
  260. raise x
  261. result = list_sentry_roles_by_group_result()
  262. result.read(self._iprot)
  263. self._iprot.readMessageEnd()
  264. if result.success is not None:
  265. return result.success
  266. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_roles_by_group failed: unknown result");
  267. def list_sentry_privileges_by_role(self, request):
  268. """
  269. Parameters:
  270. - request
  271. """
  272. self.send_list_sentry_privileges_by_role(request)
  273. return self.recv_list_sentry_privileges_by_role()
  274. def send_list_sentry_privileges_by_role(self, request):
  275. self._oprot.writeMessageBegin('list_sentry_privileges_by_role', TMessageType.CALL, self._seqid)
  276. args = list_sentry_privileges_by_role_args()
  277. args.request = request
  278. args.write(self._oprot)
  279. self._oprot.writeMessageEnd()
  280. self._oprot.trans.flush()
  281. def recv_list_sentry_privileges_by_role(self, ):
  282. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  283. if mtype == TMessageType.EXCEPTION:
  284. x = TApplicationException()
  285. x.read(self._iprot)
  286. self._iprot.readMessageEnd()
  287. raise x
  288. result = list_sentry_privileges_by_role_result()
  289. result.read(self._iprot)
  290. self._iprot.readMessageEnd()
  291. if result.success is not None:
  292. return result.success
  293. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_by_role failed: unknown result");
  294. def list_sentry_privileges_for_provider(self, request):
  295. """
  296. Parameters:
  297. - request
  298. """
  299. self.send_list_sentry_privileges_for_provider(request)
  300. return self.recv_list_sentry_privileges_for_provider()
  301. def send_list_sentry_privileges_for_provider(self, request):
  302. self._oprot.writeMessageBegin('list_sentry_privileges_for_provider', TMessageType.CALL, self._seqid)
  303. args = list_sentry_privileges_for_provider_args()
  304. args.request = request
  305. args.write(self._oprot)
  306. self._oprot.writeMessageEnd()
  307. self._oprot.trans.flush()
  308. def recv_list_sentry_privileges_for_provider(self, ):
  309. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  310. if mtype == TMessageType.EXCEPTION:
  311. x = TApplicationException()
  312. x.read(self._iprot)
  313. self._iprot.readMessageEnd()
  314. raise x
  315. result = list_sentry_privileges_for_provider_result()
  316. result.read(self._iprot)
  317. self._iprot.readMessageEnd()
  318. if result.success is not None:
  319. return result.success
  320. raise TApplicationException(TApplicationException.MISSING_RESULT, "list_sentry_privileges_for_provider failed: unknown result");
  321. class Processor(Iface, TProcessor):
  322. def __init__(self, handler):
  323. self._handler = handler
  324. self._processMap = {}
  325. self._processMap["create_sentry_role"] = Processor.process_create_sentry_role
  326. self._processMap["drop_sentry_role"] = Processor.process_drop_sentry_role
  327. self._processMap["alter_sentry_role_grant_privilege"] = Processor.process_alter_sentry_role_grant_privilege
  328. self._processMap["alter_sentry_role_revoke_privilege"] = Processor.process_alter_sentry_role_revoke_privilege
  329. self._processMap["alter_sentry_role_add_groups"] = Processor.process_alter_sentry_role_add_groups
  330. self._processMap["alter_sentry_role_delete_groups"] = Processor.process_alter_sentry_role_delete_groups
  331. self._processMap["list_sentry_roles_by_group"] = Processor.process_list_sentry_roles_by_group
  332. self._processMap["list_sentry_privileges_by_role"] = Processor.process_list_sentry_privileges_by_role
  333. self._processMap["list_sentry_privileges_for_provider"] = Processor.process_list_sentry_privileges_for_provider
  334. def process(self, iprot, oprot):
  335. (name, type, seqid) = iprot.readMessageBegin()
  336. if name not in self._processMap:
  337. iprot.skip(TType.STRUCT)
  338. iprot.readMessageEnd()
  339. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  340. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  341. x.write(oprot)
  342. oprot.writeMessageEnd()
  343. oprot.trans.flush()
  344. return
  345. else:
  346. self._processMap[name](self, seqid, iprot, oprot)
  347. return True
  348. def process_create_sentry_role(self, seqid, iprot, oprot):
  349. args = create_sentry_role_args()
  350. args.read(iprot)
  351. iprot.readMessageEnd()
  352. result = create_sentry_role_result()
  353. result.success = self._handler.create_sentry_role(args.request)
  354. oprot.writeMessageBegin("create_sentry_role", TMessageType.REPLY, seqid)
  355. result.write(oprot)
  356. oprot.writeMessageEnd()
  357. oprot.trans.flush()
  358. def process_drop_sentry_role(self, seqid, iprot, oprot):
  359. args = drop_sentry_role_args()
  360. args.read(iprot)
  361. iprot.readMessageEnd()
  362. result = drop_sentry_role_result()
  363. result.success = self._handler.drop_sentry_role(args.request)
  364. oprot.writeMessageBegin("drop_sentry_role", TMessageType.REPLY, seqid)
  365. result.write(oprot)
  366. oprot.writeMessageEnd()
  367. oprot.trans.flush()
  368. def process_alter_sentry_role_grant_privilege(self, seqid, iprot, oprot):
  369. args = alter_sentry_role_grant_privilege_args()
  370. args.read(iprot)
  371. iprot.readMessageEnd()
  372. result = alter_sentry_role_grant_privilege_result()
  373. result.success = self._handler.alter_sentry_role_grant_privilege(args.request)
  374. oprot.writeMessageBegin("alter_sentry_role_grant_privilege", TMessageType.REPLY, seqid)
  375. result.write(oprot)
  376. oprot.writeMessageEnd()
  377. oprot.trans.flush()
  378. def process_alter_sentry_role_revoke_privilege(self, seqid, iprot, oprot):
  379. args = alter_sentry_role_revoke_privilege_args()
  380. args.read(iprot)
  381. iprot.readMessageEnd()
  382. result = alter_sentry_role_revoke_privilege_result()
  383. result.success = self._handler.alter_sentry_role_revoke_privilege(args.request)
  384. oprot.writeMessageBegin("alter_sentry_role_revoke_privilege", TMessageType.REPLY, seqid)
  385. result.write(oprot)
  386. oprot.writeMessageEnd()
  387. oprot.trans.flush()
  388. def process_alter_sentry_role_add_groups(self, seqid, iprot, oprot):
  389. args = alter_sentry_role_add_groups_args()
  390. args.read(iprot)
  391. iprot.readMessageEnd()
  392. result = alter_sentry_role_add_groups_result()
  393. result.success = self._handler.alter_sentry_role_add_groups(args.request)
  394. oprot.writeMessageBegin("alter_sentry_role_add_groups", TMessageType.REPLY, seqid)
  395. result.write(oprot)
  396. oprot.writeMessageEnd()
  397. oprot.trans.flush()
  398. def process_alter_sentry_role_delete_groups(self, seqid, iprot, oprot):
  399. args = alter_sentry_role_delete_groups_args()
  400. args.read(iprot)
  401. iprot.readMessageEnd()
  402. result = alter_sentry_role_delete_groups_result()
  403. result.success = self._handler.alter_sentry_role_delete_groups(args.request)
  404. oprot.writeMessageBegin("alter_sentry_role_delete_groups", TMessageType.REPLY, seqid)
  405. result.write(oprot)
  406. oprot.writeMessageEnd()
  407. oprot.trans.flush()
  408. def process_list_sentry_roles_by_group(self, seqid, iprot, oprot):
  409. args = list_sentry_roles_by_group_args()
  410. args.read(iprot)
  411. iprot.readMessageEnd()
  412. result = list_sentry_roles_by_group_result()
  413. result.success = self._handler.list_sentry_roles_by_group(args.request)
  414. oprot.writeMessageBegin("list_sentry_roles_by_group", TMessageType.REPLY, seqid)
  415. result.write(oprot)
  416. oprot.writeMessageEnd()
  417. oprot.trans.flush()
  418. def process_list_sentry_privileges_by_role(self, seqid, iprot, oprot):
  419. args = list_sentry_privileges_by_role_args()
  420. args.read(iprot)
  421. iprot.readMessageEnd()
  422. result = list_sentry_privileges_by_role_result()
  423. result.success = self._handler.list_sentry_privileges_by_role(args.request)
  424. oprot.writeMessageBegin("list_sentry_privileges_by_role", TMessageType.REPLY, seqid)
  425. result.write(oprot)
  426. oprot.writeMessageEnd()
  427. oprot.trans.flush()
  428. def process_list_sentry_privileges_for_provider(self, seqid, iprot, oprot):
  429. args = list_sentry_privileges_for_provider_args()
  430. args.read(iprot)
  431. iprot.readMessageEnd()
  432. result = list_sentry_privileges_for_provider_result()
  433. result.success = self._handler.list_sentry_privileges_for_provider(args.request)
  434. oprot.writeMessageBegin("list_sentry_privileges_for_provider", TMessageType.REPLY, seqid)
  435. result.write(oprot)
  436. oprot.writeMessageEnd()
  437. oprot.trans.flush()
  438. # HELPER FUNCTIONS AND STRUCTURES
  439. class create_sentry_role_args(object):
  440. """
  441. Attributes:
  442. - request
  443. """
  444. thrift_spec = (
  445. None, # 0
  446. (1, TType.STRUCT, 'request', (TCreateSentryRoleRequest, TCreateSentryRoleRequest.thrift_spec), None, ), # 1
  447. )
  448. def __init__(self, request=None,):
  449. self.request = request
  450. def read(self, iprot):
  451. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  452. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  453. return
  454. iprot.readStructBegin()
  455. while True:
  456. (fname, ftype, fid) = iprot.readFieldBegin()
  457. if ftype == TType.STOP:
  458. break
  459. if fid == 1:
  460. if ftype == TType.STRUCT:
  461. self.request = TCreateSentryRoleRequest()
  462. self.request.read(iprot)
  463. else:
  464. iprot.skip(ftype)
  465. else:
  466. iprot.skip(ftype)
  467. iprot.readFieldEnd()
  468. iprot.readStructEnd()
  469. def write(self, oprot):
  470. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  471. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  472. return
  473. oprot.writeStructBegin('create_sentry_role_args')
  474. if self.request is not None:
  475. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  476. self.request.write(oprot)
  477. oprot.writeFieldEnd()
  478. oprot.writeFieldStop()
  479. oprot.writeStructEnd()
  480. def validate(self):
  481. return
  482. def __repr__(self):
  483. L = ['%s=%r' % (key, value)
  484. for key, value in self.__dict__.iteritems()]
  485. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  486. def __eq__(self, other):
  487. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  488. def __ne__(self, other):
  489. return not (self == other)
  490. class create_sentry_role_result(object):
  491. """
  492. Attributes:
  493. - success
  494. """
  495. thrift_spec = (
  496. (0, TType.STRUCT, 'success', (TCreateSentryRoleResponse, TCreateSentryRoleResponse.thrift_spec), None, ), # 0
  497. )
  498. def __init__(self, success=None,):
  499. self.success = success
  500. def read(self, iprot):
  501. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  502. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  503. return
  504. iprot.readStructBegin()
  505. while True:
  506. (fname, ftype, fid) = iprot.readFieldBegin()
  507. if ftype == TType.STOP:
  508. break
  509. if fid == 0:
  510. if ftype == TType.STRUCT:
  511. self.success = TCreateSentryRoleResponse()
  512. self.success.read(iprot)
  513. else:
  514. iprot.skip(ftype)
  515. else:
  516. iprot.skip(ftype)
  517. iprot.readFieldEnd()
  518. iprot.readStructEnd()
  519. def write(self, oprot):
  520. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  521. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  522. return
  523. oprot.writeStructBegin('create_sentry_role_result')
  524. if self.success is not None:
  525. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  526. self.success.write(oprot)
  527. oprot.writeFieldEnd()
  528. oprot.writeFieldStop()
  529. oprot.writeStructEnd()
  530. def validate(self):
  531. return
  532. def __repr__(self):
  533. L = ['%s=%r' % (key, value)
  534. for key, value in self.__dict__.iteritems()]
  535. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  536. def __eq__(self, other):
  537. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  538. def __ne__(self, other):
  539. return not (self == other)
  540. class drop_sentry_role_args(object):
  541. """
  542. Attributes:
  543. - request
  544. """
  545. thrift_spec = (
  546. None, # 0
  547. (1, TType.STRUCT, 'request', (TDropSentryRoleRequest, TDropSentryRoleRequest.thrift_spec), None, ), # 1
  548. )
  549. def __init__(self, request=None,):
  550. self.request = request
  551. def read(self, iprot):
  552. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  553. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  554. return
  555. iprot.readStructBegin()
  556. while True:
  557. (fname, ftype, fid) = iprot.readFieldBegin()
  558. if ftype == TType.STOP:
  559. break
  560. if fid == 1:
  561. if ftype == TType.STRUCT:
  562. self.request = TDropSentryRoleRequest()
  563. self.request.read(iprot)
  564. else:
  565. iprot.skip(ftype)
  566. else:
  567. iprot.skip(ftype)
  568. iprot.readFieldEnd()
  569. iprot.readStructEnd()
  570. def write(self, oprot):
  571. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  572. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  573. return
  574. oprot.writeStructBegin('drop_sentry_role_args')
  575. if self.request is not None:
  576. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  577. self.request.write(oprot)
  578. oprot.writeFieldEnd()
  579. oprot.writeFieldStop()
  580. oprot.writeStructEnd()
  581. def validate(self):
  582. return
  583. def __repr__(self):
  584. L = ['%s=%r' % (key, value)
  585. for key, value in self.__dict__.iteritems()]
  586. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  587. def __eq__(self, other):
  588. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  589. def __ne__(self, other):
  590. return not (self == other)
  591. class drop_sentry_role_result(object):
  592. """
  593. Attributes:
  594. - success
  595. """
  596. thrift_spec = (
  597. (0, TType.STRUCT, 'success', (TDropSentryRoleResponse, TDropSentryRoleResponse.thrift_spec), None, ), # 0
  598. )
  599. def __init__(self, success=None,):
  600. self.success = success
  601. def read(self, iprot):
  602. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  603. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  604. return
  605. iprot.readStructBegin()
  606. while True:
  607. (fname, ftype, fid) = iprot.readFieldBegin()
  608. if ftype == TType.STOP:
  609. break
  610. if fid == 0:
  611. if ftype == TType.STRUCT:
  612. self.success = TDropSentryRoleResponse()
  613. self.success.read(iprot)
  614. else:
  615. iprot.skip(ftype)
  616. else:
  617. iprot.skip(ftype)
  618. iprot.readFieldEnd()
  619. iprot.readStructEnd()
  620. def write(self, oprot):
  621. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  622. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  623. return
  624. oprot.writeStructBegin('drop_sentry_role_result')
  625. if self.success is not None:
  626. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  627. self.success.write(oprot)
  628. oprot.writeFieldEnd()
  629. oprot.writeFieldStop()
  630. oprot.writeStructEnd()
  631. def validate(self):
  632. return
  633. def __repr__(self):
  634. L = ['%s=%r' % (key, value)
  635. for key, value in self.__dict__.iteritems()]
  636. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  637. def __eq__(self, other):
  638. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  639. def __ne__(self, other):
  640. return not (self == other)
  641. class alter_sentry_role_grant_privilege_args(object):
  642. """
  643. Attributes:
  644. - request
  645. """
  646. thrift_spec = (
  647. None, # 0
  648. (1, TType.STRUCT, 'request', (TAlterSentryRoleGrantPrivilegeRequest, TAlterSentryRoleGrantPrivilegeRequest.thrift_spec), None, ), # 1
  649. )
  650. def __init__(self, request=None,):
  651. self.request = request
  652. def read(self, iprot):
  653. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  654. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  655. return
  656. iprot.readStructBegin()
  657. while True:
  658. (fname, ftype, fid) = iprot.readFieldBegin()
  659. if ftype == TType.STOP:
  660. break
  661. if fid == 1:
  662. if ftype == TType.STRUCT:
  663. self.request = TAlterSentryRoleGrantPrivilegeRequest()
  664. self.request.read(iprot)
  665. else:
  666. iprot.skip(ftype)
  667. else:
  668. iprot.skip(ftype)
  669. iprot.readFieldEnd()
  670. iprot.readStructEnd()
  671. def write(self, oprot):
  672. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  673. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  674. return
  675. oprot.writeStructBegin('alter_sentry_role_grant_privilege_args')
  676. if self.request is not None:
  677. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  678. self.request.write(oprot)
  679. oprot.writeFieldEnd()
  680. oprot.writeFieldStop()
  681. oprot.writeStructEnd()
  682. def validate(self):
  683. return
  684. def __repr__(self):
  685. L = ['%s=%r' % (key, value)
  686. for key, value in self.__dict__.iteritems()]
  687. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  688. def __eq__(self, other):
  689. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  690. def __ne__(self, other):
  691. return not (self == other)
  692. class alter_sentry_role_grant_privilege_result(object):
  693. """
  694. Attributes:
  695. - success
  696. """
  697. thrift_spec = (
  698. (0, TType.STRUCT, 'success', (TAlterSentryRoleGrantPrivilegeResponse, TAlterSentryRoleGrantPrivilegeResponse.thrift_spec), None, ), # 0
  699. )
  700. def __init__(self, success=None,):
  701. self.success = success
  702. def read(self, iprot):
  703. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  704. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  705. return
  706. iprot.readStructBegin()
  707. while True:
  708. (fname, ftype, fid) = iprot.readFieldBegin()
  709. if ftype == TType.STOP:
  710. break
  711. if fid == 0:
  712. if ftype == TType.STRUCT:
  713. self.success = TAlterSentryRoleGrantPrivilegeResponse()
  714. self.success.read(iprot)
  715. else:
  716. iprot.skip(ftype)
  717. else:
  718. iprot.skip(ftype)
  719. iprot.readFieldEnd()
  720. iprot.readStructEnd()
  721. def write(self, oprot):
  722. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  723. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  724. return
  725. oprot.writeStructBegin('alter_sentry_role_grant_privilege_result')
  726. if self.success is not None:
  727. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  728. self.success.write(oprot)
  729. oprot.writeFieldEnd()
  730. oprot.writeFieldStop()
  731. oprot.writeStructEnd()
  732. def validate(self):
  733. return
  734. def __repr__(self):
  735. L = ['%s=%r' % (key, value)
  736. for key, value in self.__dict__.iteritems()]
  737. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  738. def __eq__(self, other):
  739. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  740. def __ne__(self, other):
  741. return not (self == other)
  742. class alter_sentry_role_revoke_privilege_args(object):
  743. """
  744. Attributes:
  745. - request
  746. """
  747. thrift_spec = (
  748. None, # 0
  749. (1, TType.STRUCT, 'request', (TAlterSentryRoleRevokePrivilegeRequest, TAlterSentryRoleRevokePrivilegeRequest.thrift_spec), None, ), # 1
  750. )
  751. def __init__(self, request=None,):
  752. self.request = request
  753. def read(self, iprot):
  754. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  755. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  756. return
  757. iprot.readStructBegin()
  758. while True:
  759. (fname, ftype, fid) = iprot.readFieldBegin()
  760. if ftype == TType.STOP:
  761. break
  762. if fid == 1:
  763. if ftype == TType.STRUCT:
  764. self.request = TAlterSentryRoleRevokePrivilegeRequest()
  765. self.request.read(iprot)
  766. else:
  767. iprot.skip(ftype)
  768. else:
  769. iprot.skip(ftype)
  770. iprot.readFieldEnd()
  771. iprot.readStructEnd()
  772. def write(self, oprot):
  773. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  774. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  775. return
  776. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_args')
  777. if self.request is not None:
  778. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  779. self.request.write(oprot)
  780. oprot.writeFieldEnd()
  781. oprot.writeFieldStop()
  782. oprot.writeStructEnd()
  783. def validate(self):
  784. return
  785. def __repr__(self):
  786. L = ['%s=%r' % (key, value)
  787. for key, value in self.__dict__.iteritems()]
  788. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  789. def __eq__(self, other):
  790. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  791. def __ne__(self, other):
  792. return not (self == other)
  793. class alter_sentry_role_revoke_privilege_result(object):
  794. """
  795. Attributes:
  796. - success
  797. """
  798. thrift_spec = (
  799. (0, TType.STRUCT, 'success', (TAlterSentryRoleRevokePrivilegeResponse, TAlterSentryRoleRevokePrivilegeResponse.thrift_spec), None, ), # 0
  800. )
  801. def __init__(self, success=None,):
  802. self.success = success
  803. def read(self, iprot):
  804. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  805. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  806. return
  807. iprot.readStructBegin()
  808. while True:
  809. (fname, ftype, fid) = iprot.readFieldBegin()
  810. if ftype == TType.STOP:
  811. break
  812. if fid == 0:
  813. if ftype == TType.STRUCT:
  814. self.success = TAlterSentryRoleRevokePrivilegeResponse()
  815. self.success.read(iprot)
  816. else:
  817. iprot.skip(ftype)
  818. else:
  819. iprot.skip(ftype)
  820. iprot.readFieldEnd()
  821. iprot.readStructEnd()
  822. def write(self, oprot):
  823. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  824. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  825. return
  826. oprot.writeStructBegin('alter_sentry_role_revoke_privilege_result')
  827. if self.success is not None:
  828. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  829. self.success.write(oprot)
  830. oprot.writeFieldEnd()
  831. oprot.writeFieldStop()
  832. oprot.writeStructEnd()
  833. def validate(self):
  834. return
  835. def __repr__(self):
  836. L = ['%s=%r' % (key, value)
  837. for key, value in self.__dict__.iteritems()]
  838. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  839. def __eq__(self, other):
  840. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  841. def __ne__(self, other):
  842. return not (self == other)
  843. class alter_sentry_role_add_groups_args(object):
  844. """
  845. Attributes:
  846. - request
  847. """
  848. thrift_spec = (
  849. None, # 0
  850. (1, TType.STRUCT, 'request', (TAlterSentryRoleAddGroupsRequest, TAlterSentryRoleAddGroupsRequest.thrift_spec), None, ), # 1
  851. )
  852. def __init__(self, request=None,):
  853. self.request = request
  854. def read(self, iprot):
  855. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  856. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  857. return
  858. iprot.readStructBegin()
  859. while True:
  860. (fname, ftype, fid) = iprot.readFieldBegin()
  861. if ftype == TType.STOP:
  862. break
  863. if fid == 1:
  864. if ftype == TType.STRUCT:
  865. self.request = TAlterSentryRoleAddGroupsRequest()
  866. self.request.read(iprot)
  867. else:
  868. iprot.skip(ftype)
  869. else:
  870. iprot.skip(ftype)
  871. iprot.readFieldEnd()
  872. iprot.readStructEnd()
  873. def write(self, oprot):
  874. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  875. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  876. return
  877. oprot.writeStructBegin('alter_sentry_role_add_groups_args')
  878. if self.request is not None:
  879. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  880. self.request.write(oprot)
  881. oprot.writeFieldEnd()
  882. oprot.writeFieldStop()
  883. oprot.writeStructEnd()
  884. def validate(self):
  885. return
  886. def __repr__(self):
  887. L = ['%s=%r' % (key, value)
  888. for key, value in self.__dict__.iteritems()]
  889. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  890. def __eq__(self, other):
  891. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  892. def __ne__(self, other):
  893. return not (self == other)
  894. class alter_sentry_role_add_groups_result(object):
  895. """
  896. Attributes:
  897. - success
  898. """
  899. thrift_spec = (
  900. (0, TType.STRUCT, 'success', (TAlterSentryRoleAddGroupsResponse, TAlterSentryRoleAddGroupsResponse.thrift_spec), None, ), # 0
  901. )
  902. def __init__(self, success=None,):
  903. self.success = success
  904. def read(self, iprot):
  905. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  906. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  907. return
  908. iprot.readStructBegin()
  909. while True:
  910. (fname, ftype, fid) = iprot.readFieldBegin()
  911. if ftype == TType.STOP:
  912. break
  913. if fid == 0:
  914. if ftype == TType.STRUCT:
  915. self.success = TAlterSentryRoleAddGroupsResponse()
  916. self.success.read(iprot)
  917. else:
  918. iprot.skip(ftype)
  919. else:
  920. iprot.skip(ftype)
  921. iprot.readFieldEnd()
  922. iprot.readStructEnd()
  923. def write(self, oprot):
  924. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  925. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  926. return
  927. oprot.writeStructBegin('alter_sentry_role_add_groups_result')
  928. if self.success is not None:
  929. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  930. self.success.write(oprot)
  931. oprot.writeFieldEnd()
  932. oprot.writeFieldStop()
  933. oprot.writeStructEnd()
  934. def validate(self):
  935. return
  936. def __repr__(self):
  937. L = ['%s=%r' % (key, value)
  938. for key, value in self.__dict__.iteritems()]
  939. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  940. def __eq__(self, other):
  941. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  942. def __ne__(self, other):
  943. return not (self == other)
  944. class alter_sentry_role_delete_groups_args(object):
  945. """
  946. Attributes:
  947. - request
  948. """
  949. thrift_spec = (
  950. None, # 0
  951. (1, TType.STRUCT, 'request', (TAlterSentryRoleDeleteGroupsRequest, TAlterSentryRoleDeleteGroupsRequest.thrift_spec), None, ), # 1
  952. )
  953. def __init__(self, request=None,):
  954. self.request = request
  955. def read(self, iprot):
  956. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  957. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  958. return
  959. iprot.readStructBegin()
  960. while True:
  961. (fname, ftype, fid) = iprot.readFieldBegin()
  962. if ftype == TType.STOP:
  963. break
  964. if fid == 1:
  965. if ftype == TType.STRUCT:
  966. self.request = TAlterSentryRoleDeleteGroupsRequest()
  967. self.request.read(iprot)
  968. else:
  969. iprot.skip(ftype)
  970. else:
  971. iprot.skip(ftype)
  972. iprot.readFieldEnd()
  973. iprot.readStructEnd()
  974. def write(self, oprot):
  975. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  976. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  977. return
  978. oprot.writeStructBegin('alter_sentry_role_delete_groups_args')
  979. if self.request is not None:
  980. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  981. self.request.write(oprot)
  982. oprot.writeFieldEnd()
  983. oprot.writeFieldStop()
  984. oprot.writeStructEnd()
  985. def validate(self):
  986. return
  987. def __repr__(self):
  988. L = ['%s=%r' % (key, value)
  989. for key, value in self.__dict__.iteritems()]
  990. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  991. def __eq__(self, other):
  992. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  993. def __ne__(self, other):
  994. return not (self == other)
  995. class alter_sentry_role_delete_groups_result(object):
  996. """
  997. Attributes:
  998. - success
  999. """
  1000. thrift_spec = (
  1001. (0, TType.STRUCT, 'success', (TAlterSentryRoleDeleteGroupsResponse, TAlterSentryRoleDeleteGroupsResponse.thrift_spec), None, ), # 0
  1002. )
  1003. def __init__(self, success=None,):
  1004. self.success = success
  1005. def read(self, iprot):
  1006. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1007. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1008. return
  1009. iprot.readStructBegin()
  1010. while True:
  1011. (fname, ftype, fid) = iprot.readFieldBegin()
  1012. if ftype == TType.STOP:
  1013. break
  1014. if fid == 0:
  1015. if ftype == TType.STRUCT:
  1016. self.success = TAlterSentryRoleDeleteGroupsResponse()
  1017. self.success.read(iprot)
  1018. else:
  1019. iprot.skip(ftype)
  1020. else:
  1021. iprot.skip(ftype)
  1022. iprot.readFieldEnd()
  1023. iprot.readStructEnd()
  1024. def write(self, oprot):
  1025. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1026. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1027. return
  1028. oprot.writeStructBegin('alter_sentry_role_delete_groups_result')
  1029. if self.success is not None:
  1030. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1031. self.success.write(oprot)
  1032. oprot.writeFieldEnd()
  1033. oprot.writeFieldStop()
  1034. oprot.writeStructEnd()
  1035. def validate(self):
  1036. return
  1037. def __repr__(self):
  1038. L = ['%s=%r' % (key, value)
  1039. for key, value in self.__dict__.iteritems()]
  1040. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1041. def __eq__(self, other):
  1042. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1043. def __ne__(self, other):
  1044. return not (self == other)
  1045. class list_sentry_roles_by_group_args(object):
  1046. """
  1047. Attributes:
  1048. - request
  1049. """
  1050. thrift_spec = (
  1051. None, # 0
  1052. (1, TType.STRUCT, 'request', (TListSentryRolesRequest, TListSentryRolesRequest.thrift_spec), None, ), # 1
  1053. )
  1054. def __init__(self, request=None,):
  1055. self.request = request
  1056. def read(self, iprot):
  1057. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1058. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1059. return
  1060. iprot.readStructBegin()
  1061. while True:
  1062. (fname, ftype, fid) = iprot.readFieldBegin()
  1063. if ftype == TType.STOP:
  1064. break
  1065. if fid == 1:
  1066. if ftype == TType.STRUCT:
  1067. self.request = TListSentryRolesRequest()
  1068. self.request.read(iprot)
  1069. else:
  1070. iprot.skip(ftype)
  1071. else:
  1072. iprot.skip(ftype)
  1073. iprot.readFieldEnd()
  1074. iprot.readStructEnd()
  1075. def write(self, oprot):
  1076. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1077. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1078. return
  1079. oprot.writeStructBegin('list_sentry_roles_by_group_args')
  1080. if self.request is not None:
  1081. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1082. self.request.write(oprot)
  1083. oprot.writeFieldEnd()
  1084. oprot.writeFieldStop()
  1085. oprot.writeStructEnd()
  1086. def validate(self):
  1087. return
  1088. def __repr__(self):
  1089. L = ['%s=%r' % (key, value)
  1090. for key, value in self.__dict__.iteritems()]
  1091. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1092. def __eq__(self, other):
  1093. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1094. def __ne__(self, other):
  1095. return not (self == other)
  1096. class list_sentry_roles_by_group_result(object):
  1097. """
  1098. Attributes:
  1099. - success
  1100. """
  1101. thrift_spec = (
  1102. (0, TType.STRUCT, 'success', (TListSentryRolesResponse, TListSentryRolesResponse.thrift_spec), None, ), # 0
  1103. )
  1104. def __init__(self, success=None,):
  1105. self.success = success
  1106. def read(self, iprot):
  1107. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1108. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1109. return
  1110. iprot.readStructBegin()
  1111. while True:
  1112. (fname, ftype, fid) = iprot.readFieldBegin()
  1113. if ftype == TType.STOP:
  1114. break
  1115. if fid == 0:
  1116. if ftype == TType.STRUCT:
  1117. self.success = TListSentryRolesResponse()
  1118. self.success.read(iprot)
  1119. else:
  1120. iprot.skip(ftype)
  1121. else:
  1122. iprot.skip(ftype)
  1123. iprot.readFieldEnd()
  1124. iprot.readStructEnd()
  1125. def write(self, oprot):
  1126. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1127. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1128. return
  1129. oprot.writeStructBegin('list_sentry_roles_by_group_result')
  1130. if self.success is not None:
  1131. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1132. self.success.write(oprot)
  1133. oprot.writeFieldEnd()
  1134. oprot.writeFieldStop()
  1135. oprot.writeStructEnd()
  1136. def validate(self):
  1137. return
  1138. def __repr__(self):
  1139. L = ['%s=%r' % (key, value)
  1140. for key, value in self.__dict__.iteritems()]
  1141. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1142. def __eq__(self, other):
  1143. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1144. def __ne__(self, other):
  1145. return not (self == other)
  1146. class list_sentry_privileges_by_role_args(object):
  1147. """
  1148. Attributes:
  1149. - request
  1150. """
  1151. thrift_spec = (
  1152. None, # 0
  1153. (1, TType.STRUCT, 'request', (TListSentryPrivilegesRequest, TListSentryPrivilegesRequest.thrift_spec), None, ), # 1
  1154. )
  1155. def __init__(self, request=None,):
  1156. self.request = request
  1157. def read(self, iprot):
  1158. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1159. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1160. return
  1161. iprot.readStructBegin()
  1162. while True:
  1163. (fname, ftype, fid) = iprot.readFieldBegin()
  1164. if ftype == TType.STOP:
  1165. break
  1166. if fid == 1:
  1167. if ftype == TType.STRUCT:
  1168. self.request = TListSentryPrivilegesRequest()
  1169. self.request.read(iprot)
  1170. else:
  1171. iprot.skip(ftype)
  1172. else:
  1173. iprot.skip(ftype)
  1174. iprot.readFieldEnd()
  1175. iprot.readStructEnd()
  1176. def write(self, oprot):
  1177. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1178. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1179. return
  1180. oprot.writeStructBegin('list_sentry_privileges_by_role_args')
  1181. if self.request is not None:
  1182. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1183. self.request.write(oprot)
  1184. oprot.writeFieldEnd()
  1185. oprot.writeFieldStop()
  1186. oprot.writeStructEnd()
  1187. def validate(self):
  1188. return
  1189. def __repr__(self):
  1190. L = ['%s=%r' % (key, value)
  1191. for key, value in self.__dict__.iteritems()]
  1192. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1193. def __eq__(self, other):
  1194. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1195. def __ne__(self, other):
  1196. return not (self == other)
  1197. class list_sentry_privileges_by_role_result(object):
  1198. """
  1199. Attributes:
  1200. - success
  1201. """
  1202. thrift_spec = (
  1203. (0, TType.STRUCT, 'success', (TListSentryPrivilegesResponse, TListSentryPrivilegesResponse.thrift_spec), None, ), # 0
  1204. )
  1205. def __init__(self, success=None,):
  1206. self.success = success
  1207. def read(self, iprot):
  1208. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1209. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1210. return
  1211. iprot.readStructBegin()
  1212. while True:
  1213. (fname, ftype, fid) = iprot.readFieldBegin()
  1214. if ftype == TType.STOP:
  1215. break
  1216. if fid == 0:
  1217. if ftype == TType.STRUCT:
  1218. self.success = TListSentryPrivilegesResponse()
  1219. self.success.read(iprot)
  1220. else:
  1221. iprot.skip(ftype)
  1222. else:
  1223. iprot.skip(ftype)
  1224. iprot.readFieldEnd()
  1225. iprot.readStructEnd()
  1226. def write(self, oprot):
  1227. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1228. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1229. return
  1230. oprot.writeStructBegin('list_sentry_privileges_by_role_result')
  1231. if self.success is not None:
  1232. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1233. self.success.write(oprot)
  1234. oprot.writeFieldEnd()
  1235. oprot.writeFieldStop()
  1236. oprot.writeStructEnd()
  1237. def validate(self):
  1238. return
  1239. def __repr__(self):
  1240. L = ['%s=%r' % (key, value)
  1241. for key, value in self.__dict__.iteritems()]
  1242. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1243. def __eq__(self, other):
  1244. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1245. def __ne__(self, other):
  1246. return not (self == other)
  1247. class list_sentry_privileges_for_provider_args(object):
  1248. """
  1249. Attributes:
  1250. - request
  1251. """
  1252. thrift_spec = (
  1253. None, # 0
  1254. (1, TType.STRUCT, 'request', (TListSentryPrivilegesForProviderRequest, TListSentryPrivilegesForProviderRequest.thrift_spec), None, ), # 1
  1255. )
  1256. def __init__(self, request=None,):
  1257. self.request = request
  1258. def read(self, iprot):
  1259. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1260. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1261. return
  1262. iprot.readStructBegin()
  1263. while True:
  1264. (fname, ftype, fid) = iprot.readFieldBegin()
  1265. if ftype == TType.STOP:
  1266. break
  1267. if fid == 1:
  1268. if ftype == TType.STRUCT:
  1269. self.request = TListSentryPrivilegesForProviderRequest()
  1270. self.request.read(iprot)
  1271. else:
  1272. iprot.skip(ftype)
  1273. else:
  1274. iprot.skip(ftype)
  1275. iprot.readFieldEnd()
  1276. iprot.readStructEnd()
  1277. def write(self, oprot):
  1278. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1279. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1280. return
  1281. oprot.writeStructBegin('list_sentry_privileges_for_provider_args')
  1282. if self.request is not None:
  1283. oprot.writeFieldBegin('request', TType.STRUCT, 1)
  1284. self.request.write(oprot)
  1285. oprot.writeFieldEnd()
  1286. oprot.writeFieldStop()
  1287. oprot.writeStructEnd()
  1288. def validate(self):
  1289. return
  1290. def __repr__(self):
  1291. L = ['%s=%r' % (key, value)
  1292. for key, value in self.__dict__.iteritems()]
  1293. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1294. def __eq__(self, other):
  1295. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1296. def __ne__(self, other):
  1297. return not (self == other)
  1298. class list_sentry_privileges_for_provider_result(object):
  1299. """
  1300. Attributes:
  1301. - success
  1302. """
  1303. thrift_spec = (
  1304. (0, TType.STRUCT, 'success', (TListSentryPrivilegesForProviderResponse, TListSentryPrivilegesForProviderResponse.thrift_spec), None, ), # 0
  1305. )
  1306. def __init__(self, success=None,):
  1307. self.success = success
  1308. def read(self, iprot):
  1309. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1310. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1311. return
  1312. iprot.readStructBegin()
  1313. while True:
  1314. (fname, ftype, fid) = iprot.readFieldBegin()
  1315. if ftype == TType.STOP:
  1316. break
  1317. if fid == 0:
  1318. if ftype == TType.STRUCT:
  1319. self.success = TListSentryPrivilegesForProviderResponse()
  1320. self.success.read(iprot)
  1321. else:
  1322. iprot.skip(ftype)
  1323. else:
  1324. iprot.skip(ftype)
  1325. iprot.readFieldEnd()
  1326. iprot.readStructEnd()
  1327. def write(self, oprot):
  1328. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1329. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1330. return
  1331. oprot.writeStructBegin('list_sentry_privileges_for_provider_result')
  1332. if self.success is not None:
  1333. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1334. self.success.write(oprot)
  1335. oprot.writeFieldEnd()
  1336. oprot.writeFieldStop()
  1337. oprot.writeStructEnd()
  1338. def validate(self):
  1339. return
  1340. def __repr__(self):
  1341. L = ['%s=%r' % (key, value)
  1342. for key, value in self.__dict__.iteritems()]
  1343. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1344. def __eq__(self, other):
  1345. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1346. def __ne__(self, other):
  1347. return not (self == other)