# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: clickhouse_grpc.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import message as _message from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x63lickhouse_grpc.proto\x12\x0f\x63lickhouse.grpc\")\n\x0bNameAndType\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\"\xf5\x01\n\rExternalTable\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07\x63olumns\x18\x02 \x03(\x0b\x32\x1c.clickhouse.grpc.NameAndType\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\x12\x0e\n\x06\x66ormat\x18\x04 \x01(\t\x12\x18\n\x10\x63ompression_type\x18\x06 \x01(\t\x12>\n\x08settings\x18\x05 \x03(\x0b\x32,.clickhouse.grpc.ExternalTable.SettingsEntry\x1a/\n\rSettingsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x85\x03\n\x1cObsoleteTransportCompression\x12U\n\talgorithm\x18\x01 \x01(\x0e\x32\x42.clickhouse.grpc.ObsoleteTransportCompression.CompressionAlgorithm\x12M\n\x05level\x18\x02 \x01(\x0e\x32>.clickhouse.grpc.ObsoleteTransportCompression.CompressionLevel\"R\n\x14\x43ompressionAlgorithm\x12\x12\n\x0eNO_COMPRESSION\x10\x00\x12\x0b\n\x07\x44\x45\x46LATE\x10\x01\x12\x08\n\x04GZIP\x10\x02\x12\x0f\n\x0bSTREAM_GZIP\x10\x03\"k\n\x10\x43ompressionLevel\x12\x14\n\x10\x43OMPRESSION_NONE\x10\x00\x12\x13\n\x0f\x43OMPRESSION_LOW\x10\x01\x12\x16\n\x12\x43OMPRESSION_MEDIUM\x10\x02\x12\x14\n\x10\x43OMPRESSION_HIGH\x10\x03\"\x8e\x06\n\tQueryInfo\x12\r\n\x05query\x18\x01 \x01(\t\x12\x10\n\x08query_id\x18\x02 \x01(\t\x12:\n\x08settings\x18\x03 \x03(\x0b\x32(.clickhouse.grpc.QueryInfo.SettingsEntry\x12\x10\n\x08\x64\x61tabase\x18\x04 \x01(\t\x12\x12\n\ninput_data\x18\x05 \x01(\x0c\x12\x1c\n\x14input_data_delimiter\x18\x06 \x01(\x0c\x12\x15\n\routput_format\x18\x07 \x01(\t\x12\x1b\n\x13send_output_columns\x18\x18 \x01(\x08\x12\x37\n\x0f\x65xternal_tables\x18\x08 \x03(\x0b\x32\x1e.clickhouse.grpc.ExternalTable\x12\x11\n\tuser_name\x18\t \x01(\t\x12\x10\n\x08password\x18\n \x01(\t\x12\r\n\x05quota\x18\x0b \x01(\t\x12\x12\n\nsession_id\x18\x0c \x01(\t\x12\x15\n\rsession_check\x18\r \x01(\x08\x12\x17\n\x0fsession_timeout\x18\x0e \x01(\r\x12\x0e\n\x06\x63\x61ncel\x18\x0f \x01(\x08\x12\x17\n\x0fnext_query_info\x18\x10 \x01(\x08\x12\x1e\n\x16input_compression_type\x18\x14 \x01(\t\x12\x1f\n\x17output_compression_type\x18\x15 \x01(\t\x12 \n\x18output_compression_level\x18\x13 \x01(\x05\x12\"\n\x1atransport_compression_type\x18\x16 \x01(\t\x12#\n\x1btransport_compression_level\x18\x17 \x01(\x05\x12R\n\x1bobsolete_result_compression\x18\x11 \x01(\x0b\x32-.clickhouse.grpc.ObsoleteTransportCompression\x12!\n\x19obsolete_compression_type\x18\x12 \x01(\t\x1a/\n\rSettingsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xa1\x01\n\x08LogEntry\x12\x0c\n\x04time\x18\x01 \x01(\r\x12\x19\n\x11time_microseconds\x18\x02 \x01(\r\x12\x11\n\tthread_id\x18\x03 \x01(\x04\x12\x10\n\x08query_id\x18\x04 \x01(\t\x12)\n\x05level\x18\x05 \x01(\x0e\x32\x1a.clickhouse.grpc.LogsLevel\x12\x0e\n\x06source\x18\x06 \x01(\t\x12\x0c\n\x04text\x18\x07 \x01(\t\"z\n\x08Progress\x12\x11\n\tread_rows\x18\x01 \x01(\x04\x12\x12\n\nread_bytes\x18\x02 \x01(\x04\x12\x1a\n\x12total_rows_to_read\x18\x03 \x01(\x04\x12\x14\n\x0cwritten_rows\x18\x04 \x01(\x04\x12\x15\n\rwritten_bytes\x18\x05 \x01(\x04\"p\n\x05Stats\x12\x0c\n\x04rows\x18\x01 \x01(\x04\x12\x0e\n\x06\x62locks\x18\x02 \x01(\x04\x12\x17\n\x0f\x61llocated_bytes\x18\x03 \x01(\x04\x12\x15\n\rapplied_limit\x18\x04 \x01(\x08\x12\x19\n\x11rows_before_limit\x18\x05 \x01(\x04\"R\n\tException\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x14\n\x0c\x64isplay_text\x18\x03 \x01(\t\x12\x13\n\x0bstack_trace\x18\x04 \x01(\t\"\xeb\x02\n\x06Result\x12\x10\n\x08query_id\x18\t \x01(\t\x12\x11\n\ttime_zone\x18\n \x01(\t\x12\x15\n\routput_format\x18\x0b \x01(\t\x12\x34\n\x0eoutput_columns\x18\x0c \x03(\x0b\x32\x1c.clickhouse.grpc.NameAndType\x12\x0e\n\x06output\x18\x01 \x01(\x0c\x12\x0e\n\x06totals\x18\x02 \x01(\x0c\x12\x10\n\x08\x65xtremes\x18\x03 \x01(\x0c\x12\'\n\x04logs\x18\x04 \x03(\x0b\x32\x19.clickhouse.grpc.LogEntry\x12+\n\x08progress\x18\x05 \x01(\x0b\x32\x19.clickhouse.grpc.Progress\x12%\n\x05stats\x18\x06 \x01(\x0b\x32\x16.clickhouse.grpc.Stats\x12-\n\texception\x18\x07 \x01(\x0b\x32\x1a.clickhouse.grpc.Exception\x12\x11\n\tcancelled\x18\x08 \x01(\x08*\x9d\x01\n\tLogsLevel\x12\x0c\n\x08LOG_NONE\x10\x00\x12\r\n\tLOG_FATAL\x10\x01\x12\x10\n\x0cLOG_CRITICAL\x10\x02\x12\r\n\tLOG_ERROR\x10\x03\x12\x0f\n\x0bLOG_WARNING\x10\x04\x12\x0e\n\nLOG_NOTICE\x10\x05\x12\x13\n\x0fLOG_INFORMATION\x10\x06\x12\r\n\tLOG_DEBUG\x10\x07\x12\r\n\tLOG_TRACE\x10\x08\x32\xdb\x02\n\nClickHouse\x12\x45\n\x0c\x45xecuteQuery\x12\x1a.clickhouse.grpc.QueryInfo\x1a\x17.clickhouse.grpc.Result\"\x00\x12V\n\x1b\x45xecuteQueryWithStreamInput\x12\x1a.clickhouse.grpc.QueryInfo\x1a\x17.clickhouse.grpc.Result\"\x00(\x01\x12W\n\x1c\x45xecuteQueryWithStreamOutput\x12\x1a.clickhouse.grpc.QueryInfo\x1a\x17.clickhouse.grpc.Result\"\x00\x30\x01\x12U\n\x18\x45xecuteQueryWithStreamIO\x12\x1a.clickhouse.grpc.QueryInfo\x1a\x17.clickhouse.grpc.Result\"\x00(\x01\x30\x01\x62\x06proto3') _LOGSLEVEL = DESCRIPTOR.enum_types_by_name['LogsLevel'] LogsLevel = enum_type_wrapper.EnumTypeWrapper(_LOGSLEVEL) LOG_NONE = 0 LOG_FATAL = 1 LOG_CRITICAL = 2 LOG_ERROR = 3 LOG_WARNING = 4 LOG_NOTICE = 5 LOG_INFORMATION = 6 LOG_DEBUG = 7 LOG_TRACE = 8 _NAMEANDTYPE = DESCRIPTOR.message_types_by_name['NameAndType'] _EXTERNALTABLE = DESCRIPTOR.message_types_by_name['ExternalTable'] _EXTERNALTABLE_SETTINGSENTRY = _EXTERNALTABLE.nested_types_by_name['SettingsEntry'] _OBSOLETETRANSPORTCOMPRESSION = DESCRIPTOR.message_types_by_name['ObsoleteTransportCompression'] _QUERYINFO = DESCRIPTOR.message_types_by_name['QueryInfo'] _QUERYINFO_SETTINGSENTRY = _QUERYINFO.nested_types_by_name['SettingsEntry'] _LOGENTRY = DESCRIPTOR.message_types_by_name['LogEntry'] _PROGRESS = DESCRIPTOR.message_types_by_name['Progress'] _STATS = DESCRIPTOR.message_types_by_name['Stats'] _EXCEPTION = DESCRIPTOR.message_types_by_name['Exception'] _RESULT = DESCRIPTOR.message_types_by_name['Result'] _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONALGORITHM = _OBSOLETETRANSPORTCOMPRESSION.enum_types_by_name['CompressionAlgorithm'] _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONLEVEL = _OBSOLETETRANSPORTCOMPRESSION.enum_types_by_name['CompressionLevel'] NameAndType = _reflection.GeneratedProtocolMessageType('NameAndType', (_message.Message,), { 'DESCRIPTOR' : _NAMEANDTYPE, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.NameAndType) }) _sym_db.RegisterMessage(NameAndType) ExternalTable = _reflection.GeneratedProtocolMessageType('ExternalTable', (_message.Message,), { 'SettingsEntry' : _reflection.GeneratedProtocolMessageType('SettingsEntry', (_message.Message,), { 'DESCRIPTOR' : _EXTERNALTABLE_SETTINGSENTRY, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.ExternalTable.SettingsEntry) }) , 'DESCRIPTOR' : _EXTERNALTABLE, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.ExternalTable) }) _sym_db.RegisterMessage(ExternalTable) _sym_db.RegisterMessage(ExternalTable.SettingsEntry) ObsoleteTransportCompression = _reflection.GeneratedProtocolMessageType('ObsoleteTransportCompression', (_message.Message,), { 'DESCRIPTOR' : _OBSOLETETRANSPORTCOMPRESSION, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.ObsoleteTransportCompression) }) _sym_db.RegisterMessage(ObsoleteTransportCompression) QueryInfo = _reflection.GeneratedProtocolMessageType('QueryInfo', (_message.Message,), { 'SettingsEntry' : _reflection.GeneratedProtocolMessageType('SettingsEntry', (_message.Message,), { 'DESCRIPTOR' : _QUERYINFO_SETTINGSENTRY, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.QueryInfo.SettingsEntry) }) , 'DESCRIPTOR' : _QUERYINFO, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.QueryInfo) }) _sym_db.RegisterMessage(QueryInfo) _sym_db.RegisterMessage(QueryInfo.SettingsEntry) LogEntry = _reflection.GeneratedProtocolMessageType('LogEntry', (_message.Message,), { 'DESCRIPTOR' : _LOGENTRY, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.LogEntry) }) _sym_db.RegisterMessage(LogEntry) Progress = _reflection.GeneratedProtocolMessageType('Progress', (_message.Message,), { 'DESCRIPTOR' : _PROGRESS, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.Progress) }) _sym_db.RegisterMessage(Progress) Stats = _reflection.GeneratedProtocolMessageType('Stats', (_message.Message,), { 'DESCRIPTOR' : _STATS, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.Stats) }) _sym_db.RegisterMessage(Stats) Exception = _reflection.GeneratedProtocolMessageType('Exception', (_message.Message,), { 'DESCRIPTOR' : _EXCEPTION, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.Exception) }) _sym_db.RegisterMessage(Exception) Result = _reflection.GeneratedProtocolMessageType('Result', (_message.Message,), { 'DESCRIPTOR' : _RESULT, '__module__' : 'clickhouse_grpc_pb2' # @@protoc_insertion_point(class_scope:clickhouse.grpc.Result) }) _sym_db.RegisterMessage(Result) _CLICKHOUSE = DESCRIPTOR.services_by_name['ClickHouse'] if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _EXTERNALTABLE_SETTINGSENTRY._options = None _EXTERNALTABLE_SETTINGSENTRY._serialized_options = b'8\001' _QUERYINFO_SETTINGSENTRY._options = None _QUERYINFO_SETTINGSENTRY._serialized_options = b'8\001' _LOGSLEVEL._serialized_start=2363 _LOGSLEVEL._serialized_end=2520 _NAMEANDTYPE._serialized_start=42 _NAMEANDTYPE._serialized_end=83 _EXTERNALTABLE._serialized_start=86 _EXTERNALTABLE._serialized_end=331 _EXTERNALTABLE_SETTINGSENTRY._serialized_start=284 _EXTERNALTABLE_SETTINGSENTRY._serialized_end=331 _OBSOLETETRANSPORTCOMPRESSION._serialized_start=334 _OBSOLETETRANSPORTCOMPRESSION._serialized_end=723 _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONALGORITHM._serialized_start=532 _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONALGORITHM._serialized_end=614 _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONLEVEL._serialized_start=616 _OBSOLETETRANSPORTCOMPRESSION_COMPRESSIONLEVEL._serialized_end=723 _QUERYINFO._serialized_start=726 _QUERYINFO._serialized_end=1508 _QUERYINFO_SETTINGSENTRY._serialized_start=284 _QUERYINFO_SETTINGSENTRY._serialized_end=331 _LOGENTRY._serialized_start=1511 _LOGENTRY._serialized_end=1672 _PROGRESS._serialized_start=1674 _PROGRESS._serialized_end=1796 _STATS._serialized_start=1798 _STATS._serialized_end=1910 _EXCEPTION._serialized_start=1912 _EXCEPTION._serialized_end=1994 _RESULT._serialized_start=1997 _RESULT._serialized_end=2360 _CLICKHOUSE._serialized_start=2523 _CLICKHOUSE._serialized_end=2870 # @@protoc_insertion_point(module_scope)