Struct TaskAppClient 

pub struct TaskAppClient { /* private fields */ }

Client for communicating with task apps.

Implementations

impl TaskAppClient

pub fn new(base_url: &str, api_key: Option<&str>) -> TaskAppClient

Create a new task app client.

pub fn with_timeout( base_url: &str, api_key: Option<&str>, timeout_secs: u64, ) -> TaskAppClient

Create a client with custom timeout.

pub fn base_url(&self) -> &str

Get the base URL.

pub async fn health(&self) -> Result<HealthResponse, CoreError>

Check task app health.

pub async fn is_healthy(&self) -> bool

Check if the task app is healthy.

pub async fn info(&self) -> Result<InfoResponse, CoreError>

Get service info.

pub async fn task_info( &self, seeds: Option<&[i64]>, ) -> Result<Vec<TaskInfo>, CoreError>

Get task info for specific seeds.

pub async fn taskset_info(&self) -> Result<Value, CoreError>

Get taskset description (no seeds).

pub async fn rollout( &self, request: &RolloutRequest, ) -> Result<RolloutResponse, CoreError>

Execute a rollout.

pub async fn done(&self) -> Result<Value, CoreError>

Signal that the job is done.

pub async fn get(&self, path: &str) -> Result<Value, CoreError>

Raw GET request to any endpoint.

pub async fn post(&self, path: &str, body: &Value) -> Result<Value, CoreError>

Raw POST request to any endpoint.

pub async fn wait_for_healthy( &self, timeout_seconds: f64, poll_interval_seconds: f64, ) -> Result<(), CoreError>

Wait for the task app to become healthy.

impl TaskAppClient

pub fn env(&self) -> EnvClient<'_>

Get an environment client for RL-style interactions.