Struct PipelinesResource 

pub struct PipelinesResource<'c> { /* private fields */ }

Implementations

impl PipelinesResource<'_>

pub async fn list(&self) -> Result<Vec<Value>, PulseError>

GET /api/pulse/pipelines — every pipeline in the current org.

pub async fn get(&self, pipeline_id: &str) -> Result<Value, PulseError>

GET /api/pulse/pipelines/{id} — one pipeline by id.

pub async fn create(&self, definition: &Value) -> Result<Value, PulseError>

POST /api/pulse/pipelines — creates + deploys a new pipeline.

The definition must follow the CreatePipelineRequest schema (see openapi.yaml). At minimum: name + nodes.

pub async fn delete(&self, pipeline_id: &str) -> Result<(), PulseError>

DELETE /api/pulse/pipelines/{id} — tears down the pipeline.

Trait Implementations

impl<'c> Debug for PipelinesResource<'c>

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

Formats the value using the given formatter.