Struct Registry 

pub struct Registry { /* private fields */ }

A dataset registry for publishing and retrieving datasets.

The registry stores datasets along with metadata in a structured format, enabling discovery and versioning of datasets.

Example

use alimentar::{backend::MemoryBackend, registry::Registry};

let backend = MemoryBackend::new();
let registry = Registry::new(Box::new(backend));

Implementations

impl Registry

pub fn new(backend: Box<dyn StorageBackend>) -> Self

Creates a new registry with the given storage backend.

pub fn with_index_path( backend: Box<dyn StorageBackend>, index_path: impl Into<String>, ) -> Self

Creates a new registry with a custom index path.

pub fn init(&self) -> Result<()>

Initializes the registry by creating an empty index if one doesn’t exist.

Errors

Returns an error if the index cannot be created.

pub fn load_index(&self) -> Result<RegistryIndex>

Loads the registry index.

Errors

Returns an error if the index cannot be loaded or parsed.

pub fn list(&self) -> Result<Vec<DatasetInfo>>

Lists all available datasets in the registry.

Errors

Returns an error if the index cannot be loaded.

pub fn get_info(&self, name: &str) -> Result<DatasetInfo>

Gets information about a specific dataset.

Errors

Returns an error if the dataset is not found.

pub fn publish( &self, name: &str, version: &str, dataset: &ArrowDataset, metadata: DatasetMetadata, ) -> Result<()>

Publishes a dataset to the registry.

Arguments

• name - Unique name for the dataset
• version - Semantic version string (e.g., “1.0.0”)
• dataset - The dataset to publish
• metadata - Metadata describing the dataset

Errors

Returns an error if the dataset cannot be saved or the index cannot be updated.

pub fn pull(&self, name: &str, version: Option<&str>) -> Result<ArrowDataset>

Pulls a dataset from the registry.

Arguments

• name - Name of the dataset
• version - Optional version (uses latest if not specified)

Errors

Returns an error if the dataset cannot be found or loaded.

pub fn search(&self, query: &str) -> Result<Vec<DatasetInfo>>

Searches datasets by query string (matches name and description).

Errors

Returns an error if the index cannot be loaded.

pub fn search_tags(&self, tags: &[&str]) -> Result<Vec<DatasetInfo>>

Searches datasets by tags.

Errors

Returns an error if the index cannot be loaded.

pub fn delete(&self, name: &str, version: &str) -> Result<()>

Deletes a dataset version from the registry.

Errors

Returns an error if the dataset cannot be deleted.

Trait Implementations

impl Debug for Registry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.