diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-01-10 15:22:25 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-01-10 15:22:25 +0100 |
| commit | b83517d521b1bea7585ce45a803fad373f28225c (patch) | |
| tree | 5562397a39647be8d61a9c870103d15c604e09ad /src/api/k2v/api_server.rs | |
| parent | 57eabe787948ad6c23eae7761d02545c675bf7ff (diff) | |
| download | garage-b83517d521b1bea7585ce45a803fad373f28225c.tar.gz garage-b83517d521b1bea7585ce45a803fad373f28225c.zip | |
Implement PollRange API endpoint
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!(), }; |