Struct RuntaraClient 

pub struct RuntaraClient { /* private fields */ }

QUIC client for communicating with runtara-core

Implementations

impl RuntaraClient

pub fn new(config: RuntaraClientConfig) -> Result<Self, ClientError>

Create a new client with the given configuration

pub fn localhost() -> Result<Self, ClientError>

Create a client with default configuration for local development

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

Connect to the server

pub async fn open_stream( &self, ) -> Result<FramedStream<(SendStream, RecvStream)>, ClientError>

Open a new bidirectional stream for a request/response

pub async fn open_uni_send( &self, ) -> Result<FramedStream<SendStream>, ClientError>

Open a unidirectional stream for sending (e.g., events)

pub async fn request<Req: Message, Resp: Message + Default>( &self, request: &Req, ) -> Result<Resp, ClientError>

Send a request and receive a response using a new stream

pub async fn send_fire_and_forget<Req: Message>( &self, request: &Req, ) -> Result<(), ClientError>

Send a fire-and-forget request (no response expected).

Use this for events that don’t require acknowledgement.

pub async fn open_raw_stream( &self, ) -> Result<(SendStream, RecvStream), ClientError>

Open a raw bidirectional stream for streaming operations.

This returns the raw QUIC streams for advanced use cases like streaming large data that doesn’t fit in a single frame.

pub async fn close(&self)

Close the connection gracefully

pub async fn is_connected(&self) -> bool

Check if the client is currently connected

Trait Implementations

impl Drop for RuntaraClient

fn drop(&mut self)

Executes the destructor for this type.