Struct SzEngineCore 

pub struct SzEngineCore;

Core implementation of the SzEngine trait

Implementations

impl SzEngineCore

pub fn new() -> SzResult<Self>

Trait Implementations

impl SzEngine for SzEngineCore

fn prime_engine(&self) -> SzResult<()>

Primes the engine for optimal performance.

fn get_stats(&self) -> SzResult<JsonString>

Gets engine performance statistics.

fn add_record( &self, data_source_code: &str, record_id: &str, record_definition: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Adds a record for entity resolution.

fn get_record_preview( &self, record_definition: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Gets a preview of how a record would be processed without persisting it.

fn delete_record( &self, data_source_code: &str, record_id: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Deletes a record from the entity repository.

fn reevaluate_record( &self, data_source_code: &str, record_id: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Reevaluates a specific record against current rules.

fn reevaluate_entity( &self, entity_id: EntityId, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Reevaluates all records for a specific entity.

fn search_by_attributes( &self, attributes: &str, search_profile: Option<&str>, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Searches for entities by attributes.

fn why_search( &self, attributes: &str, entity_id: EntityId, search_profile: Option<&str>, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Analyzes why a search result was returned for an entity.

fn get_entity( &self, entity_ref: EntityRef<'_>, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Gets entity information by entity ID or record key.

fn get_record( &self, data_source_code: &str, record_id: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Gets record information.

fn find_interesting_entities( &self, entity_ref: EntityRef<'_>, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Finds interesting entities related to a given entity or record.

fn find_path( &self, start_entity_id: EntityId, end_entity_id: EntityId, max_degrees: i64, _avoid_entity_ids: Option<&HashSet<EntityId>>, _required_data_sources: Option<&HashSet<String>>, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Finds a relationship path between two entities.

fn find_network( &self, entity_list: &[EntityId], max_degrees: i64, build_out_degree: i64, max_entities: i64, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Finds a network of related entities.

fn why_entities( &self, entity_id1: EntityId, entity_id2: EntityId, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Analyzes why two entities are related.

fn why_records( &self, data_source_code1: &str, record_id1: &str, data_source_code2: &str, record_id2: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Analyzes why two records resolved together.

fn why_record_in_entity( &self, data_source_code: &str, record_id: &str, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Analyzes why a record belongs to its entity.

fn how_entity( &self, entity_id: EntityId, flags: Option<SzFlags>, ) -> SzResult<JsonString>

Analyzes how an entity was constructed.

fn get_virtual_entity( &self, record_keys: &[(String, String)], flags: Option<SzFlags>, ) -> SzResult<JsonString>

Creates a virtual entity from record keys without persisting.

fn process_redo_record( &self, redo_record: &str, _flags: Option<SzFlags>, ) -> SzResult<JsonString>

Processes a redo record for deferred resolution.

fn get_redo_record(&self) -> SzResult<JsonString>

Gets the next pending redo record.

fn count_redo_records(&self) -> SzResult<i64>

Counts pending redo records.

fn export_json_entity_report( &self, flags: Option<SzFlags>, ) -> SzResult<ExportHandle>

Starts a JSON entity export.

fn export_csv_entity_report( &self, csv_column_list: &str, flags: Option<SzFlags>, ) -> SzResult<ExportHandle>

Starts a CSV entity export.

fn fetch_next(&self, export_handle: ExportHandle) -> SzResult<JsonString>

Fetches the next batch of export data.

fn close_export(&self, export_handle: ExportHandle) -> SzResult<()>

Closes an export operation and releases resources.