Struct ExportService 

pub struct ExportService<S>
where
    S: DatasetStore,
{ /* private fields */ }

Service for exporting datasets in streaming mode.

Uses DatasetStore::list_stream to fetch datasets incrementally, avoiding loading all data into memory at once.

Implementations

impl<S> ExportService<S>

where S: DatasetStore,

pub fn new(store: S) -> Self

Creates a new export service with the given store.

pub async fn export_to_writer<W: Write>( &self, writer: &mut W, format: ExportFormat, portal_filter: Option<&str>, limit: Option<usize>, ) -> Result<u64, AppError>

Exports datasets to a writer in streaming mode.

Arguments

• writer - The output writer (e.g., stdout, file)
• format - The export format (JSONL, JSON, or CSV)
• portal_filter - Optional portal URL to filter by
• limit - Optional maximum number of records

Returns

The number of datasets exported.

pub async fn export_to_async_writer<W: AsyncWrite + Unpin>( &self, writer: &mut W, format: ExportFormat, portal_filter: Option<&str>, limit: Option<usize>, ) -> Result<u64, AppError>

Exports datasets to an async writer in streaming mode.

This method writes directly to the async writer without buffering the entire dataset in memory, making it suitable for HTTP streaming responses.

Arguments

• writer - The async output writer
• format - The export format (JSONL, JSON, or CSV)
• portal_filter - Optional portal URL to filter by
• limit - Optional maximum number of records

Returns

The number of datasets exported.

Trait Implementations

impl<S> Clone for ExportService<S>

where S: DatasetStore + Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.