mirror of
https://github.com/meilisearch/MeiliSearch
synced 2024-06-01 10:28:02 +02:00
a30e02c18c
implements: https://github.com/meilisearch/specifications/blob/develop/text/0060-refashion-updates-apis.md linked PR: - #1889 - #1891 - #1892 - #1902 - #1906 - #1911 - #1914 - #1915 - #1916 - #1918 - #1924 - #1925 - #1926 - #1930 - #1936 - #1937 - #1942 - #1944 - #1945 - #1946 - #1947 - #1950 - #1951 - #1957 - #1959 - #1960 - #1961 - #1962 - #1964 - https://github.com/meilisearch/milli/pull/414 - https://github.com/meilisearch/milli/pull/409 - https://github.com/meilisearch/milli/pull/406 - https://github.com/meilisearch/milli/pull/418 - close #1687 - close #1786 - close #1940 - close #1948 - close #1949 - close #1932 - close #1956
27 lines
819 B
Rust
27 lines
819 B
Rust
use tokio::sync::{mpsc, oneshot};
|
|
|
|
use super::error::Result;
|
|
use super::{DumpActorHandle, DumpInfo, DumpMsg};
|
|
|
|
#[derive(Clone)]
|
|
pub struct DumpActorHandleImpl {
|
|
pub sender: mpsc::Sender<DumpMsg>,
|
|
}
|
|
|
|
#[async_trait::async_trait]
|
|
impl DumpActorHandle for DumpActorHandleImpl {
|
|
async fn create_dump(&self) -> Result<DumpInfo> {
|
|
let (ret, receiver) = oneshot::channel();
|
|
let msg = DumpMsg::CreateDump { ret };
|
|
let _ = self.sender.send(msg).await;
|
|
receiver.await.expect("IndexActor has been killed")
|
|
}
|
|
|
|
async fn dump_info(&self, uid: String) -> Result<DumpInfo> {
|
|
let (ret, receiver) = oneshot::channel();
|
|
let msg = DumpMsg::DumpInfo { ret, uid };
|
|
let _ = self.sender.send(msg).await;
|
|
receiver.await.expect("IndexActor has been killed")
|
|
}
|
|
}
|