@cloudquery/plugin-pb-javascript - npm Package Compare versions

Comparing version 0.0.9 to 0.0.10

dist/protos/plugin/v3/plugin.d.ts

@@ -256,2 +256,41 @@ /// <reference types="node" />
         }
+        class MessageDeleteRecord extends pb_1.Message {
+            #private;
+            constructor(data?: any[] | {
+                table_name?: string;
+                where_clause?: PredicatesGroup[];
+                table_relations?: TableRelation[];
+            });
+            get table_name(): string;
+            set table_name(value: string);
+            get where_clause(): PredicatesGroup[];
+            set where_clause(value: PredicatesGroup[]);
+            get table_relations(): TableRelation[];
+            set table_relations(value: TableRelation[]);
+            static fromObject(data: {
+                table_name?: string;
+                where_clause?: ReturnType<typeof PredicatesGroup.prototype.toObject>[];
+                table_relations?: ReturnType<typeof TableRelation.prototype.toObject>[];
+            }): MessageDeleteRecord;
+            toObject(): {
+                table_name?: string | undefined;
+                where_clause?: {
+                    grouping_type?: PredicatesGroup.GroupingType | undefined;
+                    predicates?: {
+                        operator?: Predicate.Operator | undefined;
+                        column?: string | undefined;
+                        record?: Uint8Array | undefined;
+                    }[] | undefined;
+                }[] | undefined;
+                table_relations?: {
+                    table_name?: string | undefined;
+                    parent_table?: string | undefined;
+                }[] | undefined;
+            };
+            serialize(): Uint8Array;
+            serialize(w: pb_1.BinaryWriter): void;
+            static deserialize(bytes: Uint8Array | pb_1.BinaryReader): MessageDeleteRecord;
+            serializeBinary(): Uint8Array;
+            static deserializeBinary(bytes: Uint8Array): MessageDeleteRecord;
+        }
         class BackendOptions extends pb_1.Message {
@@ -329,5 +368,11 @@ #private;
                 insert?: never;
+                delete_record?: never;
             } | {
                 migrate_table?: never;
                 insert?: Sync.MessageInsert;
+                delete_record?: never;
+            } | {
+                migrate_table?: never;
+                insert?: never;
+                delete_record?: Sync.MessageDeleteRecord;
             }))));
@@ -340,6 +385,10 @@ get migrate_table(): Sync.MessageMigrateTable;
             get has_insert(): boolean;
-            get message(): "migrate_table" | "insert" | "none";
+            get delete_record(): Sync.MessageDeleteRecord;
+            set delete_record(value: Sync.MessageDeleteRecord);
+            get has_delete_record(): boolean;
+            get message(): "migrate_table" | "insert" | "delete_record" | "none";
             static fromObject(data: {
                 migrate_table?: ReturnType<typeof Sync.MessageMigrateTable.prototype.toObject>;
                 insert?: ReturnType<typeof Sync.MessageInsert.prototype.toObject>;
+                delete_record?: ReturnType<typeof Sync.MessageDeleteRecord.prototype.toObject>;
             }): Response;
@@ -353,2 +402,17 @@ toObject(): {
                 } | undefined;
+                delete_record?: {
+                    table_name?: string | undefined;
+                    where_clause?: {
+                        grouping_type?: PredicatesGroup.GroupingType | undefined;
+                        predicates?: {
+                            operator?: Predicate.Operator | undefined;
+                            column?: string | undefined;
+                            record?: Uint8Array | undefined;
+                        }[] | undefined;
+                    }[] | undefined;
+                    table_relations?: {
+                        table_name?: string | undefined;
+                        parent_table?: string | undefined;
+                    }[] | undefined;
+                } | undefined;
             };
@@ -413,2 +477,94 @@ serialize(): Uint8Array;
     }
+    export class TableRelation extends pb_1.Message {
+        #private;
+        constructor(data?: any[] | {
+            table_name?: string;
+            parent_table?: string;
+        });
+        get table_name(): string;
+        set table_name(value: string);
+        get parent_table(): string;
+        set parent_table(value: string);
+        static fromObject(data: {
+            table_name?: string;
+            parent_table?: string;
+        }): TableRelation;
+        toObject(): {
+            table_name?: string | undefined;
+            parent_table?: string | undefined;
+        };
+        serialize(): Uint8Array;
+        serialize(w: pb_1.BinaryWriter): void;
+        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): TableRelation;
+        serializeBinary(): Uint8Array;
+        static deserializeBinary(bytes: Uint8Array): TableRelation;
+    }
+    export class Predicate extends pb_1.Message {
+        #private;
+        constructor(data?: any[] | {
+            operator?: Predicate.Operator;
+            column?: string;
+            record?: Uint8Array;
+        });
+        get operator(): Predicate.Operator;
+        set operator(value: Predicate.Operator);
+        get column(): string;
+        set column(value: string);
+        get record(): Uint8Array;
+        set record(value: Uint8Array);
+        static fromObject(data: {
+            operator?: Predicate.Operator;
+            column?: string;
+            record?: Uint8Array;
+        }): Predicate;
+        toObject(): {
+            operator?: Predicate.Operator | undefined;
+            column?: string | undefined;
+            record?: Uint8Array | undefined;
+        };
+        serialize(): Uint8Array;
+        serialize(w: pb_1.BinaryWriter): void;
+        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Predicate;
+        serializeBinary(): Uint8Array;
+        static deserializeBinary(bytes: Uint8Array): Predicate;
+    }
+    export namespace Predicate {
+        enum Operator {
+            EQ = 0
+        }
+    }
+    export class PredicatesGroup extends pb_1.Message {
+        #private;
+        constructor(data?: any[] | {
+            grouping_type?: PredicatesGroup.GroupingType;
+            predicates?: Predicate[];
+        });
+        get grouping_type(): PredicatesGroup.GroupingType;
+        set grouping_type(value: PredicatesGroup.GroupingType);
+        get predicates(): Predicate[];
+        set predicates(value: Predicate[]);
+        static fromObject(data: {
+            grouping_type?: PredicatesGroup.GroupingType;
+            predicates?: ReturnType<typeof Predicate.prototype.toObject>[];
+        }): PredicatesGroup;
+        toObject(): {
+            grouping_type?: PredicatesGroup.GroupingType | undefined;
+            predicates?: {
+                operator?: Predicate.Operator | undefined;
+                column?: string | undefined;
+                record?: Uint8Array | undefined;
+            }[] | undefined;
+        };
+        serialize(): Uint8Array;
+        serialize(w: pb_1.BinaryWriter): void;
+        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): PredicatesGroup;
+        serializeBinary(): Uint8Array;
+        static deserializeBinary(bytes: Uint8Array): PredicatesGroup;
+    }
+    export namespace PredicatesGroup {
+        enum GroupingType {
+            AND = 0,
+            OR = 1
+        }
+    }
     export class Write extends pb_1.Message {
@@ -510,2 +666,41 @@ #private;
         }
