Struct SchemaRoutingAdmin 

pub struct SchemaRoutingAdmin {
    pub registry: Arc<SchemaRegistry>,
    pub router: Arc<SchemaAwareRouter>,
    pub classifier: Arc<LearningClassifier>,
    pub discovery: Arc<SchemaDiscovery>,
    pub metrics: Arc<SchemaRoutingMetrics>,
}

Admin API for schema routing

Fields

registry: Arc<SchemaRegistry>

router: Arc<SchemaAwareRouter>

classifier: Arc<LearningClassifier>

discovery: Arc<SchemaDiscovery>

metrics: Arc<SchemaRoutingMetrics>

Implementations

impl SchemaRoutingAdmin

pub fn new( registry: Arc<SchemaRegistry>, router: Arc<SchemaAwareRouter>, classifier: Arc<LearningClassifier>, discovery: Arc<SchemaDiscovery>, metrics: Arc<SchemaRoutingMetrics>, ) -> Self

Create a new admin API instance

pub fn list_tables(&self) -> TablesResponse

GET /schema/tables - List all registered tables

pub fn get_table(&self, name: &str) -> Option<TableDetails>

GET /schema/tables/:name - Get details for a specific table

pub fn register_table( &self, request: RegisterTableRequest, ) -> Result<TableDetails, AdminError>

POST /schema/tables - Register a new table

pub fn remove_table(&self, name: &str) -> Result<(), AdminError>

DELETE /schema/tables/:name - Remove a table from routing

pub fn classify_table( &self, request: ClassifyRequest, ) -> Result<ClassificationResult, AdminError>

POST /schema/classify - Manually classify a table

pub fn get_classification_suggestion( &self, table_name: &str, ) -> Result<ClassificationSuggestion, AdminError>

GET /schema/classify/:table - Get classifier suggestions

pub fn analyze_query(&self, request: AnalyzeRequest) -> AnalysisResult

POST /schema/analyze - Analyze a query

pub fn route_query(&self, request: RouteRequest) -> RouteResult

POST /schema/route - Get routing decision for a query (dry-run)

pub fn get_stats(&self) -> RoutingStatsResponse

GET /schema/stats - Get overall routing statistics

pub fn get_table_stats(&self) -> Vec<TableStatsResponse>

GET /schema/stats/tables - Get per-table statistics

pub fn get_workload_stats(&self) -> Vec<WorkloadStatsResponse>

GET /schema/stats/workloads - Get per-workload statistics

pub async fn trigger_discovery(&self) -> Result<DiscoveryResult, AdminError>

POST /schema/discover - Trigger schema discovery

pub async fn refresh_schema(&self) -> Result<RefreshResult, AdminError>

POST /schema/refresh - Refresh schema cache

pub fn get_ai_workload_stats(&self) -> AIWorkloadStatsResponse

GET /schema/ai/workloads - Get AI workload statistics

pub fn get_rag_stats(&self) -> RAGStatsResponse

GET /schema/rag/stats - Get RAG pipeline statistics