# Generated by the protocol buffer compiler. DO NOT EDIT! # source: src/payloads.proto import sys _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) from google.protobuf import descriptor as _descriptor from google.protobuf import message as _message from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database from google.protobuf import descriptor_pb2 # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor.FileDescriptor( name='src/payloads.proto', package='payloads.proto', syntax='proto3', serialized_pb=_b('\n\x12src/payloads.proto\x12\x0epayloads.proto\"Z\n\x0cValueWrapper\x12\x10\n\x06string\x18\x01 \x01(\tH\x00\x12\x0e\n\x04int8\x18\x02 \x01(\x03H\x00\x12\x0e\n\x04int4\x18\x03 \x01(\x05H\x00\x12\x0f\n\x05\x62ytes\x18\x04 \x01(\x0cH\x00\x42\x07\n\x05value\"\x99\x01\n\x11JsonObjectWrapper\x12\x39\n\x04\x62ody\x18\x01 \x03(\x0b\x32+.payloads.proto.JsonObjectWrapper.BodyEntry\x1aI\n\tBodyEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12+\n\x05value\x18\x02 \x01(\x0b\x32\x1c.payloads.proto.ValueWrapper:\x02\x38\x01\";\n\x0bRowResponse\x12,\n\x06values\x18\x01 \x03(\x0b\x32\x1c.payloads.proto.ValueWrapper\"W\n\x14QuerySuccessResponse\x12\x14\n\x0c\x63olumn_names\x18\x02 \x03(\t\x12)\n\x04rows\x18\x03 \x03(\x0b\x32\x1b.payloads.proto.RowResponse\"\xd7\x02\n\rErrorResponse\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x02 \x01(\t\x12;\n\nerror_type\x18\x03 \x01(\x0e\x32\'.payloads.proto.ErrorResponse.ErrorType\"\xdf\x01\n\tErrorType\x12\x1b\n\x17\x43ONNECTION_CONFIG_ERROR\x10\x00\x12\x15\n\x11\x43REATE_POOL_ERROR\x10\x01\x12\x1b\n\x17\x46ORBIDDEN_CONNECTION_ID\x10\x02\x12\x16\n\x12MISSING_CONNECTION\x10\x03\x12\x0e\n\nPOOL_ERROR\x10\x04\x12\x12\n\x0ePOSTGRES_ERROR\x10\x05\x12\x11\n\rSTORAGE_ERROR\x10\x06\x12\x17\n\x13WRONG_NUM_OF_PARAMS\x10\x07\x12\x19\n\x15UNKNOWN_PG_VALUE_TYPE\x10\x08\"\x83\x01\n\rQueryResponse\x12\x37\n\x07success\x18\x01 \x01(\x0b\x32$.payloads.proto.QuerySuccessResponseH\x00\x12.\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1d.payloads.proto.ErrorResponseH\x00\x42\t\n\x07payload\"b\n\x0cQueryRequest\x12\x15\n\rconnection_id\x18\x01 \x01(\t\x12\r\n\x05query\x18\x02 \x01(\t\x12,\n\x06params\x18\x03 \x03(\x0b\x32\x1c.payloads.proto.ValueWrapper\"A\n\x11TxBulkQueryParams\x12,\n\x06values\x18\x01 \x03(\x0b\x32\x1c.payloads.proto.ValueWrapper\"Z\n\x16TxBulkQueryRequestBody\x12\r\n\x05query\x18\x01 \x01(\t\x12\x31\n\x06params\x18\x02 \x03(\x0b\x32!.payloads.proto.TxBulkQueryParams\"d\n\x12TxBulkQueryRequest\x12\x15\n\rconnection_id\x18\x01 \x01(\t\x12\x37\n\x07queries\x18\x02 \x03(\x0b\x32&.payloads.proto.TxBulkQueryRequestBody\"=\n\x10RowResponseGroup\x12)\n\x04rows\x18\x01 \x03(\x0b\x32\x1b.payloads.proto.RowResponse\"u\n\x16TxQuerySuccessResponse\x12\x0f\n\x07ord_num\x18\x01 \x01(\x05\x12\x14\n\x0c\x63olumn_names\x18\x02 \x03(\t\x12\x34\n\nrow_groups\x18\x03 \x03(\x0b\x32 .payloads.proto.RowResponseGroup\"W\n\x1aTxBulkQuerySuccessResponse\x12\x39\n\tresponses\x18\x01 \x03(\x0b\x32&.payloads.proto.TxQuerySuccessResponse\"\x8f\x01\n\x13TxBulkQueryResponse\x12=\n\x07success\x18\x01 \x01(\x0b\x32*.payloads.proto.TxBulkQuerySuccessResponseH\x00\x12.\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x1d.payloads.proto.ErrorResponseH\x00\x42\t\n\x07payloadb\x06proto3') ) _sym_db.RegisterFileDescriptor(DESCRIPTOR) _ERRORRESPONSE_ERRORTYPE = _descriptor.EnumDescriptor( name='ErrorType', full_name='payloads.proto.ErrorResponse.ErrorType', filename=None, file=DESCRIPTOR, values=[ _descriptor.EnumValueDescriptor( name='CONNECTION_CONFIG_ERROR', index=0, number=0, options=None, type=None), _descriptor.EnumValueDescriptor( name='CREATE_POOL_ERROR', index=1, number=1, options=None, type=None), _descriptor.EnumValueDescriptor( name='FORBIDDEN_CONNECTION_ID', index=2, number=2, options=None, type=None), _descriptor.EnumValueDescriptor( name='MISSING_CONNECTION', index=3, number=3, options=None, type=None), _descriptor.EnumValueDescriptor( name='POOL_ERROR', index=4, number=4, options=None, type=None), _descriptor.EnumValueDescriptor( name='POSTGRES_ERROR', index=5, number=5, options=None, type=None), _descriptor.EnumValueDescriptor( name='STORAGE_ERROR', index=6, number=6, options=None, type=None), _descriptor.EnumValueDescriptor( name='WRONG_NUM_OF_PARAMS', index=7, number=7, options=None, type=None), _descriptor.EnumValueDescriptor( name='UNKNOWN_PG_VALUE_TYPE', index=8, number=8, options=None, type=None), ], containing_type=None, options=None, serialized_start=557, serialized_end=780, ) _sym_db.RegisterEnumDescriptor(_ERRORRESPONSE_ERRORTYPE) _VALUEWRAPPER = _descriptor.Descriptor( name='ValueWrapper', full_name='payloads.proto.ValueWrapper', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='string', full_name='payloads.proto.ValueWrapper.string', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='int8', full_name='payloads.proto.ValueWrapper.int8', index=1, number=2, type=3, cpp_type=2, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='int4', full_name='payloads.proto.ValueWrapper.int4', index=2, number=3, type=5, cpp_type=1, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='bytes', full_name='payloads.proto.ValueWrapper.bytes', index=3, number=4, type=12, cpp_type=9, label=1, has_default_value=False, default_value=_b(""), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ _descriptor.OneofDescriptor( name='value', full_name='payloads.proto.ValueWrapper.value', index=0, containing_type=None, fields=[]), ], serialized_start=38, serialized_end=128, ) _JSONOBJECTWRAPPER_BODYENTRY = _descriptor.Descriptor( name='BodyEntry', full_name='payloads.proto.JsonObjectWrapper.BodyEntry', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='key', full_name='payloads.proto.JsonObjectWrapper.BodyEntry.key', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='value', full_name='payloads.proto.JsonObjectWrapper.BodyEntry.value', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')), is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=211, serialized_end=284, ) _JSONOBJECTWRAPPER = _descriptor.Descriptor( name='JsonObjectWrapper', full_name='payloads.proto.JsonObjectWrapper', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='body', full_name='payloads.proto.JsonObjectWrapper.body', index=0, number=1, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[_JSONOBJECTWRAPPER_BODYENTRY, ], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=131, serialized_end=284, ) _ROWRESPONSE = _descriptor.Descriptor( name='RowResponse', full_name='payloads.proto.RowResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='values', full_name='payloads.proto.RowResponse.values', index=0, number=1, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=286, serialized_end=345, ) _QUERYSUCCESSRESPONSE = _descriptor.Descriptor( name='QuerySuccessResponse', full_name='payloads.proto.QuerySuccessResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='column_names', full_name='payloads.proto.QuerySuccessResponse.column_names', index=0, number=2, type=9, cpp_type=9, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='rows', full_name='payloads.proto.QuerySuccessResponse.rows', index=1, number=3, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=347, serialized_end=434, ) _ERRORRESPONSE = _descriptor.Descriptor( name='ErrorResponse', full_name='payloads.proto.ErrorResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='message', full_name='payloads.proto.ErrorResponse.message', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='correlation_id', full_name='payloads.proto.ErrorResponse.correlation_id', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='error_type', full_name='payloads.proto.ErrorResponse.error_type', index=2, number=3, type=14, cpp_type=8, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ _ERRORRESPONSE_ERRORTYPE, ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=437, serialized_end=780, ) _QUERYRESPONSE = _descriptor.Descriptor( name='QueryResponse', full_name='payloads.proto.QueryResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='success', full_name='payloads.proto.QueryResponse.success', index=0, number=1, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='error', full_name='payloads.proto.QueryResponse.error', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ _descriptor.OneofDescriptor( name='payload', full_name='payloads.proto.QueryResponse.payload', index=0, containing_type=None, fields=[]), ], serialized_start=783, serialized_end=914, ) _QUERYREQUEST = _descriptor.Descriptor( name='QueryRequest', full_name='payloads.proto.QueryRequest', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='connection_id', full_name='payloads.proto.QueryRequest.connection_id', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='query', full_name='payloads.proto.QueryRequest.query', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='params', full_name='payloads.proto.QueryRequest.params', index=2, number=3, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=916, serialized_end=1014, ) _TXBULKQUERYPARAMS = _descriptor.Descriptor( name='TxBulkQueryParams', full_name='payloads.proto.TxBulkQueryParams', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='values', full_name='payloads.proto.TxBulkQueryParams.values', index=0, number=1, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1016, serialized_end=1081, ) _TXBULKQUERYREQUESTBODY = _descriptor.Descriptor( name='TxBulkQueryRequestBody', full_name='payloads.proto.TxBulkQueryRequestBody', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='query', full_name='payloads.proto.TxBulkQueryRequestBody.query', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='params', full_name='payloads.proto.TxBulkQueryRequestBody.params', index=1, number=2, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1083, serialized_end=1173, ) _TXBULKQUERYREQUEST = _descriptor.Descriptor( name='TxBulkQueryRequest', full_name='payloads.proto.TxBulkQueryRequest', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='connection_id', full_name='payloads.proto.TxBulkQueryRequest.connection_id', index=0, number=1, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='queries', full_name='payloads.proto.TxBulkQueryRequest.queries', index=1, number=2, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1175, serialized_end=1275, ) _ROWRESPONSEGROUP = _descriptor.Descriptor( name='RowResponseGroup', full_name='payloads.proto.RowResponseGroup', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='rows', full_name='payloads.proto.RowResponseGroup.rows', index=0, number=1, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1277, serialized_end=1338, ) _TXQUERYSUCCESSRESPONSE = _descriptor.Descriptor( name='TxQuerySuccessResponse', full_name='payloads.proto.TxQuerySuccessResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='ord_num', full_name='payloads.proto.TxQuerySuccessResponse.ord_num', index=0, number=1, type=5, cpp_type=1, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='column_names', full_name='payloads.proto.TxQuerySuccessResponse.column_names', index=1, number=2, type=9, cpp_type=9, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='row_groups', full_name='payloads.proto.TxQuerySuccessResponse.row_groups', index=2, number=3, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1340, serialized_end=1457, ) _TXBULKQUERYSUCCESSRESPONSE = _descriptor.Descriptor( name='TxBulkQuerySuccessResponse', full_name='payloads.proto.TxBulkQuerySuccessResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='responses', full_name='payloads.proto.TxBulkQuerySuccessResponse.responses', index=0, number=1, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=1459, serialized_end=1546, ) _TXBULKQUERYRESPONSE = _descriptor.Descriptor( name='TxBulkQueryResponse', full_name='payloads.proto.TxBulkQueryResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='success', full_name='payloads.proto.TxBulkQueryResponse.success', index=0, number=1, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( name='error', full_name='payloads.proto.TxBulkQueryResponse.error', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), ], extensions=[ ], nested_types=[], enum_types=[ ], options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ _descriptor.OneofDescriptor( name='payload', full_name='payloads.proto.TxBulkQueryResponse.payload', index=0, containing_type=None, fields=[]), ], serialized_start=1549, serialized_end=1692, ) _VALUEWRAPPER.oneofs_by_name['value'].fields.append( _VALUEWRAPPER.fields_by_name['string']) _VALUEWRAPPER.fields_by_name['string'].containing_oneof = _VALUEWRAPPER.oneofs_by_name['value'] _VALUEWRAPPER.oneofs_by_name['value'].fields.append( _VALUEWRAPPER.fields_by_name['int8']) _VALUEWRAPPER.fields_by_name['int8'].containing_oneof = _VALUEWRAPPER.oneofs_by_name['value'] _VALUEWRAPPER.oneofs_by_name['value'].fields.append( _VALUEWRAPPER.fields_by_name['int4']) _VALUEWRAPPER.fields_by_name['int4'].containing_oneof = _VALUEWRAPPER.oneofs_by_name['value'] _VALUEWRAPPER.oneofs_by_name['value'].fields.append( _VALUEWRAPPER.fields_by_name['bytes']) _VALUEWRAPPER.fields_by_name['bytes'].containing_oneof = _VALUEWRAPPER.oneofs_by_name['value'] _JSONOBJECTWRAPPER_BODYENTRY.fields_by_name['value'].message_type = _VALUEWRAPPER _JSONOBJECTWRAPPER_BODYENTRY.containing_type = _JSONOBJECTWRAPPER _JSONOBJECTWRAPPER.fields_by_name['body'].message_type = _JSONOBJECTWRAPPER_BODYENTRY _ROWRESPONSE.fields_by_name['values'].message_type = _VALUEWRAPPER _QUERYSUCCESSRESPONSE.fields_by_name['rows'].message_type = _ROWRESPONSE _ERRORRESPONSE.fields_by_name['error_type'].enum_type = _ERRORRESPONSE_ERRORTYPE _ERRORRESPONSE_ERRORTYPE.containing_type = _ERRORRESPONSE _QUERYRESPONSE.fields_by_name['success'].message_type = _QUERYSUCCESSRESPONSE _QUERYRESPONSE.fields_by_name['error'].message_type = _ERRORRESPONSE _QUERYRESPONSE.oneofs_by_name['payload'].fields.append( _QUERYRESPONSE.fields_by_name['success']) _QUERYRESPONSE.fields_by_name['success'].containing_oneof = _QUERYRESPONSE.oneofs_by_name['payload'] _QUERYRESPONSE.oneofs_by_name['payload'].fields.append( _QUERYRESPONSE.fields_by_name['error']) _QUERYRESPONSE.fields_by_name['error'].containing_oneof = _QUERYRESPONSE.oneofs_by_name['payload'] _QUERYREQUEST.fields_by_name['params'].message_type = _VALUEWRAPPER _TXBULKQUERYPARAMS.fields_by_name['values'].message_type = _VALUEWRAPPER _TXBULKQUERYREQUESTBODY.fields_by_name['params'].message_type = _TXBULKQUERYPARAMS _TXBULKQUERYREQUEST.fields_by_name['queries'].message_type = _TXBULKQUERYREQUESTBODY _ROWRESPONSEGROUP.fields_by_name['rows'].message_type = _ROWRESPONSE _TXQUERYSUCCESSRESPONSE.fields_by_name['row_groups'].message_type = _ROWRESPONSEGROUP _TXBULKQUERYSUCCESSRESPONSE.fields_by_name['responses'].message_type = _TXQUERYSUCCESSRESPONSE _TXBULKQUERYRESPONSE.fields_by_name['success'].message_type = _TXBULKQUERYSUCCESSRESPONSE _TXBULKQUERYRESPONSE.fields_by_name['error'].message_type = _ERRORRESPONSE _TXBULKQUERYRESPONSE.oneofs_by_name['payload'].fields.append( _TXBULKQUERYRESPONSE.fields_by_name['success']) _TXBULKQUERYRESPONSE.fields_by_name['success'].containing_oneof = _TXBULKQUERYRESPONSE.oneofs_by_name['payload'] _TXBULKQUERYRESPONSE.oneofs_by_name['payload'].fields.append( _TXBULKQUERYRESPONSE.fields_by_name['error']) _TXBULKQUERYRESPONSE.fields_by_name['error'].containing_oneof = _TXBULKQUERYRESPONSE.oneofs_by_name['payload'] DESCRIPTOR.message_types_by_name['ValueWrapper'] = _VALUEWRAPPER DESCRIPTOR.message_types_by_name['JsonObjectWrapper'] = _JSONOBJECTWRAPPER DESCRIPTOR.message_types_by_name['RowResponse'] = _ROWRESPONSE DESCRIPTOR.message_types_by_name['QuerySuccessResponse'] = _QUERYSUCCESSRESPONSE DESCRIPTOR.message_types_by_name['ErrorResponse'] = _ERRORRESPONSE DESCRIPTOR.message_types_by_name['QueryResponse'] = _QUERYRESPONSE DESCRIPTOR.message_types_by_name['QueryRequest'] = _QUERYREQUEST DESCRIPTOR.message_types_by_name['TxBulkQueryParams'] = _TXBULKQUERYPARAMS DESCRIPTOR.message_types_by_name['TxBulkQueryRequestBody'] = _TXBULKQUERYREQUESTBODY DESCRIPTOR.message_types_by_name['TxBulkQueryRequest'] = _TXBULKQUERYREQUEST DESCRIPTOR.message_types_by_name['RowResponseGroup'] = _ROWRESPONSEGROUP DESCRIPTOR.message_types_by_name['TxQuerySuccessResponse'] = _TXQUERYSUCCESSRESPONSE DESCRIPTOR.message_types_by_name['TxBulkQuerySuccessResponse'] = _TXBULKQUERYSUCCESSRESPONSE DESCRIPTOR.message_types_by_name['TxBulkQueryResponse'] = _TXBULKQUERYRESPONSE ValueWrapper = _reflection.GeneratedProtocolMessageType('ValueWrapper', (_message.Message,), dict( DESCRIPTOR = _VALUEWRAPPER, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.ValueWrapper) )) _sym_db.RegisterMessage(ValueWrapper) JsonObjectWrapper = _reflection.GeneratedProtocolMessageType('JsonObjectWrapper', (_message.Message,), dict( BodyEntry = _reflection.GeneratedProtocolMessageType('BodyEntry', (_message.Message,), dict( DESCRIPTOR = _JSONOBJECTWRAPPER_BODYENTRY, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.JsonObjectWrapper.BodyEntry) )) , DESCRIPTOR = _JSONOBJECTWRAPPER, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.JsonObjectWrapper) )) _sym_db.RegisterMessage(JsonObjectWrapper) _sym_db.RegisterMessage(JsonObjectWrapper.BodyEntry) RowResponse = _reflection.GeneratedProtocolMessageType('RowResponse', (_message.Message,), dict( DESCRIPTOR = _ROWRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.RowResponse) )) _sym_db.RegisterMessage(RowResponse) QuerySuccessResponse = _reflection.GeneratedProtocolMessageType('QuerySuccessResponse', (_message.Message,), dict( DESCRIPTOR = _QUERYSUCCESSRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.QuerySuccessResponse) )) _sym_db.RegisterMessage(QuerySuccessResponse) ErrorResponse = _reflection.GeneratedProtocolMessageType('ErrorResponse', (_message.Message,), dict( DESCRIPTOR = _ERRORRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.ErrorResponse) )) _sym_db.RegisterMessage(ErrorResponse) QueryResponse = _reflection.GeneratedProtocolMessageType('QueryResponse', (_message.Message,), dict( DESCRIPTOR = _QUERYRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.QueryResponse) )) _sym_db.RegisterMessage(QueryResponse) QueryRequest = _reflection.GeneratedProtocolMessageType('QueryRequest', (_message.Message,), dict( DESCRIPTOR = _QUERYREQUEST, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.QueryRequest) )) _sym_db.RegisterMessage(QueryRequest) TxBulkQueryParams = _reflection.GeneratedProtocolMessageType('TxBulkQueryParams', (_message.Message,), dict( DESCRIPTOR = _TXBULKQUERYPARAMS, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxBulkQueryParams) )) _sym_db.RegisterMessage(TxBulkQueryParams) TxBulkQueryRequestBody = _reflection.GeneratedProtocolMessageType('TxBulkQueryRequestBody', (_message.Message,), dict( DESCRIPTOR = _TXBULKQUERYREQUESTBODY, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxBulkQueryRequestBody) )) _sym_db.RegisterMessage(TxBulkQueryRequestBody) TxBulkQueryRequest = _reflection.GeneratedProtocolMessageType('TxBulkQueryRequest', (_message.Message,), dict( DESCRIPTOR = _TXBULKQUERYREQUEST, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxBulkQueryRequest) )) _sym_db.RegisterMessage(TxBulkQueryRequest) RowResponseGroup = _reflection.GeneratedProtocolMessageType('RowResponseGroup', (_message.Message,), dict( DESCRIPTOR = _ROWRESPONSEGROUP, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.RowResponseGroup) )) _sym_db.RegisterMessage(RowResponseGroup) TxQuerySuccessResponse = _reflection.GeneratedProtocolMessageType('TxQuerySuccessResponse', (_message.Message,), dict( DESCRIPTOR = _TXQUERYSUCCESSRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxQuerySuccessResponse) )) _sym_db.RegisterMessage(TxQuerySuccessResponse) TxBulkQuerySuccessResponse = _reflection.GeneratedProtocolMessageType('TxBulkQuerySuccessResponse', (_message.Message,), dict( DESCRIPTOR = _TXBULKQUERYSUCCESSRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxBulkQuerySuccessResponse) )) _sym_db.RegisterMessage(TxBulkQuerySuccessResponse) TxBulkQueryResponse = _reflection.GeneratedProtocolMessageType('TxBulkQueryResponse', (_message.Message,), dict( DESCRIPTOR = _TXBULKQUERYRESPONSE, __module__ = 'src.payloads_pb2' # @@protoc_insertion_point(class_scope:payloads.proto.TxBulkQueryResponse) )) _sym_db.RegisterMessage(TxBulkQueryResponse) _JSONOBJECTWRAPPER_BODYENTRY.has_options = True _JSONOBJECTWRAPPER_BODYENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')) # @@protoc_insertion_point(module_scope)