Struct Runs 

pub struct Runs<'a> { /* private fields */ }

/v1/runs — read + control. Ids are the numeric row id (RunFeedItem::row_id parses it out of the composite feed id).

Implementations

impl Runs<'_>

pub async fn list(&self) -> Result<Page<RunFeedItem>>

GET /v1/runs.

pub async fn list_with( &self, query: &[(&str, &str)], ) -> Result<Page<RunFeedItem>>

GET /v1/runs with filters (entity_id, workflow_id, run_type, status, limit, offset).

pub async fn get(&self, run_id: i64) -> Result<RunFeedItem>

GET /v1/runs/:id.

pub async fn results(&self, run_id: i64) -> Result<RunResults>

GET /v1/runs/:id/results → {run_id, status, result}.

pub async fn data(&self, run_id: i64) -> Result<RunData>

GET /v1/runs/:id/data — the run’s extracted rows (JSON lane).

pub async fn data_csv(&self, run_id: i64) -> Result<String>

GET /v1/runs/:id/data?format=csv — the extracted rows flattened to CSV.

pub async fn cancel(&self, run_id: i64) -> Result<CancelOutcome>

POST /v1/runs/:id/cancel. Both 202 cancel_requested and 409 not_running are valid CancelOutcomes (the 409 is not an Err).

pub async fn events(&self, run_id: i64) -> Result<RunEventStream>

GET /v1/runs/:id/events — live SSE stream of RunEvents. The stream ends after the terminal finished/error frame (a run that is already finished yields exactly one terminal frame). Keep-alive comments are consumed by the parser. No reconnect logic in v1 — a dropped stream surfaces as an Err item.

Trait Implementations

impl<'a> Clone for Runs<'a>

fn clone(&self) -> Runs<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for Runs<'a>

impl<'a> Debug for Runs<'a>

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

Formats the value using the given formatter.