searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-02-06 02:23:27 +01:00
Code Issues Releases Wiki Activity

Send the OSS analytics once per day instead of once per hour

Browse Source
This commit is contained in:
Tamo 2025-02-04 15:39:00 +01:00
parent 796acd1aee
commit 61e8cfd4bc
No known key found for this signature in database
GPG Key ID: 20CD8020AFA88D69
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
crates/meilisearch/src/analytics/segment_analytics.rs
View File

@ -31,6 +31,7 @@ use crate::routes::{create_all_stats, Stats};
use crate::Opt; use crate::Opt;
const ANALYTICS_HEADER: &str = "X-Meilisearch-Client"; const ANALYTICS_HEADER: &str = "X-Meilisearch-Client";
const MEILI_SERVER_PROVIDER: &str = "MEILI_SERVER_PROVIDER";
/// Write the instance-uid in the `data.ms` and in `~/.config/MeiliSearch/path-to-db-instance-uid`. Ignore the errors. /// Write the instance-uid in the `data.ms` and in `~/.config/MeiliSearch/path-to-db-instance-uid`. Ignore the errors.
fn write_user_id(db_path: &Path, user_id: &InstanceUid) { fn write_user_id(db_path: &Path, user_id: &InstanceUid) {
@ -357,7 +358,7 @@ impl Segment {
"cores": sys.cpus().len(), "cores": sys.cpus().len(),
"ram_size": sys.total_memory(), "ram_size": sys.total_memory(),
"disk_size": disks.iter().map(|disk| disk.total_space()).max(), "disk_size": disks.iter().map(|disk| disk.total_space()).max(),
"server_provider": std::env::var("MEILI_SERVER_PROVIDER").ok(), "server_provider": std::env::var(MEILI_SERVER_PROVIDER).ok(),
}) })
}); });
let number_of_documents = let number_of_documents =
@ -380,10 +381,18 @@ impl Segment {
index_scheduler: Arc<IndexScheduler>, index_scheduler: Arc<IndexScheduler>,
auth_controller: Arc<AuthController>, auth_controller: Arc<AuthController>,
) { ) {
const INTERVAL: Duration = Duration::from_secs(60 * 60); // one hour let interval: Duration = match std::env::var(MEILI_SERVER_PROVIDER) {
// The first batch must be sent after one hour. Ok(provider) if provider.starts_with("meili_cloud:") => {
Duration::from_secs(60 * 60) // one hour
}
_ => {
// We're an open source instance
Duration::from_secs(60 * 60 * 24) // one day
}
};
let mut interval = let mut interval =
tokio::time::interval_at(tokio::time::Instant::now() + INTERVAL, INTERVAL); tokio::time::interval_at(tokio::time::Instant::now() + interval, interval);
loop { loop {
select! { select! {