mirror of
https://github.com/qdrant/qdrant.git
synced 2026-08-03 00:20:57 -05:00
317f1e0dbe
* move problems.rs to collection crate * change type on datetime_key expression * extract from expression * check for unindexed fields in formula * clippy * dedup code * Only implement verification for `CollectionQuery` types (#6319) * verify CollectionQuery's Prefetch * remove implementation for REST query * remove implementation for REST query groups * add basic openapi test
21 lines
774 B
Rust
21 lines
774 B
Rust
use std::time::Duration;
|
|
|
|
use collection::events::{CollectionDeletedEvent, IndexCreatedEvent, SlowQueryEvent};
|
|
use collection::problems::unindexed_field;
|
|
use storage::issues_subscribers::UnindexedFieldSubscriber;
|
|
|
|
use crate::settings::Settings;
|
|
|
|
pub fn setup_subscribers(settings: &Settings) {
|
|
settings
|
|
.service
|
|
.slow_query_secs
|
|
.map(|secs| unindexed_field::SLOW_QUERY_THRESHOLD.set(Duration::from_secs_f32(secs)));
|
|
|
|
let unindexed_subscriber = UnindexedFieldSubscriber;
|
|
|
|
issues::broker::add_subscriber::<SlowQueryEvent>(Box::new(unindexed_subscriber));
|
|
issues::broker::add_subscriber::<IndexCreatedEvent>(Box::new(unindexed_subscriber));
|
|
issues::broker::add_subscriber::<CollectionDeletedEvent>(Box::new(unindexed_subscriber));
|
|
}
|