snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-25 19:45:05 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

simplify the search batcher

Browse Source
This commit is contained in:
Tamo 2021-10-25 17:14:07 +02:00 committed by marin postma
parent 6591acfdfa
commit f9b14ca149
No known key found for this signature in database
GPG Key ID: 6088B7721C3E39F9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
meilisearch-http/src/analytics.rs
View File

@ -205,7 +205,7 @@ mod segment {
fn start_search( fn start_search(
&'static self, &'static self,
getter: impl Fn(&'static Self) -> &'static Mutex<SearchBatcher> + Send + Sync + 'static, batcher: &'static Mutex<SearchBatcher>,
query: &SearchQuery, query: &SearchQuery,
request: &HttpRequest, request: &HttpRequest,
) { ) {
@ -262,7 +262,7 @@ mod segment {
- 1; - 1;
println!("Batching a search"); println!("Batching a search");
let mut search_batcher = getter(self).lock().await; let mut search_batcher = batcher.lock().await;
user_agent.into_iter().for_each(|ua| { user_agent.into_iter().for_each(|ua| {
search_batcher.user_agents.insert(ua); search_batcher.user_agents.insert(ua);
}); });
@ -347,7 +347,7 @@ mod segment {
} }
fn start_get_search(&'static self, query: &SearchQuery, request: &HttpRequest) { fn start_get_search(&'static self, query: &SearchQuery, request: &HttpRequest) {
self.start_search(|s| &s.get_search_batcher, query, request) self.start_search(&self.get_search_batcher, query, request)
} }
fn end_get_search(&'static self, process_time: usize) { fn end_get_search(&'static self, process_time: usize) {
@ -359,7 +359,7 @@ mod segment {
} }
fn start_post_search(&'static self, query: &SearchQuery, request: &HttpRequest) { fn start_post_search(&'static self, query: &SearchQuery, request: &HttpRequest) {
self.start_search(|s| &s.post_search_batcher, query, request) self.start_search(&self.post_search_batcher, query, request)
} }
fn end_post_search(&'static self, process_time: usize) { fn end_post_search(&'static self, process_time: usize) {
@ -500,7 +500,7 @@ mod segment {
} }
impl DocumentsBatcher { impl DocumentsBatcher {
pub fn into_event(mut self, user: &User, event_name: &str) -> Option<Track> { pub fn into_event(self, user: &User, event_name: &str) -> Option<Track> {
if self.updated { if self.updated {
None None
} else { } else {