Struct RunAgentClient 

pub struct RunAgentClient { /* private fields */ }

Main client for interacting with RunAgent deployments

Implementations

impl RunAgentClient

pub async fn new(config: RunAgentClientConfig) -> RunAgentResult<Self>

Create a new RunAgent client from configuration

This is the single entry point for creating clients.

Examples

use runagent::{RunAgentClient, RunAgentClientConfig};
use std::env;

#[tokio::main]
async fn main() -> runagent::RunAgentResult<()> {
    // Local agent with explicit address
    let client = RunAgentClient::new(RunAgentClientConfig::new("agent-id", "entrypoint")
        .with_local(true)
        .with_address("127.0.0.1", 8450)
        .with_enable_registry(false)
    ).await?;
     
    // Remote agent
    let client = RunAgentClient::new(RunAgentClientConfig::new("agent-id", "entrypoint")
        .with_api_key(env::var("RUNAGENT_API_KEY").unwrap_or_else(|_| "key".to_string()))
    ).await?;
    Ok(())
}

pub async fn run(&self, input_kwargs: &[(&str, Value)]) -> RunAgentResult<Value>

Run the agent with keyword arguments only

pub async fn run_with_args( &self, input_args: &[Value], input_kwargs: &[(&str, Value)], ) -> RunAgentResult<Value>

Run the agent with the given input

pub async fn run_stream( &self, input_kwargs: &[(&str, Value)], ) -> RunAgentResult<Pin<Box<dyn Stream<Item = RunAgentResult<Value>> + Send>>>

Run the agent and return a stream of responses

pub async fn run_stream_with_args( &self, input_args: &[Value], input_kwargs: &[(&str, Value)], ) -> RunAgentResult<Pin<Box<dyn Stream<Item = RunAgentResult<Value>> + Send>>>

Run the agent with streaming and both positional and keyword arguments

pub async fn get_agent_architecture(&self) -> RunAgentResult<Value>

Get the agent’s architecture information

pub async fn health_check(&self) -> RunAgentResult<bool>

Check if the agent is available

pub fn agent_id(&self) -> &str

Get agent information

pub fn entrypoint_tag(&self) -> &str

Get entrypoint tag

pub fn extra_params(&self) -> Option<&HashMap<String, Value>>

Get any extra params supplied during initialization

pub fn is_local(&self) -> bool

Check if using local deployment