Struct DatasetManager 

pub struct DatasetManager { /* private fields */ }

Manages dataset CRUD operations against the Langfuse API.

Implementations

impl DatasetManager

pub fn new(config: &LangfuseConfig) -> Self

Create a new DatasetManager from the given configuration.

pub async fn create_dataset( &self, body: CreateDatasetBody, ) -> Result<Dataset, LangfuseError>

Create a new dataset.

pub async fn get_dataset(&self, name: &str) -> Result<Dataset, LangfuseError>

Get a dataset by name.

pub async fn delete_dataset(&self, name: &str) -> Result<(), LangfuseError>

Delete a dataset by name.

Sends DELETE /api/public/datasets/{name} with retry logic for transient failures.

pub async fn create_item( &self, body: CreateDatasetItemBody, ) -> Result<DatasetItem, LangfuseError>

Create a dataset item.

pub async fn get_items( &self, dataset_name: &str, page: Option<i32>, limit: Option<i32>, ) -> Result<Vec<DatasetItem>, LangfuseError>

Get dataset items (paginated).

pub async fn get_runs( &self, dataset_name: &str, ) -> Result<Vec<DatasetRun>, LangfuseError>

Get dataset runs.

pub async fn delete_run( &self, dataset_name: &str, run_name: &str, ) -> Result<(), LangfuseError>

Delete a dataset run.

Sends DELETE /api/public/datasets/{dataset_name}/runs/{run_name} with retry logic for transient failures.

pub async fn run_batched_evaluation<T>( &self, dataset_name: &str, batch_config: BatchedEvaluationConfig, task_fn: T, evaluators: Vec<Box<dyn Evaluator>>, ) -> Result<Vec<ExperimentResult>, LangfuseError>

where T: Fn(DatasetItem) -> Pin<Box<dyn Future<Output = Value> + Send>> + Send + Sync + 'static,

Run a batched evaluation over all items in a dataset.

Fetches dataset items in pages, executes the task function on each item with bounded concurrency, runs evaluators, and collects results.

If config.start_after is set, items with IDs lexicographically before that value are skipped (resume token support).

Trait Implementations

impl Debug for DatasetManager

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

Formats the value using the given formatter.