diff options
| author | Luca Casonato <hello@lcas.dev> | 2023-12-05 14:21:46 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-12-05 21:21:46 +0800 |
| commit | 74e39a927c63e789fec1c8f1817812920079229d (patch) | |
| tree | fa38e32c700865b25710f491d551086733d58d5f /test_util/src/lib.rs | |
| parent | a24d3e8763bc48b69936db9231efb76766914303 (diff) | |
feat(unstable): kv.watch() (#21147)
This commit adds support for a new `kv.watch()` method that allows
watching for changes to a key-value pair. This is useful for cases
where you want to be notified when a key-value pair changes, but
don't want to have to poll for changes.
---------
Co-authored-by: losfair <zhy20000919@hotmail.com>
Diffstat (limited to 'test_util/src/lib.rs')
| -rw-r--r-- | test_util/src/lib.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/test_util/src/lib.rs b/test_util/src/lib.rs index 8e5742636..6700a49f1 100644 --- a/test_util/src/lib.rs +++ b/test_util/src/lib.rs @@ -11,6 +11,7 @@ use denokv_proto::datapath::AtomicWriteStatus; use denokv_proto::datapath::ReadRangeOutput; use denokv_proto::datapath::SnapshotRead; use denokv_proto::datapath::SnapshotReadOutput; +use denokv_proto::datapath::SnapshotReadStatus; use fastwebsockets::FragmentCollector; use fastwebsockets::Frame; use fastwebsockets::OpCode; @@ -1226,6 +1227,7 @@ async fn main_server( .collect(), read_disabled: false, read_is_strongly_consistent: true, + status: SnapshotReadStatus::SrSuccess.into(), } .encode_to_vec(), )) |