python/google/storage/speckle/proto/sql_pb2.py

   1 #!/usr/bin/env python
   2 #
   3 # Copyright 2007 Google Inc.
   4 #
   5 # Licensed under the Apache License, Version 2.0 (the "License");
   6 # you may not use this file except in compliance with the License.
   7 # You may obtain a copy of the License at
   8 #
   9 #     http://www.apache.org/licenses/LICENSE-2.0
  10 #
  11 # Unless required by applicable law or agreed to in writing, software
  12 # distributed under the License is distributed on an "AS IS" BASIS,
  13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16 #
  17
  18
  19
  20 import sys
  21 _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
  22 from google.net.proto2.python.public import descriptor as _descriptor
  23 from google.net.proto2.python.public import message as _message
  24 from google.net.proto2.python.public import reflection as _reflection
  25 from google.net.proto2.python.public import symbol_database as _symbol_database
  26 from google.net.proto2.proto import descriptor_pb2
  27 import sys
  28 try:
  29   __import__('google.net.rpc.python.rpc_internals_lite')
  30   __import__('google.net.rpc.python.pywraprpc_lite')
  31   rpc_internals = sys.modules.get('google.net.rpc.python.rpc_internals_lite')
  32   pywraprpc = sys.modules.get('google.net.rpc.python.pywraprpc_lite')
  33   _client_stub_base_class = rpc_internals.StubbyRPCBaseStub
  34 except ImportError:
  35   _client_stub_base_class = object
  36 try:
  37   __import__('google.net.rpc.python.rpcserver')
  38   rpcserver = sys.modules.get('google.net.rpc.python.rpcserver')
  39   _server_stub_base_class = rpcserver.BaseRpcServer
  40 except ImportError:
  41   _server_stub_base_class = object
  42
  43
  44 _sym_db = _symbol_database.Default()
  45
  46
  47 import google.storage.speckle.proto.client_pb2
  48
  49
  50 DESCRIPTOR = _descriptor.FileDescriptor(
  51   name='storage/speckle/proto/sql.proto',
  52   package='speckle.sql',
  53   serialized_pb=_b('\n\x1fstorage/speckle/proto/sql.proto\x12\x0bspeckle.sql\x1a\"storage/speckle/proto/client.proto\"\x8c\x03\n\x0b\x45xecRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x14\n\x0cstatement_id\x18\x02 \x01(\x04\x12\x11\n\tstatement\x18\x03 \x01(\t\x12\x31\n\rbind_variable\x18\x04 \x03(\x0b\x32\x1a.speckle.BindVariableProto\x12\x15\n\rconnection_id\x18\x05 \x02(\x0c\x12%\n\x07options\x18\x06 \x01(\x0b\x32\x14.speckle.ExecOptions\x12I\n\x0estatement_type\x18\t \x01(\x0e\x32&.speckle.sql.ExecRequest.StatementType:\tSTATEMENT\x12\"\n\x05\x62\x61tch\x18\n \x01(\x0b\x32\x13.speckle.BatchProto\x12\x12\n\nrequest_id\x18\x0b \x01(\x04\"N\n\rStatementType\x12\r\n\tSTATEMENT\x10\x01\x12\x16\n\x12PREPARED_STATEMENT\x10\x02\x12\x16\n\x12\x43\x41LLABLE_STATEMENT\x10\x03\"b\n\x0c\x45xecResponse\x12$\n\x06result\x18\x01 \x01(\x0b\x32\x14.speckle.ResultProto\x12,\n\rsql_exception\x18\x02 \x01(\x0b\x32\x15.speckle.SqlException\"j\n\rExecOpRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x15\n\rconnection_id\x18\x02 \x02(\x0c\x12\x1c\n\x02op\x18\x03 \x02(\x0b\x32\x10.speckle.OpProto\x12\x12\n\nrequest_id\x18\x08 \x01(\x04\"\xed\x01\n\x0e\x45xecOpResponse\x12\x12\n\nnative_sql\x18\x01 \x01(\t\x12%\n\tsavepoint\x18\x02 \x01(\x0b\x32\x12.speckle.SavePoint\x12,\n\rsql_exception\x18\x03 \x01(\x0b\x32\x15.speckle.SqlException\x12$\n\x06result\x18\x04 \x01(\x0b\x32\x14.speckle.ResultProto\x12\x30\n\x10\x63\x61\x63hed_rpc_error\x18\x05 \x01(\x0b\x32\x16.speckle.RpcErrorProto\x12\x1a\n\x0e\x63\x61\x63hed_payload\x18\x06 \x01(\x0c\x42\x02\x08\x01\"\xaa\x01\n\x0fMetadataRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\'\n\x08metadata\x18\x03 \x02(\x0e\x32\x15.speckle.MetadataType\x12\x31\n\rbind_variable\x18\x04 \x03(\x0b\x32\x1a.speckle.BindVariableProto\x12\x15\n\rconnection_id\x18\x05 \x02(\x0c\x12\x12\n\nrequest_id\x18\x08 \x01(\x04\"\xaa\x01\n\x10MetadataResponse\x12$\n\x06result\x18\x01 \x01(\x0b\x32\x14.speckle.ResultProto\x12\x42\n\x16jdbc_database_metadata\x18\x02 \x01(\x0b\x32\".speckle.JdbcDatabaseMetaDataProto\x12,\n\rsql_exception\x18\x03 \x01(\x0b\x32\x15.speckle.SqlException\"\xac\x01\n\x15OpenConnectionRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12#\n\x08property\x18\x02 \x03(\x0b\x32\x11.speckle.Property\x12\x1b\n\x10protocol_version\x18\x05 \x01(\x04:\x01\x31\x12?\n\x0b\x63lient_type\x18\x06 \x01(\x0e\x32\x13.speckle.ClientType:\x15\x43LIENT_TYPE_JAVA_JDBC\"\x86\x01\n\x16OpenConnectionResponse\x12\x15\n\rconnection_id\x18\x01 \x01(\x0c\x12,\n\rsql_exception\x18\x02 \x01(\x0b\x32\x15.speckle.SqlException\x12\'\n\x08warnings\x18\x06 \x03(\x0b\x32\x15.speckle.SqlException\"A\n\x16\x43loseConnectionRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x15\n\rconnection_id\x18\x02 \x02(\x0c\"G\n\x17\x43loseConnectionResponse\x12,\n\rsql_exception\x18\x01 \x01(\x0b\x32\x15.speckle.SqlException2\xac\x03\n\nSqlService\x12?\n\x04\x45xec\x12\x18.speckle.sql.ExecRequest\x1a\x19.speckle.sql.ExecResponse\"\x02P\x01\x12\x45\n\x06\x45xecOp\x12\x1a.speckle.sql.ExecOpRequest\x1a\x1b.speckle.sql.ExecOpResponse\"\x02P\x01\x12N\n\x0bGetMetadata\x12\x1c.speckle.sql.MetadataRequest\x1a\x1d.speckle.sql.MetadataResponse\"\x02P\x01\x12\x64\n\x0eOpenConnection\x12\".speckle.sql.OpenConnectionRequest\x1a#.speckle.sql.OpenConnectionResponse\"\tP\x01\x9a\x01\x04read\x12`\n\x0f\x43loseConnection\x12#.speckle.sql.CloseConnectionRequest\x1a$.speckle.sql.CloseConnectionResponse\"\x02P\x01\x42.\n\x1b\x63om.google.protos.cloud.sql\x10\x02 \x02(\x02P\x01\x80\x01\x00\x88\x01\x00\x90\x01\x00')
  54   ,
  55   dependencies=[google.storage.speckle.proto.client_pb2.DESCRIPTOR,])
  56 _sym_db.RegisterFileDescriptor(DESCRIPTOR)
  57
  58
  59
  60 _EXECREQUEST_STATEMENTTYPE = _descriptor.EnumDescriptor(
  61   name='StatementType',
  62   full_name='speckle.sql.ExecRequest.StatementType',
  63   filename=None,
  64   file=DESCRIPTOR,
  65   values=[
  66     _descriptor.EnumValueDescriptor(
  67       name='STATEMENT', index=0, number=1,
  68       options=None,
  69       type=None),
  70     _descriptor.EnumValueDescriptor(
  71       name='PREPARED_STATEMENT', index=1, number=2,
  72       options=None,
  73       type=None),
  74     _descriptor.EnumValueDescriptor(
  75       name='CALLABLE_STATEMENT', index=2, number=3,
  76       options=None,
  77       type=None),
  78   ],
  79   containing_type=None,
  80   options=None,
  81   serialized_start=403,
  82   serialized_end=481,
  83 )
  84 _sym_db.RegisterEnumDescriptor(_EXECREQUEST_STATEMENTTYPE)
  85
  86
  87 _EXECREQUEST = _descriptor.Descriptor(
  88   name='ExecRequest',
  89   full_name='speckle.sql.ExecRequest',
  90   filename=None,
  91   file=DESCRIPTOR,
  92   containing_type=None,
  93   fields=[
  94     _descriptor.FieldDescriptor(
  95       name='instance', full_name='speckle.sql.ExecRequest.instance', index=0,
  96       number=1, type=9, cpp_type=9, label=2,
  97       has_default_value=False, default_value=_b("").decode('utf-8'),
  98       message_type=None, enum_type=None, containing_type=None,
  99       is_extension=False, extension_scope=None,
 100       options=None),
 101     _descriptor.FieldDescriptor(
 102       name='statement_id', full_name='speckle.sql.ExecRequest.statement_id', index=1,
 103       number=2, type=4, cpp_type=4, label=1,
 104       has_default_value=False, default_value=0,
 105       message_type=None, enum_type=None, containing_type=None,
 106       is_extension=False, extension_scope=None,
 107       options=None),
 108     _descriptor.FieldDescriptor(
 109       name='statement', full_name='speckle.sql.ExecRequest.statement', index=2,
 110       number=3, type=9, cpp_type=9, label=1,
 111       has_default_value=False, default_value=_b("").decode('utf-8'),
 112       message_type=None, enum_type=None, containing_type=None,
 113       is_extension=False, extension_scope=None,
 114       options=None),
 115     _descriptor.FieldDescriptor(
 116       name='bind_variable', full_name='speckle.sql.ExecRequest.bind_variable', index=3,
 117       number=4, type=11, cpp_type=10, label=3,
 118       has_default_value=False, default_value=[],
 119       message_type=None, enum_type=None, containing_type=None,
 120       is_extension=False, extension_scope=None,
 121       options=None),
 122     _descriptor.FieldDescriptor(
 123       name='connection_id', full_name='speckle.sql.ExecRequest.connection_id', index=4,
 124       number=5, type=12, cpp_type=9, label=2,
 125       has_default_value=False, default_value=_b(""),
 126       message_type=None, enum_type=None, containing_type=None,
 127       is_extension=False, extension_scope=None,
 128       options=None),
 129     _descriptor.FieldDescriptor(
 130       name='options', full_name='speckle.sql.ExecRequest.options', index=5,
 131       number=6, type=11, cpp_type=10, label=1,
 132       has_default_value=False, default_value=None,
 133       message_type=None, enum_type=None, containing_type=None,
 134       is_extension=False, extension_scope=None,
 135       options=None),
 136     _descriptor.FieldDescriptor(
 137       name='statement_type', full_name='speckle.sql.ExecRequest.statement_type', index=6,
 138       number=9, type=14, cpp_type=8, label=1,
 139       has_default_value=True, default_value=1,
 140       message_type=None, enum_type=None, containing_type=None,
 141       is_extension=False, extension_scope=None,
 142       options=None),
 143     _descriptor.FieldDescriptor(
 144       name='batch', full_name='speckle.sql.ExecRequest.batch', index=7,
 145       number=10, type=11, cpp_type=10, label=1,
 146       has_default_value=False, default_value=None,
 147       message_type=None, enum_type=None, containing_type=None,
 148       is_extension=False, extension_scope=None,
 149       options=None),
 150     _descriptor.FieldDescriptor(
 151       name='request_id', full_name='speckle.sql.ExecRequest.request_id', index=8,
 152       number=11, type=4, cpp_type=4, label=1,
 153       has_default_value=False, default_value=0,
 154       message_type=None, enum_type=None, containing_type=None,
 155       is_extension=False, extension_scope=None,
 156       options=None),
 157   ],
 158   extensions=[
 159   ],
 160   nested_types=[],
 161   enum_types=[
 162     _EXECREQUEST_STATEMENTTYPE,
 163   ],
 164   options=None,
 165   is_extendable=False,
 166   extension_ranges=[],
 167   oneofs=[
 168   ],
 169   serialized_start=85,
 170   serialized_end=481,
 171 )
 172
 173
 174 _EXECRESPONSE = _descriptor.Descriptor(
 175   name='ExecResponse',
 176   full_name='speckle.sql.ExecResponse',
 177   filename=None,
 178   file=DESCRIPTOR,
 179   containing_type=None,
 180   fields=[
 181     _descriptor.FieldDescriptor(
 182       name='result', full_name='speckle.sql.ExecResponse.result', index=0,
 183       number=1, type=11, cpp_type=10, label=1,
 184       has_default_value=False, default_value=None,
 185       message_type=None, enum_type=None, containing_type=None,
 186       is_extension=False, extension_scope=None,
 187       options=None),
 188     _descriptor.FieldDescriptor(
 189       name='sql_exception', full_name='speckle.sql.ExecResponse.sql_exception', index=1,
 190       number=2, type=11, cpp_type=10, label=1,
 191       has_default_value=False, default_value=None,
 192       message_type=None, enum_type=None, containing_type=None,
 193       is_extension=False, extension_scope=None,
 194       options=None),
 195   ],
 196   extensions=[
 197   ],
 198   nested_types=[],
 199   enum_types=[
 200   ],
 201   options=None,
 202   is_extendable=False,
 203   extension_ranges=[],
 204   oneofs=[
 205   ],
 206   serialized_start=483,
 207   serialized_end=581,
 208 )
 209
 210
 211 _EXECOPREQUEST = _descriptor.Descriptor(
 212   name='ExecOpRequest',
 213   full_name='speckle.sql.ExecOpRequest',
 214   filename=None,
 215   file=DESCRIPTOR,
 216   containing_type=None,
 217   fields=[
 218     _descriptor.FieldDescriptor(
 219       name='instance', full_name='speckle.sql.ExecOpRequest.instance', index=0,
 220       number=1, type=9, cpp_type=9, label=2,
 221       has_default_value=False, default_value=_b("").decode('utf-8'),
 222       message_type=None, enum_type=None, containing_type=None,
 223       is_extension=False, extension_scope=None,
 224       options=None),
 225     _descriptor.FieldDescriptor(
 226       name='connection_id', full_name='speckle.sql.ExecOpRequest.connection_id', index=1,
 227       number=2, type=12, cpp_type=9, label=2,
 228       has_default_value=False, default_value=_b(""),
 229       message_type=None, enum_type=None, containing_type=None,
 230       is_extension=False, extension_scope=None,
 231       options=None),
 232     _descriptor.FieldDescriptor(
 233       name='op', full_name='speckle.sql.ExecOpRequest.op', index=2,
 234       number=3, type=11, cpp_type=10, label=2,
 235       has_default_value=False, default_value=None,
 236       message_type=None, enum_type=None, containing_type=None,
 237       is_extension=False, extension_scope=None,
 238       options=None),
 239     _descriptor.FieldDescriptor(
 240       name='request_id', full_name='speckle.sql.ExecOpRequest.request_id', index=3,
 241       number=8, type=4, cpp_type=4, label=1,
 242       has_default_value=False, default_value=0,
 243       message_type=None, enum_type=None, containing_type=None,
 244       is_extension=False, extension_scope=None,
 245       options=None),
 246   ],
 247   extensions=[
 248   ],
 249   nested_types=[],
 250   enum_types=[
 251   ],
 252   options=None,
 253   is_extendable=False,
 254   extension_ranges=[],
 255   oneofs=[
 256   ],
 257   serialized_start=583,
 258   serialized_end=689,
 259 )
 260
 261
 262 _EXECOPRESPONSE = _descriptor.Descriptor(
 263   name='ExecOpResponse',
 264   full_name='speckle.sql.ExecOpResponse',
 265   filename=None,
 266   file=DESCRIPTOR,
 267   containing_type=None,
 268   fields=[
 269     _descriptor.FieldDescriptor(
 270       name='native_sql', full_name='speckle.sql.ExecOpResponse.native_sql', index=0,
 271       number=1, type=9, cpp_type=9, label=1,
 272       has_default_value=False, default_value=_b("").decode('utf-8'),
 273       message_type=None, enum_type=None, containing_type=None,
 274       is_extension=False, extension_scope=None,
 275       options=None),
 276     _descriptor.FieldDescriptor(
 277       name='savepoint', full_name='speckle.sql.ExecOpResponse.savepoint', index=1,
 278       number=2, type=11, cpp_type=10, label=1,
 279       has_default_value=False, default_value=None,
 280       message_type=None, enum_type=None, containing_type=None,
 281       is_extension=False, extension_scope=None,
 282       options=None),
 283     _descriptor.FieldDescriptor(
 284       name='sql_exception', full_name='speckle.sql.ExecOpResponse.sql_exception', index=2,
 285       number=3, type=11, cpp_type=10, label=1,
 286       has_default_value=False, default_value=None,
 287       message_type=None, enum_type=None, containing_type=None,
 288       is_extension=False, extension_scope=None,
 289       options=None),
 290     _descriptor.FieldDescriptor(
 291       name='result', full_name='speckle.sql.ExecOpResponse.result', index=3,
 292       number=4, type=11, cpp_type=10, label=1,
 293       has_default_value=False, default_value=None,
 294       message_type=None, enum_type=None, containing_type=None,
 295       is_extension=False, extension_scope=None,
 296       options=None),
 297     _descriptor.FieldDescriptor(
 298       name='cached_rpc_error', full_name='speckle.sql.ExecOpResponse.cached_rpc_error', index=4,
 299       number=5, type=11, cpp_type=10, label=1,
 300       has_default_value=False, default_value=None,
 301       message_type=None, enum_type=None, containing_type=None,
 302       is_extension=False, extension_scope=None,
 303       options=None),
 304     _descriptor.FieldDescriptor(
 305       name='cached_payload', full_name='speckle.sql.ExecOpResponse.cached_payload', index=5,
 306       number=6, type=12, cpp_type=9, label=1,
 307       has_default_value=False, default_value=_b(""),
 308       message_type=None, enum_type=None, containing_type=None,
 309       is_extension=False, extension_scope=None,
 310       options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001'))),
 311   ],
 312   extensions=[
 313   ],
 314   nested_types=[],
 315   enum_types=[
 316   ],
 317   options=None,
 318   is_extendable=False,
 319   extension_ranges=[],
 320   oneofs=[
 321   ],
 322   serialized_start=692,
 323   serialized_end=929,
 324 )
 325
 326
 327 _METADATAREQUEST = _descriptor.Descriptor(
 328   name='MetadataRequest',
 329   full_name='speckle.sql.MetadataRequest',
 330   filename=None,
 331   file=DESCRIPTOR,
 332   containing_type=None,
 333   fields=[
 334     _descriptor.FieldDescriptor(
 335       name='instance', full_name='speckle.sql.MetadataRequest.instance', index=0,
 336       number=1, type=9, cpp_type=9, label=2,
 337       has_default_value=False, default_value=_b("").decode('utf-8'),
 338       message_type=None, enum_type=None, containing_type=None,
 339       is_extension=False, extension_scope=None,
 340       options=None),
 341     _descriptor.FieldDescriptor(
 342       name='metadata', full_name='speckle.sql.MetadataRequest.metadata', index=1,
 343       number=3, type=14, cpp_type=8, label=2,
 344       has_default_value=False, default_value=1,
 345       message_type=None, enum_type=None, containing_type=None,
 346       is_extension=False, extension_scope=None,
 347       options=None),
 348     _descriptor.FieldDescriptor(
 349       name='bind_variable', full_name='speckle.sql.MetadataRequest.bind_variable', index=2,
 350       number=4, type=11, cpp_type=10, label=3,
 351       has_default_value=False, default_value=[],
 352       message_type=None, enum_type=None, containing_type=None,
 353       is_extension=False, extension_scope=None,
 354       options=None),
 355     _descriptor.FieldDescriptor(
 356       name='connection_id', full_name='speckle.sql.MetadataRequest.connection_id', index=3,
 357       number=5, type=12, cpp_type=9, label=2,
 358       has_default_value=False, default_value=_b(""),
 359       message_type=None, enum_type=None, containing_type=None,
 360       is_extension=False, extension_scope=None,
 361       options=None),
 362     _descriptor.FieldDescriptor(
 363       name='request_id', full_name='speckle.sql.MetadataRequest.request_id', index=4,
 364       number=8, type=4, cpp_type=4, label=1,
 365       has_default_value=False, default_value=0,
 366       message_type=None, enum_type=None, containing_type=None,
 367       is_extension=False, extension_scope=None,
 368       options=None),
 369   ],
 370   extensions=[
 371   ],
 372   nested_types=[],
 373   enum_types=[
 374   ],
 375   options=None,
 376   is_extendable=False,
 377   extension_ranges=[],
 378   oneofs=[
 379   ],
 380   serialized_start=932,
 381   serialized_end=1102,
 382 )
 383
 384
 385 _METADATARESPONSE = _descriptor.Descriptor(
 386   name='MetadataResponse',
 387   full_name='speckle.sql.MetadataResponse',
 388   filename=None,
 389   file=DESCRIPTOR,
 390   containing_type=None,
 391   fields=[
 392     _descriptor.FieldDescriptor(
 393       name='result', full_name='speckle.sql.MetadataResponse.result', index=0,
 394       number=1, type=11, cpp_type=10, label=1,
 395       has_default_value=False, default_value=None,
 396       message_type=None, enum_type=None, containing_type=None,
 397       is_extension=False, extension_scope=None,
 398       options=None),
 399     _descriptor.FieldDescriptor(
 400       name='jdbc_database_metadata', full_name='speckle.sql.MetadataResponse.jdbc_database_metadata', index=1,
 401       number=2, type=11, cpp_type=10, label=1,
 402       has_default_value=False, default_value=None,
 403       message_type=None, enum_type=None, containing_type=None,
 404       is_extension=False, extension_scope=None,
 405       options=None),
 406     _descriptor.FieldDescriptor(
 407       name='sql_exception', full_name='speckle.sql.MetadataResponse.sql_exception', index=2,
 408       number=3, type=11, cpp_type=10, label=1,
 409       has_default_value=False, default_value=None,
 410       message_type=None, enum_type=None, containing_type=None,
 411       is_extension=False, extension_scope=None,
 412       options=None),
 413   ],
 414   extensions=[
 415   ],
 416   nested_types=[],
 417   enum_types=[
 418   ],
 419   options=None,
 420   is_extendable=False,
 421   extension_ranges=[],
 422   oneofs=[
 423   ],
 424   serialized_start=1105,
 425   serialized_end=1275,
 426 )
 427
 428
 429 _OPENCONNECTIONREQUEST = _descriptor.Descriptor(
 430   name='OpenConnectionRequest',
 431   full_name='speckle.sql.OpenConnectionRequest',
 432   filename=None,
 433   file=DESCRIPTOR,
 434   containing_type=None,
 435   fields=[
 436     _descriptor.FieldDescriptor(
 437       name='instance', full_name='speckle.sql.OpenConnectionRequest.instance', index=0,
 438       number=1, type=9, cpp_type=9, label=2,
 439       has_default_value=False, default_value=_b("").decode('utf-8'),
 440       message_type=None, enum_type=None, containing_type=None,
 441       is_extension=False, extension_scope=None,
 442       options=None),
 443     _descriptor.FieldDescriptor(
 444       name='property', full_name='speckle.sql.OpenConnectionRequest.property', index=1,
 445       number=2, type=11, cpp_type=10, label=3,
 446       has_default_value=False, default_value=[],
 447       message_type=None, enum_type=None, containing_type=None,
 448       is_extension=False, extension_scope=None,
 449       options=None),
 450     _descriptor.FieldDescriptor(
 451       name='protocol_version', full_name='speckle.sql.OpenConnectionRequest.protocol_version', index=2,
 452       number=5, type=4, cpp_type=4, label=1,
 453       has_default_value=True, default_value=1,
 454       message_type=None, enum_type=None, containing_type=None,
 455       is_extension=False, extension_scope=None,
 456       options=None),
 457     _descriptor.FieldDescriptor(
 458       name='client_type', full_name='speckle.sql.OpenConnectionRequest.client_type', index=3,
 459       number=6, type=14, cpp_type=8, label=1,
 460       has_default_value=True, default_value=1,
 461       message_type=None, enum_type=None, containing_type=None,
 462       is_extension=False, extension_scope=None,
 463       options=None),
 464   ],
 465   extensions=[
 466   ],
 467   nested_types=[],
 468   enum_types=[
 469   ],
 470   options=None,
 471   is_extendable=False,
 472   extension_ranges=[],
 473   oneofs=[
 474   ],
 475   serialized_start=1278,
 476   serialized_end=1450,
 477 )
 478
 479
 480 _OPENCONNECTIONRESPONSE = _descriptor.Descriptor(
 481   name='OpenConnectionResponse',
 482   full_name='speckle.sql.OpenConnectionResponse',
 483   filename=None,
 484   file=DESCRIPTOR,
 485   containing_type=None,
 486   fields=[
 487     _descriptor.FieldDescriptor(
 488       name='connection_id', full_name='speckle.sql.OpenConnectionResponse.connection_id', index=0,
 489       number=1, type=12, cpp_type=9, label=1,
 490       has_default_value=False, default_value=_b(""),
 491       message_type=None, enum_type=None, containing_type=None,
 492       is_extension=False, extension_scope=None,
 493       options=None),
 494     _descriptor.FieldDescriptor(
 495       name='sql_exception', full_name='speckle.sql.OpenConnectionResponse.sql_exception', index=1,
 496       number=2, type=11, cpp_type=10, label=1,
 497       has_default_value=False, default_value=None,
 498       message_type=None, enum_type=None, containing_type=None,
 499       is_extension=False, extension_scope=None,
 500       options=None),
 501     _descriptor.FieldDescriptor(
 502       name='warnings', full_name='speckle.sql.OpenConnectionResponse.warnings', index=2,
 503       number=6, type=11, cpp_type=10, label=3,
 504       has_default_value=False, default_value=[],
 505       message_type=None, enum_type=None, containing_type=None,
 506       is_extension=False, extension_scope=None,
 507       options=None),
 508   ],
 509   extensions=[
 510   ],
 511   nested_types=[],
 512   enum_types=[
 513   ],
 514   options=None,
 515   is_extendable=False,
 516   extension_ranges=[],
 517   oneofs=[
 518   ],
 519   serialized_start=1453,
 520   serialized_end=1587,
 521 )
 522
 523
 524 _CLOSECONNECTIONREQUEST = _descriptor.Descriptor(
 525   name='CloseConnectionRequest',
 526   full_name='speckle.sql.CloseConnectionRequest',
 527   filename=None,
 528   file=DESCRIPTOR,
 529   containing_type=None,
 530   fields=[
 531     _descriptor.FieldDescriptor(
 532       name='instance', full_name='speckle.sql.CloseConnectionRequest.instance', index=0,
 533       number=1, type=9, cpp_type=9, label=2,
 534       has_default_value=False, default_value=_b("").decode('utf-8'),
 535       message_type=None, enum_type=None, containing_type=None,
 536       is_extension=False, extension_scope=None,
 537       options=None),
 538     _descriptor.FieldDescriptor(
 539       name='connection_id', full_name='speckle.sql.CloseConnectionRequest.connection_id', index=1,
 540       number=2, type=12, cpp_type=9, label=2,
 541       has_default_value=False, default_value=_b(""),
 542       message_type=None, enum_type=None, containing_type=None,
 543       is_extension=False, extension_scope=None,
 544       options=None),
 545   ],
 546   extensions=[
 547   ],
 548   nested_types=[],
 549   enum_types=[
 550   ],
 551   options=None,
 552   is_extendable=False,
 553   extension_ranges=[],
 554   oneofs=[
 555   ],
 556   serialized_start=1589,
 557   serialized_end=1654,
 558 )
 559
 560
 561 _CLOSECONNECTIONRESPONSE = _descriptor.Descriptor(
 562   name='CloseConnectionResponse',
 563   full_name='speckle.sql.CloseConnectionResponse',
 564   filename=None,
 565   file=DESCRIPTOR,
 566   containing_type=None,
 567   fields=[
 568     _descriptor.FieldDescriptor(
 569       name='sql_exception', full_name='speckle.sql.CloseConnectionResponse.sql_exception', index=0,
 570       number=1, type=11, cpp_type=10, label=1,
 571       has_default_value=False, default_value=None,
 572       message_type=None, enum_type=None, containing_type=None,
 573       is_extension=False, extension_scope=None,
 574       options=None),
 575   ],
 576   extensions=[
 577   ],
 578   nested_types=[],
 579   enum_types=[
 580   ],
 581   options=None,
 582   is_extendable=False,
 583   extension_ranges=[],
 584   oneofs=[
 585   ],
 586   serialized_start=1656,
 587   serialized_end=1727,
 588 )
 589
 590 _EXECREQUEST.fields_by_name['bind_variable'].message_type = google.storage.speckle.proto.client_pb2._BINDVARIABLEPROTO
 591 _EXECREQUEST.fields_by_name['options'].message_type = google.storage.speckle.proto.client_pb2._EXECOPTIONS
 592 _EXECREQUEST.fields_by_name['statement_type'].enum_type = _EXECREQUEST_STATEMENTTYPE
 593 _EXECREQUEST.fields_by_name['batch'].message_type = google.storage.speckle.proto.client_pb2._BATCHPROTO
 594 _EXECREQUEST_STATEMENTTYPE.containing_type = _EXECREQUEST
 595 _EXECRESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 596 _EXECRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 597 _EXECOPREQUEST.fields_by_name['op'].message_type = google.storage.speckle.proto.client_pb2._OPPROTO
 598 _EXECOPRESPONSE.fields_by_name['savepoint'].message_type = google.storage.speckle.proto.client_pb2._SAVEPOINT
 599 _EXECOPRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 600 _EXECOPRESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 601 _EXECOPRESPONSE.fields_by_name['cached_rpc_error'].message_type = google.storage.speckle.proto.client_pb2._RPCERRORPROTO
 602 _METADATAREQUEST.fields_by_name['metadata'].enum_type = google.storage.speckle.proto.client_pb2._METADATATYPE
 603 _METADATAREQUEST.fields_by_name['bind_variable'].message_type = google.storage.speckle.proto.client_pb2._BINDVARIABLEPROTO
 604 _METADATARESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 605 _METADATARESPONSE.fields_by_name['jdbc_database_metadata'].message_type = google.storage.speckle.proto.client_pb2._JDBCDATABASEMETADATAPROTO
 606 _METADATARESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 607 _OPENCONNECTIONREQUEST.fields_by_name['property'].message_type = google.storage.speckle.proto.client_pb2._PROPERTY
 608 _OPENCONNECTIONREQUEST.fields_by_name['client_type'].enum_type = google.storage.speckle.proto.client_pb2._CLIENTTYPE
 609 _OPENCONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 610 _OPENCONNECTIONRESPONSE.fields_by_name['warnings'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 611 _CLOSECONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 612 DESCRIPTOR.message_types_by_name['ExecRequest'] = _EXECREQUEST
 613 DESCRIPTOR.message_types_by_name['ExecResponse'] = _EXECRESPONSE
 614 DESCRIPTOR.message_types_by_name['ExecOpRequest'] = _EXECOPREQUEST
 615 DESCRIPTOR.message_types_by_name['ExecOpResponse'] = _EXECOPRESPONSE
 616 DESCRIPTOR.message_types_by_name['MetadataRequest'] = _METADATAREQUEST
 617 DESCRIPTOR.message_types_by_name['MetadataResponse'] = _METADATARESPONSE
 618 DESCRIPTOR.message_types_by_name['OpenConnectionRequest'] = _OPENCONNECTIONREQUEST
 619 DESCRIPTOR.message_types_by_name['OpenConnectionResponse'] = _OPENCONNECTIONRESPONSE
 620 DESCRIPTOR.message_types_by_name['CloseConnectionRequest'] = _CLOSECONNECTIONREQUEST
 621 DESCRIPTOR.message_types_by_name['CloseConnectionResponse'] = _CLOSECONNECTIONRESPONSE
 622
 623 ExecRequest = _reflection.GeneratedProtocolMessageType('ExecRequest', (_message.Message,), dict(
 624   DESCRIPTOR = _EXECREQUEST,
 625   __module__ = 'google.storage.speckle.proto.sql_pb2'
 626
 627   ))
 628 _sym_db.RegisterMessage(ExecRequest)
 629
 630 ExecResponse = _reflection.GeneratedProtocolMessageType('ExecResponse', (_message.Message,), dict(
 631   DESCRIPTOR = _EXECRESPONSE,
 632   __module__ = 'google.storage.speckle.proto.sql_pb2'
 633
 634   ))
 635 _sym_db.RegisterMessage(ExecResponse)
 636
 637 ExecOpRequest = _reflection.GeneratedProtocolMessageType('ExecOpRequest', (_message.Message,), dict(
 638   DESCRIPTOR = _EXECOPREQUEST,
 639   __module__ = 'google.storage.speckle.proto.sql_pb2'
 640
 641   ))
 642 _sym_db.RegisterMessage(ExecOpRequest)
 643
 644 ExecOpResponse = _reflection.GeneratedProtocolMessageType('ExecOpResponse', (_message.Message,), dict(
 645   DESCRIPTOR = _EXECOPRESPONSE,
 646   __module__ = 'google.storage.speckle.proto.sql_pb2'
 647
 648   ))
 649 _sym_db.RegisterMessage(ExecOpResponse)
 650
 651 MetadataRequest = _reflection.GeneratedProtocolMessageType('MetadataRequest', (_message.Message,), dict(
 652   DESCRIPTOR = _METADATAREQUEST,
 653   __module__ = 'google.storage.speckle.proto.sql_pb2'
 654
 655   ))
 656 _sym_db.RegisterMessage(MetadataRequest)
 657
 658 MetadataResponse = _reflection.GeneratedProtocolMessageType('MetadataResponse', (_message.Message,), dict(
 659   DESCRIPTOR = _METADATARESPONSE,
 660   __module__ = 'google.storage.speckle.proto.sql_pb2'
 661
 662   ))
 663 _sym_db.RegisterMessage(MetadataResponse)
 664
 665 OpenConnectionRequest = _reflection.GeneratedProtocolMessageType('OpenConnectionRequest', (_message.Message,), dict(
 666   DESCRIPTOR = _OPENCONNECTIONREQUEST,
 667   __module__ = 'google.storage.speckle.proto.sql_pb2'
 668
 669   ))
 670 _sym_db.RegisterMessage(OpenConnectionRequest)
 671
 672 OpenConnectionResponse = _reflection.GeneratedProtocolMessageType('OpenConnectionResponse', (_message.Message,), dict(
 673   DESCRIPTOR = _OPENCONNECTIONRESPONSE,
 674   __module__ = 'google.storage.speckle.proto.sql_pb2'
 675
 676   ))
 677 _sym_db.RegisterMessage(OpenConnectionResponse)
 678
 679 CloseConnectionRequest = _reflection.GeneratedProtocolMessageType('CloseConnectionRequest', (_message.Message,), dict(
 680   DESCRIPTOR = _CLOSECONNECTIONREQUEST,
 681   __module__ = 'google.storage.speckle.proto.sql_pb2'
 682
 683   ))
 684 _sym_db.RegisterMessage(CloseConnectionRequest)
 685
 686 CloseConnectionResponse = _reflection.GeneratedProtocolMessageType('CloseConnectionResponse', (_message.Message,), dict(
 687   DESCRIPTOR = _CLOSECONNECTIONRESPONSE,
 688   __module__ = 'google.storage.speckle.proto.sql_pb2'
 689
 690   ))
 691 _sym_db.RegisterMessage(CloseConnectionResponse)
 692
 693
 694 DESCRIPTOR.has_options = True
 695 DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n\033com.google.protos.cloud.sql\020\002 \002(\002P\001\200\001\000\210\001\000\220\001\000'))
 696 _EXECOPRESPONSE.fields_by_name['cached_payload'].has_options = True
 697 _EXECOPRESPONSE.fields_by_name['cached_payload']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001'))
 698
 699
 700 class _SqlService_ClientBaseStub(_client_stub_base_class):
 701   """Makes Stubby RPC calls to a SqlService server."""
 702
 703   __slots__ = (
 704       '_protorpc_Exec', '_full_name_Exec',
 705       '_protorpc_ExecOp', '_full_name_ExecOp',
 706       '_protorpc_GetMetadata', '_full_name_GetMetadata',
 707       '_protorpc_OpenConnection', '_full_name_OpenConnection',
 708       '_protorpc_CloseConnection', '_full_name_CloseConnection',
 709   )
 710
 711   def __init__(self, rpc_stub):
 712     self._stub = rpc_stub
 713
 714     self._protorpc_Exec = pywraprpc.RPC()
 715     self._protorpc_Exec.set_fail_fast(True)
 716     self._full_name_Exec = self._stub.GetFullMethodName(
 717         'Exec')
 718
 719     self._protorpc_ExecOp = pywraprpc.RPC()
 720     self._protorpc_ExecOp.set_fail_fast(True)
 721     self._full_name_ExecOp = self._stub.GetFullMethodName(
 722         'ExecOp')
 723
 724     self._protorpc_GetMetadata = pywraprpc.RPC()
 725     self._protorpc_GetMetadata.set_fail_fast(True)
 726     self._full_name_GetMetadata = self._stub.GetFullMethodName(
 727         'GetMetadata')
 728
 729     self._protorpc_OpenConnection = pywraprpc.RPC()
 730     self._protorpc_OpenConnection.set_fail_fast(True)
 731     self._full_name_OpenConnection = self._stub.GetFullMethodName(
 732         'OpenConnection')
 733
 734     self._protorpc_CloseConnection = pywraprpc.RPC()
 735     self._protorpc_CloseConnection.set_fail_fast(True)
 736     self._full_name_CloseConnection = self._stub.GetFullMethodName(
 737         'CloseConnection')
 738
 739   def Exec(self, request, rpc=None, callback=None, response=None):
 740     """Make a Exec RPC call.
 741
 742     Args:
 743       request: a ExecRequest instance.
 744       rpc: Optional RPC instance to use for the call.
 745       callback: Optional final callback. Will be called as
 746           callback(rpc, result) when the rpc completes. If None, the
 747           call is synchronous.
 748       response: Optional ProtocolMessage to be filled in with response.
 749
 750     Returns:
 751       The ExecResponse if callback is None. Otherwise, returns None.
 752     """
 753
 754     if response is None:
 755       response = ExecResponse
 756     return self._MakeCall(rpc,
 757                           self._full_name_Exec,
 758                           'Exec',
 759                           request,
 760                           response,
 761                           callback,
 762                           self._protorpc_Exec)
 763
 764   def ExecOp(self, request, rpc=None, callback=None, response=None):
 765     """Make a ExecOp RPC call.
 766
 767     Args:
 768       request: a ExecOpRequest instance.
 769       rpc: Optional RPC instance to use for the call.
 770       callback: Optional final callback. Will be called as
 771           callback(rpc, result) when the rpc completes. If None, the
 772           call is synchronous.
 773       response: Optional ProtocolMessage to be filled in with response.
 774
 775     Returns:
 776       The ExecOpResponse if callback is None. Otherwise, returns None.
 777     """
 778
 779     if response is None:
 780       response = ExecOpResponse
 781     return self._MakeCall(rpc,
 782                           self._full_name_ExecOp,
 783                           'ExecOp',
 784                           request,
 785                           response,
 786                           callback,
 787                           self._protorpc_ExecOp)
 788
 789   def GetMetadata(self, request, rpc=None, callback=None, response=None):
 790     """Make a GetMetadata RPC call.
 791
 792     Args:
 793       request: a MetadataRequest instance.
 794       rpc: Optional RPC instance to use for the call.
 795       callback: Optional final callback. Will be called as
 796           callback(rpc, result) when the rpc completes. If None, the
 797           call is synchronous.
 798       response: Optional ProtocolMessage to be filled in with response.
 799
 800     Returns:
 801       The MetadataResponse if callback is None. Otherwise, returns None.
 802     """
 803
 804     if response is None:
 805       response = MetadataResponse
 806     return self._MakeCall(rpc,
 807                           self._full_name_GetMetadata,
 808                           'GetMetadata',
 809                           request,
 810                           response,
 811                           callback,
 812                           self._protorpc_GetMetadata)
 813
 814   def OpenConnection(self, request, rpc=None, callback=None, response=None):
 815     """Make a OpenConnection RPC call.
 816
 817     Args:
 818       request: a OpenConnectionRequest instance.
 819       rpc: Optional RPC instance to use for the call.
 820       callback: Optional final callback. Will be called as
 821           callback(rpc, result) when the rpc completes. If None, the
 822           call is synchronous.
 823       response: Optional ProtocolMessage to be filled in with response.
 824
 825     Returns:
 826       The OpenConnectionResponse if callback is None. Otherwise, returns None.
 827     """
 828
 829     if response is None:
 830       response = OpenConnectionResponse
 831     return self._MakeCall(rpc,
 832                           self._full_name_OpenConnection,
 833                           'OpenConnection',
 834                           request,
 835                           response,
 836                           callback,
 837                           self._protorpc_OpenConnection)
 838
 839   def CloseConnection(self, request, rpc=None, callback=None, response=None):
 840     """Make a CloseConnection RPC call.
 841
 842     Args:
 843       request: a CloseConnectionRequest instance.
 844       rpc: Optional RPC instance to use for the call.
 845       callback: Optional final callback. Will be called as
 846           callback(rpc, result) when the rpc completes. If None, the
 847           call is synchronous.
 848       response: Optional ProtocolMessage to be filled in with response.
 849
 850     Returns:
 851       The CloseConnectionResponse if callback is None. Otherwise, returns None.
 852     """
 853
 854     if response is None:
 855       response = CloseConnectionResponse
 856     return self._MakeCall(rpc,
 857                           self._full_name_CloseConnection,
 858                           'CloseConnection',
 859                           request,
 860                           response,
 861                           callback,
 862                           self._protorpc_CloseConnection)
 863
 864
 865 class _SqlService_ClientStub(_SqlService_ClientBaseStub):
 866   __slots__ = ('_params',)
 867   def __init__(self, rpc_stub_parameters, service_name):
 868     if service_name is None:
 869       service_name = 'SqlService'
 870     _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, rpc_stub_parameters))
 871     self._params = rpc_stub_parameters
 872
 873
 874 class _SqlService_RPC2ClientStub(_SqlService_ClientBaseStub):
 875   __slots__ = ()
 876   def __init__(self, server, channel, service_name):
 877     if service_name is None:
 878       service_name = 'SqlService'
 879     if channel is not None:
 880       if channel.version() == 1:
 881         raise RuntimeError('Expecting an RPC2 channel to create the stub')
 882       _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, channel))
 883     elif server is not None:
 884       _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, pywraprpc.NewClientChannel(server)))
 885     else:
 886       raise RuntimeError('Invalid argument combination to create a stub')
 887
 888
 889 class SqlService(_server_stub_base_class):
 890   """Base class for SqlService Stubby servers."""
 891
 892   @classmethod
 893   def _MethodSignatures(cls):
 894     """Returns a dict of {<method-name>: (<request-type>, <response-type>)}."""
 895     return {
 896       'Exec': (ExecRequest, ExecResponse),
 897       'ExecOp': (ExecOpRequest, ExecOpResponse),
 898       'GetMetadata': (MetadataRequest, MetadataResponse),
 899       'OpenConnection': (OpenConnectionRequest, OpenConnectionResponse),
 900       'CloseConnection': (CloseConnectionRequest, CloseConnectionResponse),
 901       }
 902
 903   @classmethod
 904   def _StreamMethodSignatures(cls):
 905     """Returns a dict of {<method-name>: (<request-type>, <stream-type>, <response-type>)}."""
 906     return {
 907       }
 908
 909   def __init__(self, *args, **kwargs):
 910     """Creates a Stubby RPC server.
 911
 912     See BaseRpcServer.__init__ in rpcserver.py for detail on arguments.
 913     """
 914     if _server_stub_base_class is object:
 915       raise NotImplementedError('Add //net/rpc/python:rpcserver as a '
 916                                 'dependency for Stubby server support.')
 917     _server_stub_base_class.__init__(self, 'speckle.sql.SqlService', *args, **kwargs)
 918
 919   @staticmethod
 920   def NewStub(rpc_stub_parameters, service_name=None):
 921     """Creates a new SqlService Stubby client stub.
 922
 923     Args:
 924       rpc_stub_parameters: an RPC_StubParameter instance.
 925       service_name: the service name used by the Stubby server.
 926     """
 927
 928     if _client_stub_base_class is object:
 929       raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby')
 930     return _SqlService_ClientStub(rpc_stub_parameters, service_name)
 931
 932   @staticmethod
 933   def NewRPC2Stub(server=None, channel=None, service_name=None):
 934     """Creates a new SqlService Stubby2 client stub.
 935
 936     Args:
 937       server: host:port or bns address.
 938       channel: directly use a channel to create a stub. Will ignore server
 939           argument if this is specified.
 940       service_name: the service name used by the Stubby server.
 941     """
 942
 943     if _client_stub_base_class is object:
 944       raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby')
 945     return _SqlService_RPC2ClientStub(server, channel, service_name)
 946
 947   def Exec(self, rpc, request, response):
 948     """Handles a Exec RPC call. You should override this.
 949
 950     Args:
 951       rpc: a Stubby RPC object
 952       request: a ExecRequest that contains the client request
 953       response: a ExecResponse that should be modified to send the response
 954     """
 955     raise NotImplementedError
 956
 957
 958   def ExecOp(self, rpc, request, response):
 959     """Handles a ExecOp RPC call. You should override this.
 960
 961     Args:
 962       rpc: a Stubby RPC object
 963       request: a ExecOpRequest that contains the client request
 964       response: a ExecOpResponse that should be modified to send the response
 965     """
 966     raise NotImplementedError
 967
 968
 969   def GetMetadata(self, rpc, request, response):
 970     """Handles a GetMetadata RPC call. You should override this.
 971
 972     Args:
 973       rpc: a Stubby RPC object
 974       request: a MetadataRequest that contains the client request
 975       response: a MetadataResponse that should be modified to send the response
 976     """
 977     raise NotImplementedError
 978
 979
 980   def OpenConnection(self, rpc, request, response):
 981     """Handles a OpenConnection RPC call. You should override this.
 982
 983     Args:
 984       rpc: a Stubby RPC object
 985       request: a OpenConnectionRequest that contains the client request
 986       response: a OpenConnectionResponse that should be modified to send the response
 987     """
 988     raise NotImplementedError
 989
 990
 991   def CloseConnection(self, rpc, request, response):
 992     """Handles a CloseConnection RPC call. You should override this.
 993
 994     Args:
 995       rpc: a Stubby RPC object
 996       request: a CloseConnectionRequest that contains the client request
 997       response: a CloseConnectionResponse that should be modified to send the response
 998     """
 999     raise NotImplementedError
