Skip to content

Commit 801b32a

Browse files
feat: kv.watch support (#26)
This commit adds support for the `Database::watch` method in both SQLite and remote backends, and the `/watch` method in the KV Connect protocol. --------- Co-authored-by: losfair <zhy20000919@hotmail.com>
1 parent 061ffbd commit 801b32a

File tree

16 files changed

+796
-280
lines changed

16 files changed

+796
-280
lines changed

Cargo.lock

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

Cargo.toml

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,14 +15,13 @@ denokv_remote = { version = "0.4.0", path = "./remote" }
1515
denokv_timemachine = { version = "0.2.0", path = "./timemachine" }
1616

1717
anyhow = "1"
18+
async-stream = "0.3"
1819
async-trait = "0.1"
1920
aws-config = "0.55.3"
20-
aws-credential-types = "0.55.3"
2121
aws-sdk-s3 = "0.28.0"
2222
aws-smithy-async = "0.55.3"
2323
aws-smithy-client = "0.55.3"
2424
aws-smithy-types = "0.55.3"
25-
aws-types = "0.55.3"
2625
axum = { version = "0.6", features = ["macros", "http2"] }
2726
bytes = "1"
2827
chrono = { version = "0.4", default-features = false, features = ["std", "serde"] }
@@ -38,15 +37,13 @@ num-bigint = "0.4"
3837
prost = "0.11"
3938
prost-build = "0.11"
4039
rand = "0.8.5"
41-
reqwest = { version = "0.11", default-features = false, features = ["json"] }
40+
reqwest = { version = "0.11", default-features = false, features = ["json", "stream"] }
4241
rusqlite = "0.29.0"
4342
serde = { version = "1", features = ["derive"] }
4443
serde_json = "1.0.107"
4544
tempfile = "3"
4645
thiserror = "1"
4746
tokio = { version = "1.33.0", features = ["full"] }
48-
tracing = "0.1"
49-
tracing-futures = "0.2"
50-
tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
47+
tokio-util = "0.7"
5148
url = "2"
5249
uuid = { version = "1.4.1", features = ["v4", "serde"] }

0 commit comments

Comments
 (0)