Struct LangbaseClient 

pub struct LangbaseClient { /* private fields */ }

Client for interacting with Langbase Pipes API

Implementations

impl LangbaseClient

pub fn new( config: &LangbaseConfig, request_config: RequestConfig, ) -> LangbaseResult<Self>

Create a new Langbase client

pub async fn call_pipe( &self, request: PipeRequest, ) -> LangbaseResult<PipeResponse>

Call a Langbase pipe with the given request

pub fn base_url(&self) -> &str

Get the base URL (for testing)

pub async fn create_pipe( &self, request: CreatePipeRequest, ) -> LangbaseResult<CreatePipeResponse>

Create a new pipe

pub async fn delete_pipe( &self, owner_login: &str, pipe_name: &str, ) -> LangbaseResult<()>

Delete a pipe by name (uses beta endpoint)

pub async fn ensure_linear_pipe(&self, pipe_name: &str) -> LangbaseResult<()>

Ensure the linear reasoning pipe exists, creating it if needed

pub async fn ensure_tree_pipe(&self, pipe_name: &str) -> LangbaseResult<()>

Ensure the tree reasoning pipe exists, creating it if needed

pub async fn ensure_divergent_pipe(&self, pipe_name: &str) -> LangbaseResult<()>

Ensure the divergent reasoning pipe exists, creating it if needed

pub async fn ensure_reflection_pipe( &self, pipe_name: &str, ) -> LangbaseResult<()>

Ensure the reflection reasoning pipe exists, creating it if needed

pub async fn ensure_all_pipes(&self) -> LangbaseResult<()>

Ensure all reasoning pipes exist, creating them if needed

pub async fn ensure_auto_router_pipe(&self) -> LangbaseResult<()>

Ensure the auto mode router pipe exists

pub async fn ensure_consolidated_detection_pipe( &self, pipe_name: &str, ) -> LangbaseResult<()>

Ensure the consolidated detection pipe exists (prompts passed dynamically)

pub async fn ensure_consolidated_got_pipe( &self, pipe_name: &str, ) -> LangbaseResult<()>

Ensure the consolidated GoT pipe exists (prompts passed dynamically)

pub async fn ensure_detection_pipes(&self) -> LangbaseResult<()>

Ensure detection pipe exists

pub async fn ensure_got_pipes(&self) -> LangbaseResult<()>

Ensure GoT pipes exist

pub async fn ensure_consolidated_decision_framework_pipe( &self, pipe_name: &str, ) -> LangbaseResult<()>

Ensure the consolidated decision framework pipe exists (prompts passed dynamically)

pub async fn ensure_decision_framework_pipes(&self) -> LangbaseResult<()>

Ensure all decision framework pipes exist, creating them if needed

Trait Implementations

impl Clone for LangbaseClient

fn clone(&self) -> LangbaseClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.