x-algorithm/candidate-pipeline/source.rs
2026-01-20 02:31:49 +00:00

23 lines
520 B
Rust

use std::any::{Any, type_name_of_val};
use tonic::async_trait;
use crate::util;
#[async_trait]
pub trait Source<Q, C>: Any + Send + Sync
where
Q: Clone + Send + Sync + 'static,
C: Clone + Send + Sync + 'static,
{
/// Decide if this source should run for the given query
fn enable(&self, _query: &Q) -> bool {
true
}
async fn get_candidates(&self, query: &Q) -> Result<Vec<C>, String>;
fn name(&self) -> &'static str {
util::short_type_name(type_name_of_val(self))
}
}