Struct HttpStore 

pub struct HttpStore { /* private fields */ }

HTTP-backed state store that talks to the Python A2A server

Implementations

impl HttpStore

pub fn from_env() -> Self

Create from environment variables.

• CODETETHER_API_URL — base URL (default: http://localhost:8080)
• CODETETHER_API_KEY — optional Bearer token

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

Create with explicit base URL and optional API key

Trait Implementations

impl RalphStateStore for HttpStore

fn create_run<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 RalphRunState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a new run record

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, status: RalphStatus, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the run status

fn update_iteration<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, iteration: usize, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record iteration progress

fn record_story_result<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 str, result: &'life2 StoryResultEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Record a story result

fn append_progress<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 str, entry: &'life2 ProgressEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append a progress log entry

fn update_prd<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 str, prd: &'life2 Prd, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update the PRD (e.g. after marking stories passed)

fn set_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 str, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Set error message

fn complete_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, status: RalphStatus, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark run as completed

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<RalphRunState>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get full run state

fn list_runs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<RalphRunSummary>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all runs (summary only)