Struct VarpulisClient 

pub struct VarpulisClient { /* private fields */ }

Client for the Varpulis REST API.

Implementations

impl VarpulisClient

pub fn new(base_url: &str, api_key: &str) -> Self

pub async fn deploy_pipeline( &self, name: &str, source: &str, ) -> Result<DeployPipelineResponse, ClientError>

Deploy a pipeline to the remote server.

pub async fn list_pipelines(&self) -> Result<PipelineListResponse, ClientError>

List all pipelines for the authenticated tenant.

pub async fn delete_pipeline( &self, pipeline_id: &str, ) -> Result<(), ClientError>

Delete a pipeline by ID.

pub fn logs_url(&self, pipeline_id: &str) -> String

Stream logs for a pipeline via SSE. Returns the URL for SSE connection (caller handles streaming).

pub fn api_key(&self) -> &str

Get the API key for SSE header authentication.

pub async fn get_usage(&self) -> Result<UsageResponse, ClientError>

Get usage statistics for the authenticated tenant.

Trait Implementations

impl Debug for VarpulisClient

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

Formats the value using the given formatter.