diff --git a/v2_examples/destination/python/sdk_pb2/common_pb2.py b/v2_examples/destination/python/sdk_pb2/common_pb2.py deleted file mode 100644 index e11376d..0000000 --- a/v2_examples/destination/python/sdk_pb2/common_pb2.py +++ /dev/null @@ -1,66 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: common.proto -# Protobuf Python Version: 4.25.0 -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0c\x63ommon.proto\x12\x0c\x66ivetran_sdk\x1a\x1fgoogle/protobuf/timestamp.proto\"\x1a\n\x18\x43onfigurationFormRequest\"\xbb\x01\n\x19\x43onfigurationFormResponse\x12\"\n\x1aschema_selection_supported\x18\x01 \x01(\x08\x12!\n\x19table_selection_supported\x18\x02 \x01(\x08\x12\'\n\x06\x66ields\x18\x03 \x03(\x0b\x32\x17.fivetran_sdk.FormField\x12.\n\x05tests\x18\x04 \x03(\x0b\x32\x1f.fivetran_sdk.ConfigurationTest\"\x85\x02\n\tFormField\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05label\x18\x02 \x01(\t\x12\x10\n\x08required\x18\x03 \x01(\x08\x12\x18\n\x0b\x64\x65scription\x18\x04 \x01(\tH\x01\x88\x01\x01\x12-\n\ntext_field\x18\x05 \x01(\x0e\x32\x17.fivetran_sdk.TextFieldH\x00\x12\x35\n\x0e\x64ropdown_field\x18\x06 \x01(\x0b\x32\x1b.fivetran_sdk.DropdownFieldH\x00\x12\x31\n\x0ctoggle_field\x18\x07 \x01(\x0b\x32\x19.fivetran_sdk.ToggleFieldH\x00\x42\x06\n\x04typeB\x0e\n\x0c_description\"\'\n\rDropdownField\x12\x16\n\x0e\x64ropdown_field\x18\x01 \x03(\t\"\r\n\x0bToggleField\"0\n\x11\x43onfigurationTest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05label\x18\x02 \x01(\t\"\x96\x01\n\x0bTestRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x43\n\rconfiguration\x18\x02 \x03(\x0b\x32,.fivetran_sdk.TestRequest.ConfigurationEntry\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"@\n\x0cTestResponse\x12\x11\n\x07success\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x42\n\n\x08response\"3\n\nSchemaList\x12%\n\x07schemas\x18\x01 \x03(\x0b\x32\x14.fivetran_sdk.Schema\"0\n\tTableList\x12#\n\x06tables\x18\x01 \x03(\x0b\x32\x13.fivetran_sdk.Table\";\n\x06Schema\x12\x0c\n\x04name\x18\x01 \x01(\t\x12#\n\x06tables\x18\x02 \x03(\x0b\x32\x13.fivetran_sdk.Table\"1\n\rDecimalParams\x12\x11\n\tprecision\x18\x01 \x01(\r\x12\r\n\x05scale\x18\x02 \x01(\r\"\xf9\x02\n\tValueType\x12\x0e\n\x04null\x18\x01 \x01(\x08H\x00\x12\x0e\n\x04\x62ool\x18\x02 \x01(\x08H\x00\x12\x0f\n\x05short\x18\x03 \x01(\x05H\x00\x12\r\n\x03int\x18\x04 \x01(\x05H\x00\x12\x0e\n\x04long\x18\x05 \x01(\x03H\x00\x12\x0f\n\x05\x66loat\x18\x06 \x01(\x02H\x00\x12\x10\n\x06\x64ouble\x18\x07 \x01(\x01H\x00\x12\x30\n\nnaive_date\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x12\x34\n\x0enaive_datetime\x18\t \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x12\x32\n\x0cutc_datetime\x18\n \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x12\x11\n\x07\x64\x65\x63imal\x18\x0b \x01(\tH\x00\x12\x10\n\x06\x62inary\x18\x0c \x01(\x0cH\x00\x12\x10\n\x06string\x18\r \x01(\tH\x00\x12\x0e\n\x04json\x18\x0e \x01(\tH\x00\x12\r\n\x03xml\x18\x0f \x01(\tH\x00\x42\x07\n\x05inner\"<\n\x05Table\x12\x0c\n\x04name\x18\x01 \x01(\t\x12%\n\x07\x63olumns\x18\x02 \x03(\x0b\x32\x14.fivetran_sdk.Column\"\x90\x01\n\x06\x43olumn\x12\x0c\n\x04name\x18\x01 \x01(\t\x12$\n\x04type\x18\x02 \x01(\x0e\x32\x16.fivetran_sdk.DataType\x12\x13\n\x0bprimary_key\x18\x03 \x01(\x08\x12\x31\n\x07\x64\x65\x63imal\x18\x04 \x01(\x0b\x32\x1b.fivetran_sdk.DecimalParamsH\x00\x88\x01\x01\x42\n\n\x08_decimal*4\n\tTextField\x12\r\n\tPlainText\x10\x00\x12\x0c\n\x08Password\x10\x01\x12\n\n\x06Hidden\x10\x02*\xcb\x01\n\x08\x44\x61taType\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\x0b\n\x07\x42OOLEAN\x10\x01\x12\t\n\x05SHORT\x10\x02\x12\x07\n\x03INT\x10\x03\x12\x08\n\x04LONG\x10\x04\x12\x0b\n\x07\x44\x45\x43IMAL\x10\x05\x12\t\n\x05\x46LOAT\x10\x06\x12\n\n\x06\x44OUBLE\x10\x07\x12\x0e\n\nNAIVE_DATE\x10\x08\x12\x12\n\x0eNAIVE_DATETIME\x10\t\x12\x10\n\x0cUTC_DATETIME\x10\n\x12\n\n\x06\x42INARY\x10\x0b\x12\x07\n\x03XML\x10\x0c\x12\n\n\x06STRING\x10\r\x12\x08\n\x04JSON\x10\x0e*:\n\x06OpType\x12\n\n\x06UPSERT\x10\x00\x12\n\n\x06UPDATE\x10\x01\x12\n\n\x06\x44\x45LETE\x10\x02\x12\x0c\n\x08TRUNCATE\x10\x03\x42\x1fH\x01P\x01Z\x19\x66ivetran.com/fivetran_sdkb\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'common_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None - _globals['DESCRIPTOR']._serialized_options = b'H\001P\001Z\031fivetran.com/fivetran_sdk' - _globals['_TESTREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_TESTREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_TEXTFIELD']._serialized_start=1674 - _globals['_TEXTFIELD']._serialized_end=1726 - _globals['_DATATYPE']._serialized_start=1729 - _globals['_DATATYPE']._serialized_end=1932 - _globals['_OPTYPE']._serialized_start=1934 - _globals['_OPTYPE']._serialized_end=1992 - _globals['_CONFIGURATIONFORMREQUEST']._serialized_start=63 - _globals['_CONFIGURATIONFORMREQUEST']._serialized_end=89 - _globals['_CONFIGURATIONFORMRESPONSE']._serialized_start=92 - _globals['_CONFIGURATIONFORMRESPONSE']._serialized_end=279 - _globals['_FORMFIELD']._serialized_start=282 - _globals['_FORMFIELD']._serialized_end=543 - _globals['_DROPDOWNFIELD']._serialized_start=545 - _globals['_DROPDOWNFIELD']._serialized_end=584 - _globals['_TOGGLEFIELD']._serialized_start=586 - _globals['_TOGGLEFIELD']._serialized_end=599 - _globals['_CONFIGURATIONTEST']._serialized_start=601 - _globals['_CONFIGURATIONTEST']._serialized_end=649 - _globals['_TESTREQUEST']._serialized_start=652 - _globals['_TESTREQUEST']._serialized_end=802 - _globals['_TESTREQUEST_CONFIGURATIONENTRY']._serialized_start=750 - _globals['_TESTREQUEST_CONFIGURATIONENTRY']._serialized_end=802 - _globals['_TESTRESPONSE']._serialized_start=804 - _globals['_TESTRESPONSE']._serialized_end=868 - _globals['_SCHEMALIST']._serialized_start=870 - _globals['_SCHEMALIST']._serialized_end=921 - _globals['_TABLELIST']._serialized_start=923 - _globals['_TABLELIST']._serialized_end=971 - _globals['_SCHEMA']._serialized_start=973 - _globals['_SCHEMA']._serialized_end=1032 - _globals['_DECIMALPARAMS']._serialized_start=1034 - _globals['_DECIMALPARAMS']._serialized_end=1083 - _globals['_VALUETYPE']._serialized_start=1086 - _globals['_VALUETYPE']._serialized_end=1463 - _globals['_TABLE']._serialized_start=1465 - _globals['_TABLE']._serialized_end=1525 - _globals['_COLUMN']._serialized_start=1528 - _globals['_COLUMN']._serialized_end=1672 -# @@protoc_insertion_point(module_scope) diff --git a/v2_examples/destination/python/sdk_pb2/common_pb2.pyi b/v2_examples/destination/python/sdk_pb2/common_pb2.pyi deleted file mode 100644 index f8cba9c..0000000 --- a/v2_examples/destination/python/sdk_pb2/common_pb2.pyi +++ /dev/null @@ -1,218 +0,0 @@ -from google.protobuf import timestamp_pb2 as _timestamp_pb2 -from google.protobuf.internal import containers as _containers -from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper -from google.protobuf import descriptor as _descriptor -from google.protobuf import message as _message -from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union - -DESCRIPTOR: _descriptor.FileDescriptor - -class TextField(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - PlainText: _ClassVar[TextField] - Password: _ClassVar[TextField] - Hidden: _ClassVar[TextField] - -class DataType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - UNSPECIFIED: _ClassVar[DataType] - BOOLEAN: _ClassVar[DataType] - SHORT: _ClassVar[DataType] - INT: _ClassVar[DataType] - LONG: _ClassVar[DataType] - DECIMAL: _ClassVar[DataType] - FLOAT: _ClassVar[DataType] - DOUBLE: _ClassVar[DataType] - NAIVE_DATE: _ClassVar[DataType] - NAIVE_DATETIME: _ClassVar[DataType] - UTC_DATETIME: _ClassVar[DataType] - BINARY: _ClassVar[DataType] - XML: _ClassVar[DataType] - STRING: _ClassVar[DataType] - JSON: _ClassVar[DataType] - -class OpType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - UPSERT: _ClassVar[OpType] - UPDATE: _ClassVar[OpType] - DELETE: _ClassVar[OpType] - TRUNCATE: _ClassVar[OpType] -PlainText: TextField -Password: TextField -Hidden: TextField -UNSPECIFIED: DataType -BOOLEAN: DataType -SHORT: DataType -INT: DataType -LONG: DataType -DECIMAL: DataType -FLOAT: DataType -DOUBLE: DataType -NAIVE_DATE: DataType -NAIVE_DATETIME: DataType -UTC_DATETIME: DataType -BINARY: DataType -XML: DataType -STRING: DataType -JSON: DataType -UPSERT: OpType -UPDATE: OpType -DELETE: OpType -TRUNCATE: OpType - -class ConfigurationFormRequest(_message.Message): - __slots__ = () - def __init__(self) -> None: ... - -class ConfigurationFormResponse(_message.Message): - __slots__ = ("schema_selection_supported", "table_selection_supported", "fields", "tests") - SCHEMA_SELECTION_SUPPORTED_FIELD_NUMBER: _ClassVar[int] - TABLE_SELECTION_SUPPORTED_FIELD_NUMBER: _ClassVar[int] - FIELDS_FIELD_NUMBER: _ClassVar[int] - TESTS_FIELD_NUMBER: _ClassVar[int] - schema_selection_supported: bool - table_selection_supported: bool - fields: _containers.RepeatedCompositeFieldContainer[FormField] - tests: _containers.RepeatedCompositeFieldContainer[ConfigurationTest] - def __init__(self, schema_selection_supported: bool = ..., table_selection_supported: bool = ..., fields: _Optional[_Iterable[_Union[FormField, _Mapping]]] = ..., tests: _Optional[_Iterable[_Union[ConfigurationTest, _Mapping]]] = ...) -> None: ... - -class FormField(_message.Message): - __slots__ = ("name", "label", "required", "description", "text_field", "dropdown_field", "toggle_field") - NAME_FIELD_NUMBER: _ClassVar[int] - LABEL_FIELD_NUMBER: _ClassVar[int] - REQUIRED_FIELD_NUMBER: _ClassVar[int] - DESCRIPTION_FIELD_NUMBER: _ClassVar[int] - TEXT_FIELD_FIELD_NUMBER: _ClassVar[int] - DROPDOWN_FIELD_FIELD_NUMBER: _ClassVar[int] - TOGGLE_FIELD_FIELD_NUMBER: _ClassVar[int] - name: str - label: str - required: bool - description: str - text_field: TextField - dropdown_field: DropdownField - toggle_field: ToggleField - def __init__(self, name: _Optional[str] = ..., label: _Optional[str] = ..., required: bool = ..., description: _Optional[str] = ..., text_field: _Optional[_Union[TextField, str]] = ..., dropdown_field: _Optional[_Union[DropdownField, _Mapping]] = ..., toggle_field: _Optional[_Union[ToggleField, _Mapping]] = ...) -> None: ... - -class DropdownField(_message.Message): - __slots__ = ("dropdown_field",) - DROPDOWN_FIELD_FIELD_NUMBER: _ClassVar[int] - dropdown_field: _containers.RepeatedScalarFieldContainer[str] - def __init__(self, dropdown_field: _Optional[_Iterable[str]] = ...) -> None: ... - -class ToggleField(_message.Message): - __slots__ = () - def __init__(self) -> None: ... - -class ConfigurationTest(_message.Message): - __slots__ = ("name", "label") - NAME_FIELD_NUMBER: _ClassVar[int] - LABEL_FIELD_NUMBER: _ClassVar[int] - name: str - label: str - def __init__(self, name: _Optional[str] = ..., label: _Optional[str] = ...) -> None: ... - -class TestRequest(_message.Message): - __slots__ = ("name", "configuration") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - NAME_FIELD_NUMBER: _ClassVar[int] - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - name: str - configuration: _containers.ScalarMap[str, str] - def __init__(self, name: _Optional[str] = ..., configuration: _Optional[_Mapping[str, str]] = ...) -> None: ... - -class TestResponse(_message.Message): - __slots__ = ("success", "failure") - SUCCESS_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - success: bool - failure: str - def __init__(self, success: bool = ..., failure: _Optional[str] = ...) -> None: ... - -class SchemaList(_message.Message): - __slots__ = ("schemas",) - SCHEMAS_FIELD_NUMBER: _ClassVar[int] - schemas: _containers.RepeatedCompositeFieldContainer[Schema] - def __init__(self, schemas: _Optional[_Iterable[_Union[Schema, _Mapping]]] = ...) -> None: ... - -class TableList(_message.Message): - __slots__ = ("tables",) - TABLES_FIELD_NUMBER: _ClassVar[int] - tables: _containers.RepeatedCompositeFieldContainer[Table] - def __init__(self, tables: _Optional[_Iterable[_Union[Table, _Mapping]]] = ...) -> None: ... - -class Schema(_message.Message): - __slots__ = ("name", "tables") - NAME_FIELD_NUMBER: _ClassVar[int] - TABLES_FIELD_NUMBER: _ClassVar[int] - name: str - tables: _containers.RepeatedCompositeFieldContainer[Table] - def __init__(self, name: _Optional[str] = ..., tables: _Optional[_Iterable[_Union[Table, _Mapping]]] = ...) -> None: ... - -class DecimalParams(_message.Message): - __slots__ = ("precision", "scale") - PRECISION_FIELD_NUMBER: _ClassVar[int] - SCALE_FIELD_NUMBER: _ClassVar[int] - precision: int - scale: int - def __init__(self, precision: _Optional[int] = ..., scale: _Optional[int] = ...) -> None: ... - -class ValueType(_message.Message): - __slots__ = ("null", "bool", "short", "int", "long", "float", "double", "naive_date", "naive_datetime", "utc_datetime", "decimal", "binary", "string", "json", "xml") - NULL_FIELD_NUMBER: _ClassVar[int] - BOOL_FIELD_NUMBER: _ClassVar[int] - SHORT_FIELD_NUMBER: _ClassVar[int] - INT_FIELD_NUMBER: _ClassVar[int] - LONG_FIELD_NUMBER: _ClassVar[int] - FLOAT_FIELD_NUMBER: _ClassVar[int] - DOUBLE_FIELD_NUMBER: _ClassVar[int] - NAIVE_DATE_FIELD_NUMBER: _ClassVar[int] - NAIVE_DATETIME_FIELD_NUMBER: _ClassVar[int] - UTC_DATETIME_FIELD_NUMBER: _ClassVar[int] - DECIMAL_FIELD_NUMBER: _ClassVar[int] - BINARY_FIELD_NUMBER: _ClassVar[int] - STRING_FIELD_NUMBER: _ClassVar[int] - JSON_FIELD_NUMBER: _ClassVar[int] - XML_FIELD_NUMBER: _ClassVar[int] - null: bool - bool: bool - short: int - int: int - long: int - float: float - double: float - naive_date: _timestamp_pb2.Timestamp - naive_datetime: _timestamp_pb2.Timestamp - utc_datetime: _timestamp_pb2.Timestamp - decimal: str - binary: bytes - string: str - json: str - xml: str - def __init__(self, null: bool = ..., bool: bool = ..., short: _Optional[int] = ..., int: _Optional[int] = ..., long: _Optional[int] = ..., float: _Optional[float] = ..., double: _Optional[float] = ..., naive_date: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., naive_datetime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., utc_datetime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., decimal: _Optional[str] = ..., binary: _Optional[bytes] = ..., string: _Optional[str] = ..., json: _Optional[str] = ..., xml: _Optional[str] = ...) -> None: ... - -class Table(_message.Message): - __slots__ = ("name", "columns") - NAME_FIELD_NUMBER: _ClassVar[int] - COLUMNS_FIELD_NUMBER: _ClassVar[int] - name: str - columns: _containers.RepeatedCompositeFieldContainer[Column] - def __init__(self, name: _Optional[str] = ..., columns: _Optional[_Iterable[_Union[Column, _Mapping]]] = ...) -> None: ... - -class Column(_message.Message): - __slots__ = ("name", "type", "primary_key", "decimal") - NAME_FIELD_NUMBER: _ClassVar[int] - TYPE_FIELD_NUMBER: _ClassVar[int] - PRIMARY_KEY_FIELD_NUMBER: _ClassVar[int] - DECIMAL_FIELD_NUMBER: _ClassVar[int] - name: str - type: DataType - primary_key: bool - decimal: DecimalParams - def __init__(self, name: _Optional[str] = ..., type: _Optional[_Union[DataType, str]] = ..., primary_key: bool = ..., decimal: _Optional[_Union[DecimalParams, _Mapping]] = ...) -> None: ... diff --git a/v2_examples/destination/python/sdk_pb2/common_pb2_grpc.py b/v2_examples/destination/python/sdk_pb2/common_pb2_grpc.py deleted file mode 100644 index 2daafff..0000000 --- a/v2_examples/destination/python/sdk_pb2/common_pb2_grpc.py +++ /dev/null @@ -1,4 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc - diff --git a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.py b/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.py deleted file mode 100644 index 79d1e5a..0000000 --- a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.py +++ /dev/null @@ -1,74 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: connector_sdk.proto -# Protobuf Python Version: 4.25.0 -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -import common_pb2 as common__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13\x63onnector_sdk.proto\x12\x0c\x66ivetran_sdk\x1a\x0c\x63ommon.proto\"\x8c\x01\n\rSchemaRequest\x12\x45\n\rconfiguration\x18\x01 \x03(\x0b\x32..fivetran_sdk.SchemaRequest.ConfigurationEntry\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xeb\x01\n\x0eSchemaResponse\x12\'\n\x1dschema_response_not_supported\x18\x01 \x01(\x08H\x00\x12/\n\x0bwith_schema\x18\x02 \x01(\x0b\x32\x18.fivetran_sdk.SchemaListH\x00\x12\x31\n\x0ewithout_schema\x18\x03 \x01(\x0b\x32\x17.fivetran_sdk.TableListH\x00\x12$\n\x17selection_not_supported\x18\x04 \x01(\x08H\x01\x88\x01\x01\x42\n\n\x08responseB\x1a\n\x18_selection_not_supported\"\xf3\x01\n\rUpdateRequest\x12\x45\n\rconfiguration\x18\x01 \x03(\x0b\x32..fivetran_sdk.UpdateRequest.ConfigurationEntry\x12/\n\tselection\x18\x02 \x01(\x0b\x32\x17.fivetran_sdk.SelectionH\x00\x88\x01\x01\x12\x17\n\nstate_json\x18\x03 \x01(\tH\x01\x88\x01\x01\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x42\x0c\n\n_selectionB\r\n\x0b_state_json\"\x8b\x01\n\tSelection\x12:\n\x0ewithout_schema\x18\x01 \x01(\x0b\x32 .fivetran_sdk.TablesWithNoSchemaH\x00\x12\x35\n\x0bwith_schema\x18\x02 \x01(\x0b\x32\x1e.fivetran_sdk.TablesWithSchemaH\x00\x42\x0b\n\tselection\"^\n\x12TablesWithNoSchema\x12,\n\x06tables\x18\x01 \x03(\x0b\x32\x1c.fivetran_sdk.TableSelection\x12\x1a\n\x12include_new_tables\x18\x02 \x01(\x08\"_\n\x10TablesWithSchema\x12.\n\x07schemas\x18\x01 \x03(\x0b\x32\x1d.fivetran_sdk.SchemaSelection\x12\x1b\n\x13include_new_schemas\x18\x02 \x01(\x08\"\x82\x01\n\x0fSchemaSelection\x12\x10\n\x08included\x18\x01 \x01(\x08\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12,\n\x06tables\x18\x03 \x03(\x0b\x32\x1c.fivetran_sdk.TableSelection\x12\x1a\n\x12include_new_tables\x18\x04 \x01(\x08\"\xbf\x01\n\x0eTableSelection\x12\x10\n\x08included\x18\x01 \x01(\x08\x12\x12\n\ntable_name\x18\x02 \x01(\t\x12:\n\x07\x63olumns\x18\x03 \x03(\x0b\x32).fivetran_sdk.TableSelection.ColumnsEntry\x12\x1b\n\x13include_new_columns\x18\x04 \x01(\x08\x1a.\n\x0c\x43olumnsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x08:\x02\x38\x01\"w\n\x0eUpdateResponse\x12+\n\tlog_entry\x18\x01 \x01(\x0b\x32\x16.fivetran_sdk.LogEntryH\x00\x12,\n\toperation\x18\x02 \x01(\x0b\x32\x17.fivetran_sdk.OperationH\x00\x42\n\n\x08response\"B\n\x08LogEntry\x12%\n\x05level\x18\x01 \x01(\x0e\x32\x16.fivetran_sdk.LogLevel\x12\x0f\n\x07message\x18\x02 \x01(\t\"\x9e\x01\n\tOperation\x12&\n\x06record\x18\x01 \x01(\x0b\x32\x14.fivetran_sdk.RecordH\x00\x12\x33\n\rschema_change\x18\x02 \x01(\x0b\x32\x1a.fivetran_sdk.SchemaChangeH\x00\x12.\n\ncheckpoint\x18\x03 \x01(\x0b\x32\x18.fivetran_sdk.CheckpointH\x00\x42\x04\n\x02op\"|\n\x0cSchemaChange\x12/\n\x0bwith_schema\x18\x01 \x01(\x0b\x32\x18.fivetran_sdk.SchemaListH\x00\x12\x31\n\x0ewithout_schema\x18\x02 \x01(\x0b\x32\x17.fivetran_sdk.TableListH\x00\x42\x08\n\x06\x63hange\"\xde\x01\n\x06Record\x12\x18\n\x0bschema_name\x18\x01 \x01(\tH\x00\x88\x01\x01\x12\x12\n\ntable_name\x18\x02 \x01(\t\x12\"\n\x04type\x18\x03 \x01(\x0e\x32\x14.fivetran_sdk.OpType\x12,\n\x04\x64\x61ta\x18\x04 \x03(\x0b\x32\x1e.fivetran_sdk.Record.DataEntry\x1a\x44\n\tDataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12&\n\x05value\x18\x02 \x01(\x0b\x32\x17.fivetran_sdk.ValueType:\x02\x38\x01\x42\x0e\n\x0c_schema_name\" \n\nCheckpoint\x12\x12\n\nstate_json\x18\x01 \x01(\t*-\n\x08LogLevel\x12\x08\n\x04INFO\x10\x00\x12\x0b\n\x07WARNING\x10\x01\x12\n\n\x06SEVERE\x10\x02\x32\xc4\x02\n\tConnector\x12\x66\n\x11\x43onfigurationForm\x12&.fivetran_sdk.ConfigurationFormRequest\x1a\'.fivetran_sdk.ConfigurationFormResponse\"\x00\x12?\n\x04Test\x12\x19.fivetran_sdk.TestRequest\x1a\x1a.fivetran_sdk.TestResponse\"\x00\x12\x45\n\x06Schema\x12\x1b.fivetran_sdk.SchemaRequest\x1a\x1c.fivetran_sdk.SchemaResponse\"\x00\x12G\n\x06Update\x12\x1b.fivetran_sdk.UpdateRequest\x1a\x1c.fivetran_sdk.UpdateResponse\"\x00\x30\x01\x42\x1fH\x01P\x01Z\x19\x66ivetran.com/fivetran_sdkb\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'connector_sdk_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None - _globals['DESCRIPTOR']._serialized_options = b'H\001P\001Z\031fivetran.com/fivetran_sdk' - _globals['_SCHEMAREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_SCHEMAREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_UPDATEREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_UPDATEREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_TABLESELECTION_COLUMNSENTRY']._options = None - _globals['_TABLESELECTION_COLUMNSENTRY']._serialized_options = b'8\001' - _globals['_RECORD_DATAENTRY']._options = None - _globals['_RECORD_DATAENTRY']._serialized_options = b'8\001' - _globals['_LOGLEVEL']._serialized_start=2075 - _globals['_LOGLEVEL']._serialized_end=2120 - _globals['_SCHEMAREQUEST']._serialized_start=52 - _globals['_SCHEMAREQUEST']._serialized_end=192 - _globals['_SCHEMAREQUEST_CONFIGURATIONENTRY']._serialized_start=140 - _globals['_SCHEMAREQUEST_CONFIGURATIONENTRY']._serialized_end=192 - _globals['_SCHEMARESPONSE']._serialized_start=195 - _globals['_SCHEMARESPONSE']._serialized_end=430 - _globals['_UPDATEREQUEST']._serialized_start=433 - _globals['_UPDATEREQUEST']._serialized_end=676 - _globals['_UPDATEREQUEST_CONFIGURATIONENTRY']._serialized_start=140 - _globals['_UPDATEREQUEST_CONFIGURATIONENTRY']._serialized_end=192 - _globals['_SELECTION']._serialized_start=679 - _globals['_SELECTION']._serialized_end=818 - _globals['_TABLESWITHNOSCHEMA']._serialized_start=820 - _globals['_TABLESWITHNOSCHEMA']._serialized_end=914 - _globals['_TABLESWITHSCHEMA']._serialized_start=916 - _globals['_TABLESWITHSCHEMA']._serialized_end=1011 - _globals['_SCHEMASELECTION']._serialized_start=1014 - _globals['_SCHEMASELECTION']._serialized_end=1144 - _globals['_TABLESELECTION']._serialized_start=1147 - _globals['_TABLESELECTION']._serialized_end=1338 - _globals['_TABLESELECTION_COLUMNSENTRY']._serialized_start=1292 - _globals['_TABLESELECTION_COLUMNSENTRY']._serialized_end=1338 - _globals['_UPDATERESPONSE']._serialized_start=1340 - _globals['_UPDATERESPONSE']._serialized_end=1459 - _globals['_LOGENTRY']._serialized_start=1461 - _globals['_LOGENTRY']._serialized_end=1527 - _globals['_OPERATION']._serialized_start=1530 - _globals['_OPERATION']._serialized_end=1688 - _globals['_SCHEMACHANGE']._serialized_start=1690 - _globals['_SCHEMACHANGE']._serialized_end=1814 - _globals['_RECORD']._serialized_start=1817 - _globals['_RECORD']._serialized_end=2039 - _globals['_RECORD_DATAENTRY']._serialized_start=1955 - _globals['_RECORD_DATAENTRY']._serialized_end=2023 - _globals['_CHECKPOINT']._serialized_start=2041 - _globals['_CHECKPOINT']._serialized_end=2073 - _globals['_CONNECTOR']._serialized_start=2123 - _globals['_CONNECTOR']._serialized_end=2447 -# @@protoc_insertion_point(module_scope) diff --git a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.pyi b/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.pyi deleted file mode 100644 index ba600f1..0000000 --- a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2.pyi +++ /dev/null @@ -1,173 +0,0 @@ -import common_pb2 as _common_pb2 -from google.protobuf.internal import containers as _containers -from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper -from google.protobuf import descriptor as _descriptor -from google.protobuf import message as _message -from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union - -DESCRIPTOR: _descriptor.FileDescriptor - -class LogLevel(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - INFO: _ClassVar[LogLevel] - WARNING: _ClassVar[LogLevel] - SEVERE: _ClassVar[LogLevel] -INFO: LogLevel -WARNING: LogLevel -SEVERE: LogLevel - -class SchemaRequest(_message.Message): - __slots__ = ("configuration",) - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ...) -> None: ... - -class SchemaResponse(_message.Message): - __slots__ = ("schema_response_not_supported", "with_schema", "without_schema", "selection_not_supported") - SCHEMA_RESPONSE_NOT_SUPPORTED_FIELD_NUMBER: _ClassVar[int] - WITH_SCHEMA_FIELD_NUMBER: _ClassVar[int] - WITHOUT_SCHEMA_FIELD_NUMBER: _ClassVar[int] - SELECTION_NOT_SUPPORTED_FIELD_NUMBER: _ClassVar[int] - schema_response_not_supported: bool - with_schema: _common_pb2.SchemaList - without_schema: _common_pb2.TableList - selection_not_supported: bool - def __init__(self, schema_response_not_supported: bool = ..., with_schema: _Optional[_Union[_common_pb2.SchemaList, _Mapping]] = ..., without_schema: _Optional[_Union[_common_pb2.TableList, _Mapping]] = ..., selection_not_supported: bool = ...) -> None: ... - -class UpdateRequest(_message.Message): - __slots__ = ("configuration", "selection", "state_json") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SELECTION_FIELD_NUMBER: _ClassVar[int] - STATE_JSON_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - selection: Selection - state_json: str - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., selection: _Optional[_Union[Selection, _Mapping]] = ..., state_json: _Optional[str] = ...) -> None: ... - -class Selection(_message.Message): - __slots__ = ("without_schema", "with_schema") - WITHOUT_SCHEMA_FIELD_NUMBER: _ClassVar[int] - WITH_SCHEMA_FIELD_NUMBER: _ClassVar[int] - without_schema: TablesWithNoSchema - with_schema: TablesWithSchema - def __init__(self, without_schema: _Optional[_Union[TablesWithNoSchema, _Mapping]] = ..., with_schema: _Optional[_Union[TablesWithSchema, _Mapping]] = ...) -> None: ... - -class TablesWithNoSchema(_message.Message): - __slots__ = ("tables", "include_new_tables") - TABLES_FIELD_NUMBER: _ClassVar[int] - INCLUDE_NEW_TABLES_FIELD_NUMBER: _ClassVar[int] - tables: _containers.RepeatedCompositeFieldContainer[TableSelection] - include_new_tables: bool - def __init__(self, tables: _Optional[_Iterable[_Union[TableSelection, _Mapping]]] = ..., include_new_tables: bool = ...) -> None: ... - -class TablesWithSchema(_message.Message): - __slots__ = ("schemas", "include_new_schemas") - SCHEMAS_FIELD_NUMBER: _ClassVar[int] - INCLUDE_NEW_SCHEMAS_FIELD_NUMBER: _ClassVar[int] - schemas: _containers.RepeatedCompositeFieldContainer[SchemaSelection] - include_new_schemas: bool - def __init__(self, schemas: _Optional[_Iterable[_Union[SchemaSelection, _Mapping]]] = ..., include_new_schemas: bool = ...) -> None: ... - -class SchemaSelection(_message.Message): - __slots__ = ("included", "schema_name", "tables", "include_new_tables") - INCLUDED_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLES_FIELD_NUMBER: _ClassVar[int] - INCLUDE_NEW_TABLES_FIELD_NUMBER: _ClassVar[int] - included: bool - schema_name: str - tables: _containers.RepeatedCompositeFieldContainer[TableSelection] - include_new_tables: bool - def __init__(self, included: bool = ..., schema_name: _Optional[str] = ..., tables: _Optional[_Iterable[_Union[TableSelection, _Mapping]]] = ..., include_new_tables: bool = ...) -> None: ... - -class TableSelection(_message.Message): - __slots__ = ("included", "table_name", "columns", "include_new_columns") - class ColumnsEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: bool - def __init__(self, key: _Optional[str] = ..., value: bool = ...) -> None: ... - INCLUDED_FIELD_NUMBER: _ClassVar[int] - TABLE_NAME_FIELD_NUMBER: _ClassVar[int] - COLUMNS_FIELD_NUMBER: _ClassVar[int] - INCLUDE_NEW_COLUMNS_FIELD_NUMBER: _ClassVar[int] - included: bool - table_name: str - columns: _containers.ScalarMap[str, bool] - include_new_columns: bool - def __init__(self, included: bool = ..., table_name: _Optional[str] = ..., columns: _Optional[_Mapping[str, bool]] = ..., include_new_columns: bool = ...) -> None: ... - -class UpdateResponse(_message.Message): - __slots__ = ("log_entry", "operation") - LOG_ENTRY_FIELD_NUMBER: _ClassVar[int] - OPERATION_FIELD_NUMBER: _ClassVar[int] - log_entry: LogEntry - operation: Operation - def __init__(self, log_entry: _Optional[_Union[LogEntry, _Mapping]] = ..., operation: _Optional[_Union[Operation, _Mapping]] = ...) -> None: ... - -class LogEntry(_message.Message): - __slots__ = ("level", "message") - LEVEL_FIELD_NUMBER: _ClassVar[int] - MESSAGE_FIELD_NUMBER: _ClassVar[int] - level: LogLevel - message: str - def __init__(self, level: _Optional[_Union[LogLevel, str]] = ..., message: _Optional[str] = ...) -> None: ... - -class Operation(_message.Message): - __slots__ = ("record", "schema_change", "checkpoint") - RECORD_FIELD_NUMBER: _ClassVar[int] - SCHEMA_CHANGE_FIELD_NUMBER: _ClassVar[int] - CHECKPOINT_FIELD_NUMBER: _ClassVar[int] - record: Record - schema_change: SchemaChange - checkpoint: Checkpoint - def __init__(self, record: _Optional[_Union[Record, _Mapping]] = ..., schema_change: _Optional[_Union[SchemaChange, _Mapping]] = ..., checkpoint: _Optional[_Union[Checkpoint, _Mapping]] = ...) -> None: ... - -class SchemaChange(_message.Message): - __slots__ = ("with_schema", "without_schema") - WITH_SCHEMA_FIELD_NUMBER: _ClassVar[int] - WITHOUT_SCHEMA_FIELD_NUMBER: _ClassVar[int] - with_schema: _common_pb2.SchemaList - without_schema: _common_pb2.TableList - def __init__(self, with_schema: _Optional[_Union[_common_pb2.SchemaList, _Mapping]] = ..., without_schema: _Optional[_Union[_common_pb2.TableList, _Mapping]] = ...) -> None: ... - -class Record(_message.Message): - __slots__ = ("schema_name", "table_name", "type", "data") - class DataEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: _common_pb2.ValueType - def __init__(self, key: _Optional[str] = ..., value: _Optional[_Union[_common_pb2.ValueType, _Mapping]] = ...) -> None: ... - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_NAME_FIELD_NUMBER: _ClassVar[int] - TYPE_FIELD_NUMBER: _ClassVar[int] - DATA_FIELD_NUMBER: _ClassVar[int] - schema_name: str - table_name: str - type: _common_pb2.OpType - data: _containers.MessageMap[str, _common_pb2.ValueType] - def __init__(self, schema_name: _Optional[str] = ..., table_name: _Optional[str] = ..., type: _Optional[_Union[_common_pb2.OpType, str]] = ..., data: _Optional[_Mapping[str, _common_pb2.ValueType]] = ...) -> None: ... - -class Checkpoint(_message.Message): - __slots__ = ("state_json",) - STATE_JSON_FIELD_NUMBER: _ClassVar[int] - state_json: str - def __init__(self, state_json: _Optional[str] = ...) -> None: ... diff --git a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2_grpc.py b/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2_grpc.py deleted file mode 100644 index e95294a..0000000 --- a/v2_examples/destination/python/sdk_pb2/connector_sdk_pb2_grpc.py +++ /dev/null @@ -1,169 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc - -import common_pb2 as common__pb2 -import connector_sdk_pb2 as connector__sdk__pb2 - - -class ConnectorStub(object): - """Fivetran (grpc client) <> Connector (grpc server) - """ - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.ConfigurationForm = channel.unary_unary( - '/fivetran_sdk.Connector/ConfigurationForm', - request_serializer=common__pb2.ConfigurationFormRequest.SerializeToString, - response_deserializer=common__pb2.ConfigurationFormResponse.FromString, - ) - self.Test = channel.unary_unary( - '/fivetran_sdk.Connector/Test', - request_serializer=common__pb2.TestRequest.SerializeToString, - response_deserializer=common__pb2.TestResponse.FromString, - ) - self.Schema = channel.unary_unary( - '/fivetran_sdk.Connector/Schema', - request_serializer=connector__sdk__pb2.SchemaRequest.SerializeToString, - response_deserializer=connector__sdk__pb2.SchemaResponse.FromString, - ) - self.Update = channel.unary_stream( - '/fivetran_sdk.Connector/Update', - request_serializer=connector__sdk__pb2.UpdateRequest.SerializeToString, - response_deserializer=connector__sdk__pb2.UpdateResponse.FromString, - ) - - -class ConnectorServicer(object): - """Fivetran (grpc client) <> Connector (grpc server) - """ - - def ConfigurationForm(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Test(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Schema(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Update(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_ConnectorServicer_to_server(servicer, server): - rpc_method_handlers = { - 'ConfigurationForm': grpc.unary_unary_rpc_method_handler( - servicer.ConfigurationForm, - request_deserializer=common__pb2.ConfigurationFormRequest.FromString, - response_serializer=common__pb2.ConfigurationFormResponse.SerializeToString, - ), - 'Test': grpc.unary_unary_rpc_method_handler( - servicer.Test, - request_deserializer=common__pb2.TestRequest.FromString, - response_serializer=common__pb2.TestResponse.SerializeToString, - ), - 'Schema': grpc.unary_unary_rpc_method_handler( - servicer.Schema, - request_deserializer=connector__sdk__pb2.SchemaRequest.FromString, - response_serializer=connector__sdk__pb2.SchemaResponse.SerializeToString, - ), - 'Update': grpc.unary_stream_rpc_method_handler( - servicer.Update, - request_deserializer=connector__sdk__pb2.UpdateRequest.FromString, - response_serializer=connector__sdk__pb2.UpdateResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'fivetran_sdk.Connector', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - - # This class is part of an EXPERIMENTAL API. -class Connector(object): - """Fivetran (grpc client) <> Connector (grpc server) - """ - - @staticmethod - def ConfigurationForm(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Connector/ConfigurationForm', - common__pb2.ConfigurationFormRequest.SerializeToString, - common__pb2.ConfigurationFormResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Test(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Connector/Test', - common__pb2.TestRequest.SerializeToString, - common__pb2.TestResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Schema(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Connector/Schema', - connector__sdk__pb2.SchemaRequest.SerializeToString, - connector__sdk__pb2.SchemaResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Update(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_stream(request, target, '/fivetran_sdk.Connector/Update', - connector__sdk__pb2.UpdateRequest.SerializeToString, - connector__sdk__pb2.UpdateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.py b/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.py deleted file mode 100644 index 69aae76..0000000 --- a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.py +++ /dev/null @@ -1,89 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: destination_sdk.proto -# Protobuf Python Version: 4.25.0 -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 -import common_pb2 as common__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x64\x65stination_sdk.proto\x12\x0c\x66ivetran_sdk\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x0c\x63ommon.proto\"\x15\n\x13\x43\x61pabilitiesRequest\"P\n\x14\x43\x61pabilitiesResponse\x12\x38\n\x11\x62\x61tch_file_format\x18\x01 \x01(\x0e\x32\x1d.fivetran_sdk.BatchFileFormat\"\xc3\x01\n\x14\x44\x65scribeTableRequest\x12L\n\rconfiguration\x18\x01 \x03(\x0b\x32\x35.fivetran_sdk.DescribeTableRequest.ConfigurationEntry\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12\x12\n\ntable_name\x18\x03 \x01(\t\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"q\n\x15\x44\x65scribeTableResponse\x12\x13\n\tnot_found\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x12$\n\x05table\x18\x03 \x01(\x0b\x32\x13.fivetran_sdk.TableH\x00\x42\n\n\x08response\"\xcf\x01\n\x12\x43reateTableRequest\x12J\n\rconfiguration\x18\x01 \x03(\x0b\x32\x33.fivetran_sdk.CreateTableRequest.ConfigurationEntry\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12\"\n\x05table\x18\x03 \x01(\x0b\x32\x13.fivetran_sdk.Table\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"G\n\x13\x43reateTableResponse\x12\x11\n\x07success\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x42\n\n\x08response\"\xcd\x01\n\x11\x41lterTableRequest\x12I\n\rconfiguration\x18\x01 \x03(\x0b\x32\x32.fivetran_sdk.AlterTableRequest.ConfigurationEntry\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12\"\n\x05table\x18\x03 \x01(\x0b\x32\x13.fivetran_sdk.Table\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"F\n\x12\x41lterTableResponse\x12\x11\n\x07success\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x42\n\n\x08response\"\xbf\x02\n\x0fTruncateRequest\x12G\n\rconfiguration\x18\x01 \x03(\x0b\x32\x30.fivetran_sdk.TruncateRequest.ConfigurationEntry\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12\x12\n\ntable_name\x18\x03 \x01(\t\x12\x15\n\rsynced_column\x18\x04 \x01(\t\x12\x35\n\x11utc_delete_before\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12-\n\x04soft\x18\x06 \x01(\x0b\x32\x1a.fivetran_sdk.SoftTruncateH\x00\x88\x01\x01\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x42\x07\n\x05_soft\"&\n\x0cSoftTruncate\x12\x16\n\x0e\x64\x65leted_column\x18\x03 \x01(\t\"D\n\x10TruncateResponse\x12\x11\n\x07success\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x42\n\n\x08response\"\xe5\x03\n\x11WriteBatchRequest\x12I\n\rconfiguration\x18\x01 \x03(\x0b\x32\x32.fivetran_sdk.WriteBatchRequest.ConfigurationEntry\x12\x13\n\x0bschema_name\x18\x02 \x01(\t\x12\"\n\x05table\x18\x03 \x01(\x0b\x32\x13.fivetran_sdk.Table\x12\x37\n\x04keys\x18\x04 \x03(\x0b\x32).fivetran_sdk.WriteBatchRequest.KeysEntry\x12\x15\n\rreplace_files\x18\x05 \x03(\t\x12\x14\n\x0cupdate_files\x18\x06 \x03(\t\x12\x14\n\x0c\x64\x65lete_files\x18\x07 \x03(\t\x12*\n\x03\x63sv\x18\x08 \x01(\x0b\x32\x1b.fivetran_sdk.CsvFileParamsH\x00\x12\x32\n\x07parquet\x18\t \x01(\x0b\x32\x1f.fivetran_sdk.ParquetFileParamsH\x00\x1a\x34\n\x12\x43onfigurationEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a+\n\tKeysEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\x42\r\n\x0b\x66ile_params\"\x9d\x01\n\rCsvFileParams\x12.\n\x0b\x63ompression\x18\x01 \x01(\x0e\x32\x19.fivetran_sdk.Compression\x12,\n\nencryption\x18\x02 \x01(\x0e\x32\x18.fivetran_sdk.Encryption\x12\x13\n\x0bnull_string\x18\x03 \x01(\t\x12\x19\n\x11unmodified_string\x18\x04 \x01(\t\"A\n\x11ParquetFileParams\x12,\n\nencryption\x18\x01 \x01(\x0e\x32\x18.fivetran_sdk.Encryption\"F\n\x12WriteBatchResponse\x12\x11\n\x07success\x18\x01 \x01(\x08H\x00\x12\x11\n\x07\x66\x61ilure\x18\x02 \x01(\tH\x00\x42\n\n\x08response*\x1f\n\nEncryption\x12\x08\n\x04NONE\x10\x00\x12\x07\n\x03\x41\x45S\x10\x01*\'\n\x0f\x42\x61tchFileFormat\x12\x07\n\x03\x43SV\x10\x00\x12\x0b\n\x07PARQUET\x10\x01**\n\x0b\x43ompression\x12\x07\n\x03OFF\x10\x00\x12\x08\n\x04ZSTD\x10\x01\x12\x08\n\x04GZIP\x10\x02\x32\xb4\x05\n\x0b\x44\x65stination\x12\x66\n\x11\x43onfigurationForm\x12&.fivetran_sdk.ConfigurationFormRequest\x1a\'.fivetran_sdk.ConfigurationFormResponse\"\x00\x12W\n\x0c\x43\x61pabilities\x12!.fivetran_sdk.CapabilitiesRequest\x1a\".fivetran_sdk.CapabilitiesResponse\"\x00\x12?\n\x04Test\x12\x19.fivetran_sdk.TestRequest\x1a\x1a.fivetran_sdk.TestResponse\"\x00\x12Z\n\rDescribeTable\x12\".fivetran_sdk.DescribeTableRequest\x1a#.fivetran_sdk.DescribeTableResponse\"\x00\x12T\n\x0b\x43reateTable\x12 .fivetran_sdk.CreateTableRequest\x1a!.fivetran_sdk.CreateTableResponse\"\x00\x12Q\n\nAlterTable\x12\x1f.fivetran_sdk.AlterTableRequest\x1a .fivetran_sdk.AlterTableResponse\"\x00\x12K\n\x08Truncate\x12\x1d.fivetran_sdk.TruncateRequest\x1a\x1e.fivetran_sdk.TruncateResponse\"\x00\x12Q\n\nWriteBatch\x12\x1f.fivetran_sdk.WriteBatchRequest\x1a .fivetran_sdk.WriteBatchResponse\"\x00\x42\x1fH\x01P\x01Z\x19\x66ivetran.com/fivetran_sdkb\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'destination_sdk_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None - _globals['DESCRIPTOR']._serialized_options = b'H\001P\001Z\031fivetran.com/fivetran_sdk' - _globals['_DESCRIBETABLEREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_DESCRIBETABLEREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_CREATETABLEREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_CREATETABLEREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_ALTERTABLEREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_ALTERTABLEREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_TRUNCATEREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_TRUNCATEREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_WRITEBATCHREQUEST_CONFIGURATIONENTRY']._options = None - _globals['_WRITEBATCHREQUEST_CONFIGURATIONENTRY']._serialized_options = b'8\001' - _globals['_WRITEBATCHREQUEST_KEYSENTRY']._options = None - _globals['_WRITEBATCHREQUEST_KEYSENTRY']._serialized_options = b'8\001' - _globals['_ENCRYPTION']._serialized_start=2286 - _globals['_ENCRYPTION']._serialized_end=2317 - _globals['_BATCHFILEFORMAT']._serialized_start=2319 - _globals['_BATCHFILEFORMAT']._serialized_end=2358 - _globals['_COMPRESSION']._serialized_start=2360 - _globals['_COMPRESSION']._serialized_end=2402 - _globals['_CAPABILITIESREQUEST']._serialized_start=86 - _globals['_CAPABILITIESREQUEST']._serialized_end=107 - _globals['_CAPABILITIESRESPONSE']._serialized_start=109 - _globals['_CAPABILITIESRESPONSE']._serialized_end=189 - _globals['_DESCRIBETABLEREQUEST']._serialized_start=192 - _globals['_DESCRIBETABLEREQUEST']._serialized_end=387 - _globals['_DESCRIBETABLEREQUEST_CONFIGURATIONENTRY']._serialized_start=335 - _globals['_DESCRIBETABLEREQUEST_CONFIGURATIONENTRY']._serialized_end=387 - _globals['_DESCRIBETABLERESPONSE']._serialized_start=389 - _globals['_DESCRIBETABLERESPONSE']._serialized_end=502 - _globals['_CREATETABLEREQUEST']._serialized_start=505 - _globals['_CREATETABLEREQUEST']._serialized_end=712 - _globals['_CREATETABLEREQUEST_CONFIGURATIONENTRY']._serialized_start=335 - _globals['_CREATETABLEREQUEST_CONFIGURATIONENTRY']._serialized_end=387 - _globals['_CREATETABLERESPONSE']._serialized_start=714 - _globals['_CREATETABLERESPONSE']._serialized_end=785 - _globals['_ALTERTABLEREQUEST']._serialized_start=788 - _globals['_ALTERTABLEREQUEST']._serialized_end=993 - _globals['_ALTERTABLEREQUEST_CONFIGURATIONENTRY']._serialized_start=335 - _globals['_ALTERTABLEREQUEST_CONFIGURATIONENTRY']._serialized_end=387 - _globals['_ALTERTABLERESPONSE']._serialized_start=995 - _globals['_ALTERTABLERESPONSE']._serialized_end=1065 - _globals['_TRUNCATEREQUEST']._serialized_start=1068 - _globals['_TRUNCATEREQUEST']._serialized_end=1387 - _globals['_TRUNCATEREQUEST_CONFIGURATIONENTRY']._serialized_start=335 - _globals['_TRUNCATEREQUEST_CONFIGURATIONENTRY']._serialized_end=387 - _globals['_SOFTTRUNCATE']._serialized_start=1389 - _globals['_SOFTTRUNCATE']._serialized_end=1427 - _globals['_TRUNCATERESPONSE']._serialized_start=1429 - _globals['_TRUNCATERESPONSE']._serialized_end=1497 - _globals['_WRITEBATCHREQUEST']._serialized_start=1500 - _globals['_WRITEBATCHREQUEST']._serialized_end=1985 - _globals['_WRITEBATCHREQUEST_CONFIGURATIONENTRY']._serialized_start=335 - _globals['_WRITEBATCHREQUEST_CONFIGURATIONENTRY']._serialized_end=387 - _globals['_WRITEBATCHREQUEST_KEYSENTRY']._serialized_start=1927 - _globals['_WRITEBATCHREQUEST_KEYSENTRY']._serialized_end=1970 - _globals['_CSVFILEPARAMS']._serialized_start=1988 - _globals['_CSVFILEPARAMS']._serialized_end=2145 - _globals['_PARQUETFILEPARAMS']._serialized_start=2147 - _globals['_PARQUETFILEPARAMS']._serialized_end=2212 - _globals['_WRITEBATCHRESPONSE']._serialized_start=2214 - _globals['_WRITEBATCHRESPONSE']._serialized_end=2284 - _globals['_DESTINATION']._serialized_start=2405 - _globals['_DESTINATION']._serialized_end=3097 -# @@protoc_insertion_point(module_scope) diff --git a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.pyi b/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.pyi deleted file mode 100644 index d831985..0000000 --- a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2.pyi +++ /dev/null @@ -1,218 +0,0 @@ -from google.protobuf import timestamp_pb2 as _timestamp_pb2 -import common_pb2 as _common_pb2 -from google.protobuf.internal import containers as _containers -from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper -from google.protobuf import descriptor as _descriptor -from google.protobuf import message as _message -from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union - -DESCRIPTOR: _descriptor.FileDescriptor - -class Encryption(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - NONE: _ClassVar[Encryption] - AES: _ClassVar[Encryption] - -class BatchFileFormat(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - CSV: _ClassVar[BatchFileFormat] - PARQUET: _ClassVar[BatchFileFormat] - -class Compression(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = () - OFF: _ClassVar[Compression] - ZSTD: _ClassVar[Compression] - GZIP: _ClassVar[Compression] -NONE: Encryption -AES: Encryption -CSV: BatchFileFormat -PARQUET: BatchFileFormat -OFF: Compression -ZSTD: Compression -GZIP: Compression - -class CapabilitiesRequest(_message.Message): - __slots__ = () - def __init__(self) -> None: ... - -class CapabilitiesResponse(_message.Message): - __slots__ = ("batch_file_format",) - BATCH_FILE_FORMAT_FIELD_NUMBER: _ClassVar[int] - batch_file_format: BatchFileFormat - def __init__(self, batch_file_format: _Optional[_Union[BatchFileFormat, str]] = ...) -> None: ... - -class DescribeTableRequest(_message.Message): - __slots__ = ("configuration", "schema_name", "table_name") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_NAME_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - schema_name: str - table_name: str - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., schema_name: _Optional[str] = ..., table_name: _Optional[str] = ...) -> None: ... - -class DescribeTableResponse(_message.Message): - __slots__ = ("not_found", "failure", "table") - NOT_FOUND_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - TABLE_FIELD_NUMBER: _ClassVar[int] - not_found: bool - failure: str - table: _common_pb2.Table - def __init__(self, not_found: bool = ..., failure: _Optional[str] = ..., table: _Optional[_Union[_common_pb2.Table, _Mapping]] = ...) -> None: ... - -class CreateTableRequest(_message.Message): - __slots__ = ("configuration", "schema_name", "table") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - schema_name: str - table: _common_pb2.Table - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., schema_name: _Optional[str] = ..., table: _Optional[_Union[_common_pb2.Table, _Mapping]] = ...) -> None: ... - -class CreateTableResponse(_message.Message): - __slots__ = ("success", "failure") - SUCCESS_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - success: bool - failure: str - def __init__(self, success: bool = ..., failure: _Optional[str] = ...) -> None: ... - -class AlterTableRequest(_message.Message): - __slots__ = ("configuration", "schema_name", "table") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - schema_name: str - table: _common_pb2.Table - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., schema_name: _Optional[str] = ..., table: _Optional[_Union[_common_pb2.Table, _Mapping]] = ...) -> None: ... - -class AlterTableResponse(_message.Message): - __slots__ = ("success", "failure") - SUCCESS_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - success: bool - failure: str - def __init__(self, success: bool = ..., failure: _Optional[str] = ...) -> None: ... - -class TruncateRequest(_message.Message): - __slots__ = ("configuration", "schema_name", "table_name", "synced_column", "utc_delete_before", "soft") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_NAME_FIELD_NUMBER: _ClassVar[int] - SYNCED_COLUMN_FIELD_NUMBER: _ClassVar[int] - UTC_DELETE_BEFORE_FIELD_NUMBER: _ClassVar[int] - SOFT_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - schema_name: str - table_name: str - synced_column: str - utc_delete_before: _timestamp_pb2.Timestamp - soft: SoftTruncate - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., schema_name: _Optional[str] = ..., table_name: _Optional[str] = ..., synced_column: _Optional[str] = ..., utc_delete_before: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., soft: _Optional[_Union[SoftTruncate, _Mapping]] = ...) -> None: ... - -class SoftTruncate(_message.Message): - __slots__ = ("deleted_column",) - DELETED_COLUMN_FIELD_NUMBER: _ClassVar[int] - deleted_column: str - def __init__(self, deleted_column: _Optional[str] = ...) -> None: ... - -class TruncateResponse(_message.Message): - __slots__ = ("success", "failure") - SUCCESS_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - success: bool - failure: str - def __init__(self, success: bool = ..., failure: _Optional[str] = ...) -> None: ... - -class WriteBatchRequest(_message.Message): - __slots__ = ("configuration", "schema_name", "table", "keys", "replace_files", "update_files", "delete_files", "csv", "parquet") - class ConfigurationEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: str - def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... - class KeysEntry(_message.Message): - __slots__ = ("key", "value") - KEY_FIELD_NUMBER: _ClassVar[int] - VALUE_FIELD_NUMBER: _ClassVar[int] - key: str - value: bytes - def __init__(self, key: _Optional[str] = ..., value: _Optional[bytes] = ...) -> None: ... - CONFIGURATION_FIELD_NUMBER: _ClassVar[int] - SCHEMA_NAME_FIELD_NUMBER: _ClassVar[int] - TABLE_FIELD_NUMBER: _ClassVar[int] - KEYS_FIELD_NUMBER: _ClassVar[int] - REPLACE_FILES_FIELD_NUMBER: _ClassVar[int] - UPDATE_FILES_FIELD_NUMBER: _ClassVar[int] - DELETE_FILES_FIELD_NUMBER: _ClassVar[int] - CSV_FIELD_NUMBER: _ClassVar[int] - PARQUET_FIELD_NUMBER: _ClassVar[int] - configuration: _containers.ScalarMap[str, str] - schema_name: str - table: _common_pb2.Table - keys: _containers.ScalarMap[str, bytes] - replace_files: _containers.RepeatedScalarFieldContainer[str] - update_files: _containers.RepeatedScalarFieldContainer[str] - delete_files: _containers.RepeatedScalarFieldContainer[str] - csv: CsvFileParams - parquet: ParquetFileParams - def __init__(self, configuration: _Optional[_Mapping[str, str]] = ..., schema_name: _Optional[str] = ..., table: _Optional[_Union[_common_pb2.Table, _Mapping]] = ..., keys: _Optional[_Mapping[str, bytes]] = ..., replace_files: _Optional[_Iterable[str]] = ..., update_files: _Optional[_Iterable[str]] = ..., delete_files: _Optional[_Iterable[str]] = ..., csv: _Optional[_Union[CsvFileParams, _Mapping]] = ..., parquet: _Optional[_Union[ParquetFileParams, _Mapping]] = ...) -> None: ... - -class CsvFileParams(_message.Message): - __slots__ = ("compression", "encryption", "null_string", "unmodified_string") - COMPRESSION_FIELD_NUMBER: _ClassVar[int] - ENCRYPTION_FIELD_NUMBER: _ClassVar[int] - NULL_STRING_FIELD_NUMBER: _ClassVar[int] - UNMODIFIED_STRING_FIELD_NUMBER: _ClassVar[int] - compression: Compression - encryption: Encryption - null_string: str - unmodified_string: str - def __init__(self, compression: _Optional[_Union[Compression, str]] = ..., encryption: _Optional[_Union[Encryption, str]] = ..., null_string: _Optional[str] = ..., unmodified_string: _Optional[str] = ...) -> None: ... - -class ParquetFileParams(_message.Message): - __slots__ = ("encryption",) - ENCRYPTION_FIELD_NUMBER: _ClassVar[int] - encryption: Encryption - def __init__(self, encryption: _Optional[_Union[Encryption, str]] = ...) -> None: ... - -class WriteBatchResponse(_message.Message): - __slots__ = ("success", "failure") - SUCCESS_FIELD_NUMBER: _ClassVar[int] - FAILURE_FIELD_NUMBER: _ClassVar[int] - success: bool - failure: str - def __init__(self, success: bool = ..., failure: _Optional[str] = ...) -> None: ... diff --git a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2_grpc.py b/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2_grpc.py deleted file mode 100644 index 0d766d2..0000000 --- a/v2_examples/destination/python/sdk_pb2/destination_sdk_pb2_grpc.py +++ /dev/null @@ -1,301 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc - -import common_pb2 as common__pb2 -import destination_sdk_pb2 as destination__sdk__pb2 - - -class DestinationStub(object): - """Fivetran (grpc client) <> Destination (grpc server) - """ - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.ConfigurationForm = channel.unary_unary( - '/fivetran_sdk.Destination/ConfigurationForm', - request_serializer=common__pb2.ConfigurationFormRequest.SerializeToString, - response_deserializer=common__pb2.ConfigurationFormResponse.FromString, - ) - self.Capabilities = channel.unary_unary( - '/fivetran_sdk.Destination/Capabilities', - request_serializer=destination__sdk__pb2.CapabilitiesRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.CapabilitiesResponse.FromString, - ) - self.Test = channel.unary_unary( - '/fivetran_sdk.Destination/Test', - request_serializer=common__pb2.TestRequest.SerializeToString, - response_deserializer=common__pb2.TestResponse.FromString, - ) - self.DescribeTable = channel.unary_unary( - '/fivetran_sdk.Destination/DescribeTable', - request_serializer=destination__sdk__pb2.DescribeTableRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.DescribeTableResponse.FromString, - ) - self.CreateTable = channel.unary_unary( - '/fivetran_sdk.Destination/CreateTable', - request_serializer=destination__sdk__pb2.CreateTableRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.CreateTableResponse.FromString, - ) - self.AlterTable = channel.unary_unary( - '/fivetran_sdk.Destination/AlterTable', - request_serializer=destination__sdk__pb2.AlterTableRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.AlterTableResponse.FromString, - ) - self.Truncate = channel.unary_unary( - '/fivetran_sdk.Destination/Truncate', - request_serializer=destination__sdk__pb2.TruncateRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.TruncateResponse.FromString, - ) - self.WriteBatch = channel.unary_unary( - '/fivetran_sdk.Destination/WriteBatch', - request_serializer=destination__sdk__pb2.WriteBatchRequest.SerializeToString, - response_deserializer=destination__sdk__pb2.WriteBatchResponse.FromString, - ) - - -class DestinationServicer(object): - """Fivetran (grpc client) <> Destination (grpc server) - """ - - def ConfigurationForm(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Capabilities(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Test(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def DescribeTable(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def CreateTable(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def AlterTable(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Truncate(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def WriteBatch(self, request, context): - """Missing associated documentation comment in .proto file.""" - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_DestinationServicer_to_server(servicer, server): - rpc_method_handlers = { - 'ConfigurationForm': grpc.unary_unary_rpc_method_handler( - servicer.ConfigurationForm, - request_deserializer=common__pb2.ConfigurationFormRequest.FromString, - response_serializer=common__pb2.ConfigurationFormResponse.SerializeToString, - ), - 'Capabilities': grpc.unary_unary_rpc_method_handler( - servicer.Capabilities, - request_deserializer=destination__sdk__pb2.CapabilitiesRequest.FromString, - response_serializer=destination__sdk__pb2.CapabilitiesResponse.SerializeToString, - ), - 'Test': grpc.unary_unary_rpc_method_handler( - servicer.Test, - request_deserializer=common__pb2.TestRequest.FromString, - response_serializer=common__pb2.TestResponse.SerializeToString, - ), - 'DescribeTable': grpc.unary_unary_rpc_method_handler( - servicer.DescribeTable, - request_deserializer=destination__sdk__pb2.DescribeTableRequest.FromString, - response_serializer=destination__sdk__pb2.DescribeTableResponse.SerializeToString, - ), - 'CreateTable': grpc.unary_unary_rpc_method_handler( - servicer.CreateTable, - request_deserializer=destination__sdk__pb2.CreateTableRequest.FromString, - response_serializer=destination__sdk__pb2.CreateTableResponse.SerializeToString, - ), - 'AlterTable': grpc.unary_unary_rpc_method_handler( - servicer.AlterTable, - request_deserializer=destination__sdk__pb2.AlterTableRequest.FromString, - response_serializer=destination__sdk__pb2.AlterTableResponse.SerializeToString, - ), - 'Truncate': grpc.unary_unary_rpc_method_handler( - servicer.Truncate, - request_deserializer=destination__sdk__pb2.TruncateRequest.FromString, - response_serializer=destination__sdk__pb2.TruncateResponse.SerializeToString, - ), - 'WriteBatch': grpc.unary_unary_rpc_method_handler( - servicer.WriteBatch, - request_deserializer=destination__sdk__pb2.WriteBatchRequest.FromString, - response_serializer=destination__sdk__pb2.WriteBatchResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'fivetran_sdk.Destination', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - - # This class is part of an EXPERIMENTAL API. -class Destination(object): - """Fivetran (grpc client) <> Destination (grpc server) - """ - - @staticmethod - def ConfigurationForm(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/ConfigurationForm', - common__pb2.ConfigurationFormRequest.SerializeToString, - common__pb2.ConfigurationFormResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Capabilities(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/Capabilities', - destination__sdk__pb2.CapabilitiesRequest.SerializeToString, - destination__sdk__pb2.CapabilitiesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Test(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/Test', - common__pb2.TestRequest.SerializeToString, - common__pb2.TestResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def DescribeTable(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/DescribeTable', - destination__sdk__pb2.DescribeTableRequest.SerializeToString, - destination__sdk__pb2.DescribeTableResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def CreateTable(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/CreateTable', - destination__sdk__pb2.CreateTableRequest.SerializeToString, - destination__sdk__pb2.CreateTableResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def AlterTable(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/AlterTable', - destination__sdk__pb2.AlterTableRequest.SerializeToString, - destination__sdk__pb2.AlterTableResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Truncate(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/Truncate', - destination__sdk__pb2.TruncateRequest.SerializeToString, - destination__sdk__pb2.TruncateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def WriteBatch(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/fivetran_sdk.Destination/WriteBatch', - destination__sdk__pb2.WriteBatchRequest.SerializeToString, - destination__sdk__pb2.WriteBatchResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata)