-
Notifications
You must be signed in to change notification settings - Fork 3
Expand file tree
/
Copy pathplugin_pb2.py
More file actions
142 lines (136 loc) · 13 KB
/
plugin_pb2.py
File metadata and controls
142 lines (136 loc) · 13 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# NO CHECKED-IN PROTOBUF GENCODE
# source: cloudquery/plugin_v3/plugin.proto
# Protobuf Python Version: 6.31.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import runtime_version as _runtime_version
from google.protobuf import symbol_database as _symbol_database
from google.protobuf.internal import builder as _builder
_runtime_version.ValidateProtobufRuntimeVersion(
_runtime_version.Domain.PUBLIC,
6,
31,
1,
'',
'cloudquery/plugin_v3/plugin.proto'
)
# @@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!cloudquery/plugin_v3/plugin.proto\x12\x14\x63loudquery.plugin.v3\x1a\x1fgoogle/protobuf/timestamp.proto\".\n\x07GetName\x1a\t\n\x07Request\x1a\x18\n\x08Response\x12\x0c\n\x04name\x18\x01 \x01(\t\"4\n\nGetVersion\x1a\t\n\x07Request\x1a\x1b\n\x08Response\x12\x0f\n\x07version\x18\x01 \x01(\t\"P\n\rGetSpecSchema\x1a\t\n\x07Request\x1a\x34\n\x08Response\x12\x18\n\x0bjson_schema\x18\x01 \x01(\tH\x00\x88\x01\x01\x42\x0e\n\x0c_json_schema\"Y\n\x04Init\x1a\x45\n\x07Request\x12\x0c\n\x04spec\x18\x01 \x01(\x0c\x12\x15\n\rno_connection\x18\x02 \x01(\x08\x12\x15\n\rinvocation_id\x18\x03 \x01(\t\x1a\n\n\x08Response\"v\n\tGetTables\x1aM\n\x07Request\x12\x0e\n\x06tables\x18\x01 \x03(\t\x12\x13\n\x0bskip_tables\x18\x02 \x03(\t\x12\x1d\n\x15skip_dependent_tables\x18\x03 \x01(\x08\x1a\x1a\n\x08Response\x12\x0e\n\x06tables\x18\x01 \x03(\x0c\"\xb2\x07\n\x04Sync\x1a\x1f\n\rMessageInsert\x12\x0e\n\x06record\x18\x01 \x01(\x0c\x1a$\n\x13MessageMigrateTable\x12\r\n\x05table\x18\x01 \x01(\x0c\x1a\xa4\x01\n\x13MessageDeleteRecord\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12;\n\x0cwhere_clause\x18\x02 \x03(\x0b\x32%.cloudquery.plugin.v3.PredicatesGroup\x12<\n\x0ftable_relations\x18\x03 \x03(\x0b\x32#.cloudquery.plugin.v3.TableRelation\x1a\x31\n\x0cMessageError\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\r\n\x05\x65rror\x18\x02 \x01(\t\x1a\x38\n\x0e\x42\x61\x63kendOptions\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x12\n\nconnection\x18\x02 \x01(\t\x1a\xae\x02\n\x07Request\x12\x0e\n\x06tables\x18\x01 \x03(\t\x12\x13\n\x0bskip_tables\x18\x02 \x03(\t\x12\x1d\n\x15skip_dependent_tables\x18\x03 \x01(\x08\x12\x1b\n\x13\x64\x65terministic_cq_id\x18\x04 \x01(\x08\x12:\n\x07\x62\x61\x63kend\x18\x05 \x01(\x0b\x32).cloudquery.plugin.v3.Sync.BackendOptions\x12<\n\x05shard\x18\x06 \x01(\x0b\x32(.cloudquery.plugin.v3.Sync.Request.ShardH\x00\x88\x01\x01\x12\x19\n\x11withErrorMessages\x18\x07 \x01(\x08\x1a#\n\x05Shard\x12\x0b\n\x03num\x18\x01 \x01(\x05\x12\r\n\x05total\x18\x02 \x01(\x05\x42\x08\n\x06_shard\x1a\x9d\x02\n\x08Response\x12G\n\rmigrate_table\x18\x01 \x01(\x0b\x32..cloudquery.plugin.v3.Sync.MessageMigrateTableH\x00\x12:\n\x06insert\x18\x02 \x01(\x0b\x32(.cloudquery.plugin.v3.Sync.MessageInsertH\x00\x12G\n\rdelete_record\x18\x03 \x01(\x0b\x32..cloudquery.plugin.v3.Sync.MessageDeleteRecordH\x00\x12\x38\n\x05\x65rror\x18\x04 \x01(\x0b\x32\'.cloudquery.plugin.v3.Sync.MessageErrorH\x00\x42\t\n\x07message\"<\n\x04Read\x1a\x18\n\x07Request\x12\r\n\x05table\x18\x01 \x01(\x0c\x1a\x1a\n\x08Response\x12\x0e\n\x06record\x18\x01 \x01(\x0c\"9\n\rTableRelation\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x14\n\x0cparent_table\x18\x02 \x01(\t\"{\n\tPredicate\x12:\n\x08operator\x18\x01 \x01(\x0e\x32(.cloudquery.plugin.v3.Predicate.Operator\x12\x0e\n\x06\x63olumn\x18\x02 \x01(\t\x12\x0e\n\x06record\x18\x03 \x01(\x0c\"\x12\n\x08Operator\x12\x06\n\x02\x45Q\x10\x00\"\xb2\x01\n\x0fPredicatesGroup\x12I\n\rgrouping_type\x18\x01 \x01(\x0e\x32\x32.cloudquery.plugin.v3.PredicatesGroup.GroupingType\x12\x33\n\npredicates\x18\x02 \x03(\x0b\x32\x1f.cloudquery.plugin.v3.Predicate\"\x1f\n\x0cGroupingType\x12\x07\n\x03\x41ND\x10\x00\x12\x06\n\x02OR\x10\x01\"\xc3\x05\n\x05Write\x1a;\n\x13MessageMigrateTable\x12\r\n\x05table\x18\x01 \x01(\x0c\x12\x15\n\rmigrate_force\x18\x02 \x01(\x08\x1a\x1f\n\rMessageInsert\x12\x0e\n\x06record\x18\x01 \x01(\x0c\x1a\x7f\n\x12MessageDeleteStale\x12\x11\n\x05table\x18\x01 \x01(\x0c\x42\x02\x18\x01\x12\x13\n\x0bsource_name\x18\x02 \x01(\t\x12-\n\tsync_time\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x12\n\ntable_name\x18\x04 \x01(\t\x1a\xa4\x01\n\x13MessageDeleteRecord\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12;\n\x0cwhere_clause\x18\x02 \x03(\x0b\x32%.cloudquery.plugin.v3.PredicatesGroup\x12<\n\x0ftable_relations\x18\x03 \x03(\x0b\x32#.cloudquery.plugin.v3.TableRelation\x1a\xa7\x02\n\x07Request\x12H\n\rmigrate_table\x18\x01 \x01(\x0b\x32/.cloudquery.plugin.v3.Write.MessageMigrateTableH\x00\x12;\n\x06insert\x18\x02 \x01(\x0b\x32).cloudquery.plugin.v3.Write.MessageInsertH\x00\x12@\n\x06\x64\x65lete\x18\x03 \x01(\x0b\x32..cloudquery.plugin.v3.Write.MessageDeleteStaleH\x00\x12H\n\rdelete_record\x18\x04 \x01(\x0b\x32/.cloudquery.plugin.v3.Write.MessageDeleteRecordH\x00\x42\t\n\x07message\x1a\n\n\x08Response\"B\n\tTransform\x1a\x19\n\x07Request\x12\x0e\n\x06record\x18\x01 \x01(\x0c\x1a\x1a\n\x08Response\x12\x0e\n\x06record\x18\x01 \x01(\x0c\"H\n\x0fTransformSchema\x1a\x19\n\x07Request\x12\x0e\n\x06schema\x18\x01 \x01(\x0c\x1a\x1a\n\x08Response\x12\x0e\n\x06schema\x18\x01 \x01(\x0c\"\x1e\n\x05\x43lose\x1a\t\n\x07Request\x1a\n\n\x08Response\"y\n\x0eTestConnection\x1a\x17\n\x07Request\x12\x0c\n\x04spec\x18\x01 \x01(\x0c\x1aN\n\x08Response\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x14\n\x0c\x66\x61ilure_code\x18\x02 \x01(\t\x12\x1b\n\x13\x66\x61ilure_description\x18\x03 \x01(\t2\xf7\x08\n\x06Plugin\x12X\n\x07GetName\x12%.cloudquery.plugin.v3.GetName.Request\x1a&.cloudquery.plugin.v3.GetName.Response\x12\x61\n\nGetVersion\x12(.cloudquery.plugin.v3.GetVersion.Request\x1a).cloudquery.plugin.v3.GetVersion.Response\x12j\n\rGetSpecSchema\x12+.cloudquery.plugin.v3.GetSpecSchema.Request\x1a,.cloudquery.plugin.v3.GetSpecSchema.Response\x12O\n\x04Init\x12\".cloudquery.plugin.v3.Init.Request\x1a#.cloudquery.plugin.v3.Init.Response\x12^\n\tGetTables\x12\'.cloudquery.plugin.v3.GetTables.Request\x1a(.cloudquery.plugin.v3.GetTables.Response\x12Q\n\x04Sync\x12\".cloudquery.plugin.v3.Sync.Request\x1a#.cloudquery.plugin.v3.Sync.Response0\x01\x12Q\n\x04Read\x12\".cloudquery.plugin.v3.Read.Request\x1a#.cloudquery.plugin.v3.Read.Response0\x01\x12T\n\x05Write\x12#.cloudquery.plugin.v3.Write.Request\x1a$.cloudquery.plugin.v3.Write.Response(\x01\x12\x62\n\tTransform\x12\'.cloudquery.plugin.v3.Transform.Request\x1a(.cloudquery.plugin.v3.Transform.Response(\x01\x30\x01\x12p\n\x0fTransformSchema\x12-.cloudquery.plugin.v3.TransformSchema.Request\x1a..cloudquery.plugin.v3.TransformSchema.Response\x12R\n\x05\x43lose\x12#.cloudquery.plugin.v3.Close.Request\x1a$.cloudquery.plugin.v3.Close.Response\x12m\n\x0eTestConnection\x12,.cloudquery.plugin.v3.TestConnection.Request\x1a-.cloudquery.plugin.v3.TestConnection.ResponseBS\n\x17io.cloudquery.plugin.v3P\x01Z6github.com/cloudquery/plugin-pb-go/pb/plugin/v3;pluginb\x06proto3')
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'cloudquery.plugin_v3.plugin_pb2', _globals)
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'\n\027io.cloudquery.plugin.v3P\001Z6github.com/cloudquery/plugin-pb-go/pb/plugin/v3;plugin'
_globals['_WRITE_MESSAGEDELETESTALE'].fields_by_name['table']._loaded_options = None
_globals['_WRITE_MESSAGEDELETESTALE'].fields_by_name['table']._serialized_options = b'\030\001'
_globals['_GETNAME']._serialized_start=92
_globals['_GETNAME']._serialized_end=138
_globals['_GETNAME_REQUEST']._serialized_start=103
_globals['_GETNAME_REQUEST']._serialized_end=112
_globals['_GETNAME_RESPONSE']._serialized_start=114
_globals['_GETNAME_RESPONSE']._serialized_end=138
_globals['_GETVERSION']._serialized_start=140
_globals['_GETVERSION']._serialized_end=192
_globals['_GETVERSION_REQUEST']._serialized_start=103
_globals['_GETVERSION_REQUEST']._serialized_end=112
_globals['_GETVERSION_RESPONSE']._serialized_start=165
_globals['_GETVERSION_RESPONSE']._serialized_end=192
_globals['_GETSPECSCHEMA']._serialized_start=194
_globals['_GETSPECSCHEMA']._serialized_end=274
_globals['_GETSPECSCHEMA_REQUEST']._serialized_start=103
_globals['_GETSPECSCHEMA_REQUEST']._serialized_end=112
_globals['_GETSPECSCHEMA_RESPONSE']._serialized_start=222
_globals['_GETSPECSCHEMA_RESPONSE']._serialized_end=274
_globals['_INIT']._serialized_start=276
_globals['_INIT']._serialized_end=365
_globals['_INIT_REQUEST']._serialized_start=284
_globals['_INIT_REQUEST']._serialized_end=353
_globals['_INIT_RESPONSE']._serialized_start=114
_globals['_INIT_RESPONSE']._serialized_end=124
_globals['_GETTABLES']._serialized_start=367
_globals['_GETTABLES']._serialized_end=485
_globals['_GETTABLES_REQUEST']._serialized_start=380
_globals['_GETTABLES_REQUEST']._serialized_end=457
_globals['_GETTABLES_RESPONSE']._serialized_start=459
_globals['_GETTABLES_RESPONSE']._serialized_end=485
_globals['_SYNC']._serialized_start=488
_globals['_SYNC']._serialized_end=1434
_globals['_SYNC_MESSAGEINSERT']._serialized_start=496
_globals['_SYNC_MESSAGEINSERT']._serialized_end=527
_globals['_SYNC_MESSAGEMIGRATETABLE']._serialized_start=529
_globals['_SYNC_MESSAGEMIGRATETABLE']._serialized_end=565
_globals['_SYNC_MESSAGEDELETERECORD']._serialized_start=568
_globals['_SYNC_MESSAGEDELETERECORD']._serialized_end=732
_globals['_SYNC_MESSAGEERROR']._serialized_start=734
_globals['_SYNC_MESSAGEERROR']._serialized_end=783
_globals['_SYNC_BACKENDOPTIONS']._serialized_start=785
_globals['_SYNC_BACKENDOPTIONS']._serialized_end=841
_globals['_SYNC_REQUEST']._serialized_start=844
_globals['_SYNC_REQUEST']._serialized_end=1146
_globals['_SYNC_REQUEST_SHARD']._serialized_start=1101
_globals['_SYNC_REQUEST_SHARD']._serialized_end=1136
_globals['_SYNC_RESPONSE']._serialized_start=1149
_globals['_SYNC_RESPONSE']._serialized_end=1434
_globals['_READ']._serialized_start=1436
_globals['_READ']._serialized_end=1496
_globals['_READ_REQUEST']._serialized_start=1444
_globals['_READ_REQUEST']._serialized_end=1468
_globals['_READ_RESPONSE']._serialized_start=1470
_globals['_READ_RESPONSE']._serialized_end=1496
_globals['_TABLERELATION']._serialized_start=1498
_globals['_TABLERELATION']._serialized_end=1555
_globals['_PREDICATE']._serialized_start=1557
_globals['_PREDICATE']._serialized_end=1680
_globals['_PREDICATE_OPERATOR']._serialized_start=1662
_globals['_PREDICATE_OPERATOR']._serialized_end=1680
_globals['_PREDICATESGROUP']._serialized_start=1683
_globals['_PREDICATESGROUP']._serialized_end=1861
_globals['_PREDICATESGROUP_GROUPINGTYPE']._serialized_start=1830
_globals['_PREDICATESGROUP_GROUPINGTYPE']._serialized_end=1861
_globals['_WRITE']._serialized_start=1864
_globals['_WRITE']._serialized_end=2571
_globals['_WRITE_MESSAGEMIGRATETABLE']._serialized_start=1873
_globals['_WRITE_MESSAGEMIGRATETABLE']._serialized_end=1932
_globals['_WRITE_MESSAGEINSERT']._serialized_start=496
_globals['_WRITE_MESSAGEINSERT']._serialized_end=527
_globals['_WRITE_MESSAGEDELETESTALE']._serialized_start=1967
_globals['_WRITE_MESSAGEDELETESTALE']._serialized_end=2094
_globals['_WRITE_MESSAGEDELETERECORD']._serialized_start=568
_globals['_WRITE_MESSAGEDELETERECORD']._serialized_end=732
_globals['_WRITE_REQUEST']._serialized_start=2264
_globals['_WRITE_REQUEST']._serialized_end=2559
_globals['_WRITE_RESPONSE']._serialized_start=114
_globals['_WRITE_RESPONSE']._serialized_end=124
_globals['_TRANSFORM']._serialized_start=2573
_globals['_TRANSFORM']._serialized_end=2639
_globals['_TRANSFORM_REQUEST']._serialized_start=2586
_globals['_TRANSFORM_REQUEST']._serialized_end=2611
_globals['_TRANSFORM_RESPONSE']._serialized_start=1470
_globals['_TRANSFORM_RESPONSE']._serialized_end=1496
_globals['_TRANSFORMSCHEMA']._serialized_start=2641
_globals['_TRANSFORMSCHEMA']._serialized_end=2713
_globals['_TRANSFORMSCHEMA_REQUEST']._serialized_start=2660
_globals['_TRANSFORMSCHEMA_REQUEST']._serialized_end=2685
_globals['_TRANSFORMSCHEMA_RESPONSE']._serialized_start=2687
_globals['_TRANSFORMSCHEMA_RESPONSE']._serialized_end=2713
_globals['_CLOSE']._serialized_start=2715
_globals['_CLOSE']._serialized_end=2745
_globals['_CLOSE_REQUEST']._serialized_start=103
_globals['_CLOSE_REQUEST']._serialized_end=112
_globals['_CLOSE_RESPONSE']._serialized_start=114
_globals['_CLOSE_RESPONSE']._serialized_end=124
_globals['_TESTCONNECTION']._serialized_start=2747
_globals['_TESTCONNECTION']._serialized_end=2868
_globals['_TESTCONNECTION_REQUEST']._serialized_start=284
_globals['_TESTCONNECTION_REQUEST']._serialized_end=307
_globals['_TESTCONNECTION_RESPONSE']._serialized_start=2790
_globals['_TESTCONNECTION_RESPONSE']._serialized_end=2868
_globals['_PLUGIN']._serialized_start=2871
_globals['_PLUGIN']._serialized_end=4014
# @@protoc_insertion_point(module_scope)