Struct DocStore 

pub struct DocStore { /* private fields */ }

Implementations

impl DocStore

pub fn open(path: &Path) -> Result<Self>

pub fn connection(&self) -> Result<Connection<'_>>

pub fn get_doc_hashes(&self) -> Result<HashMap<String, String>>

pub fn upsert_all_parquet( &self, docs: &[&ExtractedDoc], chunks: &[&Chunk], ) -> Result<()>

pub fn upsert_source( &self, id: &str, source_type: &str, base_url: &str, space_key: &str, ) -> Result<()>

pub fn link_doc_to_source(&self, doc_id: &str, source_id: &str) -> Result<()>

pub fn get_docs_by_source(&self, source_id: &str) -> Result<Vec<String>>

pub fn delete_docs_by_ids(&self, doc_ids: &[&str]) -> Result<()>

pub fn create_link( &self, from_doc_id: &str, to_doc_id: &str, url: &str, link_type: &str, ) -> Result<()>

pub fn delete_links_from(&self, doc_id: &str) -> Result<()>

pub fn stats(&self) -> Result<DocStoreStats>

pub fn ensure_plugin_table( &self, plugin_id: &str, columns: &[(String, String)], ) -> Result<()>

Create a per-plugin node table from schema definition.

pub fn upsert_pipeline_core(&self, record: &PipelineCoreRecord) -> Result<()>

Upsert a pipeline core record.

pub fn upsert_plugin_properties( &self, pipeline_id: &str, plugin_id: &str, properties: &Map<String, Value>, schema: &[(String, String)], ) -> Result<()>

Upsert plugin-specific properties into Pipeline_<plugin_id> table.

pub fn link_pipeline_core_to_doc( &self, pipeline_id: &str, doc_id: &str, ) -> Result<()>

Link a pipeline core to a document via DEFINED_IN edge.

pub fn link_pipeline_dependencies(&self) -> Result<usize>

Link pipeline dependencies using PipelineCore inputs/outputs matching. Cross-plugin: if plugin A’s output matches plugin B’s input, creates DEPENDS_ON edge.

pub fn get_all_pipeline_cores( &self, plugin_id: Option<&str>, ) -> Result<Vec<PipelineCoreRecord>>

Get all PipelineCore records, optionally filtered by plugin_id.

pub fn get_pipeline_core( &self, pipeline_id: &str, ) -> Result<Option<PipelineCoreRecord>>

Get a PipelineCore record by id.

pub fn impact_analysis( &self, table_name: &str, max_depth: u32, ) -> Result<Vec<ImpactResult>>

Impact analysis using PipelineCore inputs/outputs.

pub fn get_pipeline_deps(&self) -> Result<Vec<(String, String, String)>>

Get all DEPENDS_ON edges as (from_name, to_name, dep_type) tuples.

pub fn query_plugin_table( &self, plugin_id: &str, field: &str, value: &str, ) -> Result<Vec<Value>>

Query a plugin-specific table by field value.

pub fn pipeline_core_count(&self) -> Result<usize>

Pipeline count for stats (using PipelineCore).

pub fn get_all_chunks(&self) -> Result<Vec<(String, String)>>

pub fn get_chunk_ids(&self) -> Result<HashSet<String>>

pub fn get_chunk_details(&self, chunk_ids: &[&str]) -> Result<Vec<ChunkDetail>>