Skip to content

Commit 4a5f9e8

Browse files
erezrokaherezrokah
authored
fix: Implement sync, scheduler, resource encoding (#44)
Fixes #39
1 parent 4c07a3d commit 4a5f9e8

File tree

18 files changed

+400
-61
lines changed

18 files changed

+400
-61
lines changed

‎package-lock.json‎

Lines changed: 125 additions & 27 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎package.json‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,9 +82,13 @@
8282
"@apache-arrow/esnext-esm": "^12.0.1",
8383
"@cloudquery/plugin-pb-javascript": "^0.0.7",
8484
"@types/luxon": "^3.3.1",
85+
"ajv": "^8.12.0",
8586
"boolean": "^3.2.0",
87+
"dot-prop": "^8.0.2",
8688
"luxon": "^3.4.0",
8789
"matcher": "^5.0.0",
90+
"p-map": "^6.0.0",
91+
"p-timeout": "^6.1.2",
8892
"winston": "^3.10.0",
8993
"yargs": "^17.7.2"
9094
}

‎src/grpc/plugin.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import { encodeTables } from '../schema/table.js';
66

77
export class MigrateTable extends pluginV3.cloudquery.plugin.v3.Sync.MessageMigrateTable {}
88
export class SyncRequest extends pluginV3.cloudquery.plugin.v3.Sync.Request {}
9+
export class Insert extends pluginV3.cloudquery.plugin.v3.Sync.MessageInsert {}
910
export class SyncResponse extends pluginV3.cloudquery.plugin.v3.Sync.Response {}
1011
export class ReadRequest extends pluginV3.cloudquery.plugin.v3.Read.Request {}
1112
export class ReadResponse extends pluginV3.cloudquery.plugin.v3.Read.Response {}

0 commit comments

Comments
 (0)