+        class MessageDeleteRecord extends pb_1.Message {
+            #private;
+            constructor(data?: any[] | {
+                table_name?: string;
+                where_clause?: PredicatesGroup[];
+                table_relations?: TableRelation[];
+            });
+            get table_name(): string;
+            set table_name(value: string);
+            get where_clause(): PredicatesGroup[];
+            set where_clause(value: PredicatesGroup[]);
+            get table_relations(): TableRelation[];
+            set table_relations(value: TableRelation[]);
+            static fromObject(data: {
+                table_name?: string;
+                where_clause?: ReturnType<typeof PredicatesGroup.prototype.toObject>[];
+                table_relations?: ReturnType<typeof TableRelation.prototype.toObject>[];
+            }): MessageDeleteRecord;
+            toObject(): {
+                table_name?: string | undefined;
+                where_clause?: {
+                    grouping_type?: PredicatesGroup.GroupingType | undefined;
+                    predicates?: {
+                        operator?: Predicate.Operator | undefined;
+                        column?: string | undefined;
+                        record?: Uint8Array | undefined;
+                    }[] | undefined;
+                }[] | undefined;
+                table_relations?: {
+                    table_name?: string | undefined;
+                    parent_table?: string | undefined;
+                }[] | undefined;
+            };
+            serialize(): Uint8Array;
+            serialize(w: pb_1.BinaryWriter): void;
+            static deserialize(bytes: Uint8Array | pb_1.BinaryReader): MessageDeleteRecord;
+            serializeBinary(): Uint8Array;
+            static deserializeBinary(bytes: Uint8Array): MessageDeleteRecord;
+        }
         class Request extends pb_1.Message {
@@ -517,2 +712,3 @@ #private;
                 delete?: never;
+                delete_record?: never;
             } | {
@@ -522,2 +718,3 @@ migrate_table?: never;
                 delete?: never;
+                delete_record?: never;
             } | {
@@ -527,2 +724,8 @@ migrate_table?: never;
                 delete?: Write.MessageDeleteStale;
+                delete_record?: never;
+            } | {
+                migrate_table?: never;
+                insert?: never;
+                delete?: never;
+                delete_record?: Write.MessageDeleteRecord;
             }))));
@@ -538,3 +741,6 @@ get migrate_table(): Write.MessageMigrateTable;
             get has_delete(): boolean;
-            get message(): "migrate_table" | "insert" | "none" | "delete";
+            get delete_record(): Write.MessageDeleteRecord;
+            set delete_record(value: Write.MessageDeleteRecord);
+            get has_delete_record(): boolean;
+            get message(): "migrate_table" | "insert" | "delete_record" | "none" | "delete";
             static fromObject(data: {
@@ -544,2 +750,3 @@ migrate_table?: ReturnType<typeof Write.MessageMigrateTable.prototype.toObject>;
                 delete?: ReturnType<typeof Write.MessageDeleteStale.prototype.toObject>;
+                delete_record?: ReturnType<typeof Write.MessageDeleteRecord.prototype.toObject>;
             }): Request;
@@ -563,2 +770,17 @@ toObject(): {
                 } | undefined;
+                delete_record?: {
+                    table_name?: string | undefined;
+                    where_clause?: {
+                        grouping_type?: PredicatesGroup.GroupingType | undefined;
+                        predicates?: {
+                            operator?: Predicate.Operator | undefined;
+                            column?: string | undefined;
+                            record?: Uint8Array | undefined;
+                        }[] | undefined;
+                    }[] | undefined;
+                    table_relations?: {
+                        table_name?: string | undefined;
+                        parent_table?: string | undefined;
+                    }[] | undefined;
+                } | undefined;
             };
@@ -565,0 +787,0 @@ serialize(): Uint8Array;

package.json

 {
   "name": "@cloudquery/plugin-pb-javascript",
-  "version": "0.0.9",
+  "version": "0.0.10",
   "files": [
@@ -5,0 +5,0 @@ "dist"

No alert changes

Improved metrics

Total package byte prevSize

210390

21.53%

Lines of code

3986

23.1%

No dependency changes