fix: Generate Python Code from plugin-pb (#28)

This PR was created by a scheduled workflow to regenerate the Python code from `plugin-pb`.

Author: cq-bot

cloudquery/plugin_v3/plugin_pb2.py

@@ -1,5 +1,6 @@
 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
@@ -74,6 +75,15 @@ class Sync(_message.Message):
         TABLE_FIELD_NUMBER: _ClassVar[int]
         table: bytes
         def __init__(self, table: _Optional[bytes] = ...) -> None: ...
+    class MessageDeleteRecord(_message.Message):
+        __slots__ = ["table_name", "where_clause", "table_relations"]
+        TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
+        WHERE_CLAUSE_FIELD_NUMBER: _ClassVar[int]
+        TABLE_RELATIONS_FIELD_NUMBER: _ClassVar[int]
+        table_name: str
+        where_clause: _containers.RepeatedCompositeFieldContainer[PredicatesGroup]
+        table_relations: _containers.RepeatedCompositeFieldContainer[TableRelation]
+        def __init__(self, table_name: _Optional[str] = ..., where_clause: _Optional[_Iterable[_Union[PredicatesGroup, _Mapping]]] = ..., table_relations: _Optional[_Iterable[_Union[TableRelation, _Mapping]]] = ...) -> None: ...
     class BackendOptions(_message.Message):
         __slots__ = ["table_name", "connection"]
         TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
@@ -95,12 +105,14 @@ class Sync(_message.Message):
         backend: Sync.BackendOptions
         def __init__(self, tables: _Optional[_Iterable[str]] = ..., skip_tables: _Optional[_Iterable[str]] = ..., skip_dependent_tables: bool = ..., deterministic_cq_id: bool = ..., backend: _Optional[_Union[Sync.BackendOptions, _Mapping]] = ...) -> None: ...
     class Response(_message.Message):
-        __slots__ = ["migrate_table", "insert"]
+        __slots__ = ["migrate_table", "insert", "delete_record"]
         MIGRATE_TABLE_FIELD_NUMBER: _ClassVar[int]
         INSERT_FIELD_NUMBER: _ClassVar[int]
+        DELETE_RECORD_FIELD_NUMBER: _ClassVar[int]
         migrate_table: Sync.MessageMigrateTable
         insert: Sync.MessageInsert
-        def __init__(self, migrate_table: _Optional[_Union[Sync.MessageMigrateTable, _Mapping]] = ..., insert: _Optional[_Union[Sync.MessageInsert, _Mapping]] = ...) -> None: ...
+        delete_record: Sync.MessageDeleteRecord
+        def __init__(self, migrate_table: _Optional[_Union[Sync.MessageMigrateTable, _Mapping]] = ..., insert: _Optional[_Union[Sync.MessageInsert, _Mapping]] = ..., delete_record: _Optional[_Union[Sync.MessageDeleteRecord, _Mapping]] = ...) -> None: ...
     def __init__(self) -> None: ...
 
 class Read(_message.Message):
@@ -117,6 +129,42 @@ class Read(_message.Message):
         def __init__(self, record: _Optional[bytes] = ...) -> None: ...
     def __init__(self) -> None: ...
 
+class TableRelation(_message.Message):
+    __slots__ = ["table_name", "parent_table"]
+    TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
+    PARENT_TABLE_FIELD_NUMBER: _ClassVar[int]
+    table_name: str
+    parent_table: str
+    def __init__(self, table_name: _Optional[str] = ..., parent_table: _Optional[str] = ...) -> None: ...
+
+class Predicate(_message.Message):
+    __slots__ = ["operator", "column", "record"]
+    class Operator(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
+        __slots__ = []
+        EQ: _ClassVar[Predicate.Operator]
+    EQ: Predicate.Operator
+    OPERATOR_FIELD_NUMBER: _ClassVar[int]
+    COLUMN_FIELD_NUMBER: _ClassVar[int]
+    RECORD_FIELD_NUMBER: _ClassVar[int]
+    operator: Predicate.Operator
+    column: str
+    record: bytes
+    def __init__(self, operator: _Optional[_Union[Predicate.Operator, str]] = ..., column: _Optional[str] = ..., record: _Optional[bytes] = ...) -> None: ...
+
+class PredicatesGroup(_message.Message):
+    __slots__ = ["grouping_type", "predicates"]
+    class GroupingType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
+        __slots__ = []
+        AND: _ClassVar[PredicatesGroup.GroupingType]
+        OR: _ClassVar[PredicatesGroup.GroupingType]
+    AND: PredicatesGroup.GroupingType
+    OR: PredicatesGroup.GroupingType
+    GROUPING_TYPE_FIELD_NUMBER: _ClassVar[int]
+    PREDICATES_FIELD_NUMBER: _ClassVar[int]
+    grouping_type: PredicatesGroup.GroupingType
+    predicates: _containers.RepeatedCompositeFieldContainer[Predicate]
+    def __init__(self, grouping_type: _Optional[_Union[PredicatesGroup.GroupingType, str]] = ..., predicates: _Optional[_Iterable[_Union[Predicate, _Mapping]]] = ...) -> None: ...
+
 class Write(_message.Message):
     __slots__ = []
     class MessageMigrateTable(_message.Message):
@@ -142,15 +190,26 @@ class Write(_message.Message):
         sync_time: _timestamp_pb2.Timestamp
         table_name: str
         def __init__(self, table: _Optional[bytes] = ..., source_name: _Optional[str] = ..., sync_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., table_name: _Optional[str] = ...) -> None: ...
+    class MessageDeleteRecord(_message.Message):
+        __slots__ = ["table_name", "where_clause", "table_relations"]
+        TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
+        WHERE_CLAUSE_FIELD_NUMBER: _ClassVar[int]
+        TABLE_RELATIONS_FIELD_NUMBER: _ClassVar[int]
+        table_name: str
+        where_clause: _containers.RepeatedCompositeFieldContainer[PredicatesGroup]
+        table_relations: _containers.RepeatedCompositeFieldContainer[TableRelation]
+        def __init__(self, table_name: _Optional[str] = ..., where_clause: _Optional[_Iterable[_Union[PredicatesGroup, _Mapping]]] = ..., table_relations: _Optional[_Iterable[_Union[TableRelation, _Mapping]]] = ...) -> None: ...
     class Request(_message.Message):
-        __slots__ = ["migrate_table", "insert", "delete"]
+        __slots__ = ["migrate_table", "insert", "delete", "delete_record"]
         MIGRATE_TABLE_FIELD_NUMBER: _ClassVar[int]
         INSERT_FIELD_NUMBER: _ClassVar[int]
         DELETE_FIELD_NUMBER: _ClassVar[int]
+        DELETE_RECORD_FIELD_NUMBER: _ClassVar[int]
         migrate_table: Write.MessageMigrateTable
         insert: Write.MessageInsert
         delete: Write.MessageDeleteStale
-        def __init__(self, migrate_table: _Optional[_Union[Write.MessageMigrateTable, _Mapping]] = ..., insert: _Optional[_Union[Write.MessageInsert, _Mapping]] = ..., delete: _Optional[_Union[Write.MessageDeleteStale, _Mapping]] = ...) -> None: ...
+        delete_record: Write.MessageDeleteRecord
+        def __init__(self, migrate_table: _Optional[_Union[Write.MessageMigrateTable, _Mapping]] = ..., insert: _Optional[_Union[Write.MessageInsert, _Mapping]] = ..., delete: _Optional[_Union[Write.MessageDeleteStale, _Mapping]] = ..., delete_record: _Optional[_Union[Write.MessageDeleteRecord, _Mapping]] = ...) -> None: ...
     class Response(_message.Message):
         __slots__ = []
         def __init__(self) -> None: ...