diff options
| author | Alex <alex@adnab.me> | 2023-01-26 16:19:04 +0000 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2023-01-26 16:19:04 +0000 |
| commit | 246f7468cd18c8ef4f3c0c4c209853cd2500cc76 (patch) | |
| tree | 6e5f9ddd2159ba5396cc441a82b8240c4306323f /src/api/k2v/api_server.rs | |
| parent | 611792ddcf86f0a728e22abaa6e172d3679d5ca6 (diff) | |
| parent | 1dff62564fdda392a97986dca55232f30a1f4234 (diff) | |
| download | garage-246f7468cd18c8ef4f3c0c4c209853cd2500cc76.tar.gz garage-246f7468cd18c8ef4f3c0c4c209853cd2500cc76.zip | |
Merge pull request 'K2V PollRange, version 2' (#471) from k2v-watch-range-2 into main
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/471
Diffstat (limited to 'src/api/k2v/api_server.rs')
| -rw-r--r-- | src/api/k2v/api_server.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/api/k2v/api_server.rs b/src/api/k2v/api_server.rs index 084867b5..bb85b2e7 100644 --- a/src/api/k2v/api_server.rs +++ b/src/api/k2v/api_server.rs @@ -164,6 +164,9 @@ impl ApiHandler for K2VApiServer { Endpoint::InsertBatch {} => handle_insert_batch(garage, bucket_id, req).await, Endpoint::ReadBatch {} => handle_read_batch(garage, bucket_id, req).await, Endpoint::DeleteBatch {} => handle_delete_batch(garage, bucket_id, req).await, + Endpoint::PollRange { partition_key } => { + handle_poll_range(garage, bucket_id, &partition_key, req).await + } Endpoint::Options => unreachable!(), }; |