1000
1001   def _AddMethodAttributes(self):
1002     """Sets attributes on Python RPC handlers.
1003
1004     See BaseRpcServer in rpcserver.py for details.
1005     """
1006     rpcserver._GetHandlerDecorator(
1007         getattr(self.Exec, '__func__'),
1008         ExecRequest,
1009         ExecResponse,
1010         None,
1011         'INTEGRITY')
1012     rpcserver._GetHandlerDecorator(
1013         getattr(self.ExecOp, '__func__'),
1014         ExecOpRequest,
1015         ExecOpResponse,
1016         None,
1017         'INTEGRITY')
1018     rpcserver._GetHandlerDecorator(
1019         getattr(self.GetMetadata, '__func__'),
1020         MetadataRequest,
1021         MetadataResponse,
1022         None,
1023         'INTEGRITY')
1024     rpcserver._GetHandlerDecorator(
1025         getattr(self.OpenConnection, '__func__'),
1026         OpenConnectionRequest,
1027         OpenConnectionResponse,
1028         None,
1029         'INTEGRITY')
1030     rpcserver._GetHandlerDecorator(
1031         getattr(self.CloseConnection, '__func__'),
1032         CloseConnectionRequest,
1033         CloseConnectionResponse,
1034         None,
1035         'INTEGRITY')
1036
1037