mirror of
https://github.com/meilisearch/meilisearch.git
synced 2024-11-23 10:37:41 +08:00
integrate the search batcher in the tick
This commit is contained in:
parent
d3d76bf97a
commit
35ffd0ec3a
@ -143,7 +143,17 @@ mod segment {
|
|||||||
})
|
})
|
||||||
.await;
|
.await;
|
||||||
}
|
}
|
||||||
|
let get_search = std::mem::take(&mut *self.get_search_batcher.lock().await)
|
||||||
|
.into_event(self.user.clone(), "Documents Searched GET".to_string());
|
||||||
|
let post_search = std::mem::take(&mut *self.post_search_batcher.lock().await)
|
||||||
|
.into_event(self.user.clone(), "Documents Searched POST".to_string());
|
||||||
|
// keep the lock on the batcher just for these three operations
|
||||||
|
{
|
||||||
|
let mut batcher = self.batcher.lock().await;
|
||||||
|
let _ = batcher.push(get_search).await;
|
||||||
|
let _ = batcher.push(post_search).await;
|
||||||
let _ = self.batcher.lock().await.flush().await;
|
let _ = self.batcher.lock().await.flush().await;
|
||||||
|
}
|
||||||
println!("ANALYTICS: sent the batch");
|
println!("ANALYTICS: sent the batch");
|
||||||
tokio::time::sleep(Duration::from_secs(60 * 5)).await; // 5 minutes
|
tokio::time::sleep(Duration::from_secs(60 * 5)).await; // 5 minutes
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user