Struct Client 

pub struct Client {
    pub default_address: Option<Arc<String>>,
    pub default_signature: Option<Arc<String>>,
    /* private fields */
}

The viewer HTTP client. Constructed once at process startup; all send_* methods take &self so the client is shared across the app via Arc<Client>.

Fields

default_address: Option<Arc<String>>

Fallback address used when a send_* call’s address is None. Set from the constructor’s address argument, or from VIEWER_ADDRESS if address is None and the env feature is enabled.

default_signature: Option<Arc<String>>

Fallback signature used when a send_* call’s signature is None. Set from the constructor’s signature argument, or from VIEWER_SIGNATURE if signature is None and the env feature is enabled.

Implementations

impl Client

pub fn new( http_client: Client, address: Option<impl Into<String>>, signature: Option<impl Into<String>>, backoff_current_interval: Duration, backoff_initial_interval: Duration, backoff_randomization_factor: f64, backoff_multiplier: f64, backoff_max_interval: Duration, backoff_max_elapsed_time: Duration, ) -> Self

Construct a new client and spawn its background task.

address / signature defaults: an explicit Some(...) wins. When None, and the env feature is enabled, falls back to the VIEWER_ADDRESS / VIEWER_SIGNATURE env vars. When both the argument and the env var are missing, the client has no default — every send_* call must supply its own address, or the request is dropped.

Backoff parameters tune the backoff::ExponentialBackoff the background task uses for retry. max_elapsed_time caps how long the task keeps retrying a single failed request before giving up.

pub async fn flush(self)

Closes the channel and awaits the background task. After this returns, every enqueued request has either succeeded or exhausted its retry budget. Takes self so the can’t-send-after-flush invariant is enforced by the type system.

Intended for short-lived consumers (e.g. the cli) that must drain in-flight POSTs before dropping the tokio runtime. Long- lived consumers (api server) can rely on the natural drop behavior — when the Client drops, tx drops, the bg task’s rx.recv() returns None, and the loop exits.

pub fn send_agent_completion_begin( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, request: Arc<AgentCompletionCreateParams>, )

pub fn send_agent_completion_continue( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, chunk: AgentCompletionChunk, )

pub fn send_agent_completion_error( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, error: ResponseError, )

pub fn send_function_execution_begin( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, request: Arc<FunctionExecutionCreateParams>, )

pub fn send_function_execution_continue( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, chunk: FunctionExecutionChunk, )

pub fn send_function_execution_error( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, error: ResponseError, )

pub fn send_function_invention_recursive_begin( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, request: Arc<FunctionInventionRecursiveCreateParams>, )

pub fn send_function_invention_recursive_continue( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, chunk: FunctionInventionRecursiveChunk, )

pub fn send_function_invention_recursive_error( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, error: ResponseError, )

pub fn send_laboratory_execution_begin( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, request: Arc<LaboratoryExecutionCreateParams>, )

pub fn send_laboratory_execution_continue( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, chunk: LaboratoryExecutionChunk, )

pub fn send_laboratory_execution_error( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, id: String, error: ResponseError, )

pub fn send_agents_favorites_changed( &self, address: Option<Arc<String>>, signature: Option<Arc<String>>, notification: ChangedNotification, )

Enqueue an agents_favorites_changed notification. Posts to <address>/agents/favorites/changed. Fired by the cli’s agents favorites config {add,del,edit} handlers so any running viewer that exposes a useFavoriteAgents()-style hook can refresh its favorites list.