Struct RdfRegistry 

pub struct RdfRegistry { /* private fields */ }

High-performance RDF-backed registry

Uses oxigraph (semantic data store) as the single source of truth. All packages are stored as RDF triples enabling:

• SPARQL queries for intelligent search
• Semantic relationships between packages
• Version history tracking
• Full dependency graph representation

Implementations

impl RdfRegistry

pub fn new() -> RdfRegistry

Create a new RDF-backed registry

pub fn from_store(store: Store) -> RdfRegistry

Create a new RDF-backed registry from an existing store

pub fn insert_package_rdf(&self, package: &Package) -> Result<(), Error>

Insert a package as RDF triples using the mapper (public wrapper with locking)

Errors

• Error::RdfStoreError - When inserting triples into the RDF store fails
• Error::SerializationError - When serializing package data to RDF fails

pub fn batch_insert_packages( &self, packages: Vec<Package>, ) -> Result<usize, Error>

Batch insert multiple packages for efficient loading

Errors

• Error::RdfStoreError - When inserting triples into the RDF store fails
• Error::SerializationError - When serializing package data to RDF fails

pub fn query_sparql(&self, query: &str) -> Result<Vec<String>, Error>

Query packages by SPARQL

Errors

• Error::SparqlError - When the SPARQL query syntax is invalid
• Error::RdfStoreError - When querying the RDF store fails

pub fn stats(&self) -> RdfRegistryStats

Get statistics about the RDF store

impl RdfRegistry

pub async fn create_package(&self, package: Package) -> Result<Package, Error>

Create a new package in the RDF store

Errors

• Error::PackageAlreadyExists - When a package with the same ID already exists
• Error::RdfStoreError - When inserting into the RDF store fails
• Error::SerializationError - When serializing package data fails

pub async fn update_package( &self, id: &PackageId, package: Package, ) -> Result<Package, Error>

Update an existing package in the RDF store

Errors

• Error::PackageNotFound - When the package does not exist
• Error::RdfStoreError - When updating the RDF store fails
• Error::SerializationError - When serializing updated package data fails

pub async fn delete_package(&self, id: &PackageId) -> Result<(), Error>

Delete a package from the RDF store

Errors

• Error::PackageNotFound - When the package does not exist
• Error::RdfStoreError - When deleting from the RDF store fails

pub async fn search_packages( &self, keyword: &str, limit: usize, ) -> Result<Vec<SearchResult>, Error>

Search for packages by keyword

This performs full-text-like search over package names and descriptions by matching the keyword against RDF literals.

Errors

• Error::SearchError - When the search query fails

pub async fn list_packages( &self, offset: usize, limit: usize, ) -> Result<Vec<Package>, Error>

List packages with pagination support

Errors

• Error::SearchError - When listing packages fails

pub async fn count_packages(&self) -> Result<u64, Error>

Get total count of packages in the registry

Errors

• Error::SearchError - When querying the count fails

Trait Implementations

impl AsyncRepository for RdfRegistry

type PackageIterator = IntoIter<Package>

Type for the iterator over packages

fn get_package<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PackageId, ) -> Pin<Box<dyn Future<Output = Result<Package, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RdfRegistry: 'async_trait,

Get a package by ID

fn get_package_version<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 PackageId, version: &'life2 PackageVersion, ) -> Pin<Box<dyn Future<Output = Result<Package, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RdfRegistry: 'async_trait,

Get a specific version of a package

fn all_packages<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Package>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RdfRegistry: 'async_trait,

Get all packages in the repository

fn list_versions<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PackageId, ) -> Pin<Box<dyn Future<Output = Result<Vec<PackageVersion>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RdfRegistry: 'async_trait,

List all versions of a package

fn package_exists<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PackageId, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RdfRegistry: 'async_trait,

Check if a package exists

impl Default for RdfRegistry

fn default() -> RdfRegistry

Returns the “default value” for a type.