Struct KnowledgeRuntime 

pub struct KnowledgeRuntime { /* private fields */ }

Implementations

impl KnowledgeRuntime

pub fn new(result_cache_capacity: usize) -> Self

pub fn install_provider<F>( &self, kind: ProviderKind, datasource_id: DatasourceId, build: F, ) -> KnowledgeResult<Generation>

where F: FnOnce(Generation) -> KnowledgeResult<Arc<dyn ProviderExecutor>>,

pub fn install_provider_named<F>( &self, name: &str, kind: ProviderKind, datasource_id: DatasourceId, build: F, is_default: bool, ) -> KnowledgeResult<Generation>

where F: FnOnce(Generation) -> KnowledgeResult<Arc<dyn ProviderExecutor>>,

安装一个 provider：注册到命名注册表（name -> handle），并在 is_default 时同时设置为默认 provider。共享同一个单调递增 generation 计数器， 保证重载后的结果缓存键不与旧数据冲突。

pub fn configure_result_cache( &self, enabled: bool, capacity: usize, ttl: Duration, )

pub fn configure_redis_cache(&self, global_enabled: bool, capacity: usize)

pub fn current_generation(&self) -> Option<Generation>

pub fn snapshot(&self) -> RuntimeSnapshot

pub fn current_metadata_scope(&self) -> MetadataCacheScope

pub fn current_provider_kind(&self) -> Option<ProviderKind>

pub fn provider_by_name( &self, name: &str, ) -> KnowledgeResult<Arc<ProviderHandle>>

按名称取 provider handle；未找到时返回错误。

pub fn provider_exists(&self, name: &str) -> bool

pub fn provider_names(&self) -> Vec<String>

pub fn prune_named_providers_except(&self, keep: &HashSet<String>)

清理命名注册表中不在 keep 内的过期 provider。仅在成功安装后调用， 中途失败时保留旧状态。

pub fn named_provider_epoch(&self) -> u64

命名 provider 注册表版本号：任何安装/清理都会递增，用于路由 memo 失效判断。

pub fn record_result_cache_hit(&self)

pub fn record_result_cache_miss(&self)

pub fn record_metadata_cache_hit(&self)

pub fn record_metadata_cache_miss(&self)

pub fn record_local_cache_hit(&self)

pub fn record_local_cache_miss(&self)

pub fn execute(&self, req: &QueryRequest) -> KnowledgeResult<QueryResponse>

pub fn execute_for( &self, name: &str, req: &QueryRequest, ) -> KnowledgeResult<QueryResponse>

对指定命名 provider 执行查询。

pub fn execute_first_row_fields( &self, sql: &str, params: &[DataField], cache_policy: CachePolicy, ) -> KnowledgeResult<RowData>

pub fn execute_first_row_fields_for( &self, name: &str, sql: &str, params: &[DataField], cache_policy: CachePolicy, ) -> KnowledgeResult<RowData>

对指定命名 provider 执行首行查询。

pub async fn execute_async( &self, req: &QueryRequest, ) -> KnowledgeResult<QueryResponse>

pub async fn execute_for_async( &self, name: &str, req: &QueryRequest, ) -> KnowledgeResult<QueryResponse>

pub async fn execute_first_row_fields_async( &self, sql: &str, params: &[DataField], cache_policy: CachePolicy, ) -> KnowledgeResult<RowData>

pub async fn execute_first_row_fields_for_async( &self, name: &str, sql: &str, params: &[DataField], cache_policy: CachePolicy, ) -> KnowledgeResult<RowData>