ClickHouse/utils/grpc-client/pb2/clickhouse_grpc_pb2.py

# -*- 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)