Struct HttpClient 

pub struct HttpClient {
    inner: Client,
    base_url: Url,
    remote_name: String,
    retry_config: RetryConfig,
}

Production HTTP client for a single Sashiko remote.

Uses reqwest for async HTTP with connection pooling. Each remote gets its own HttpClient instance.

Fields

inner: Client

base_url: Url

remote_name: String

retry_config: RetryConfig

Implementations

impl HttpClient

pub fn new(config: &RemoteConfig) -> Result<Self, ApiError>

Construct a new client for the given remote configuration.

Errors

Returns ApiError::Configuration if the URL is invalid or the HTTP client cannot be built.

async fn get<T: DeserializeOwned>( &self, path: &str, query: &[(&str, String)], ) -> Result<T, ApiError>

Execute a GET request with retry logic and JSON deserialization.

fn compute_backoff(&self, attempt: u32) -> Duration

Compute backoff delay with jitter for the given attempt number.

fn list_query(params: &ListParams) -> Vec<(&'static str, String)>

Build query parameters for list endpoints.

Wire names follow the Sashiko API docs: limit (not per_page), list (not mailing_list).

fn id_query(id: &PatchId) -> Vec<(&'static str, String)>

Build the id query parameter from a PatchId.

fn review_query(params: &ReviewQuery) -> Vec<(&'static str, String)>

Build query parameters for review endpoints.

Trait Implementations

impl SashikoApi for HttpClient

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

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

List tracked mailing lists.

fn patchsets<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListParams, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Patchset>, ApiError>> + Send + 'async_trait>>

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

Search/list patchsets with pagination.

fn messages<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListParams, ) -> Pin<Box<dyn Future<Output = Result<Paginated<EmailMessage>, ApiError>> + Send + 'async_trait>>

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

Search/list messages with pagination.

fn patch_detail<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<PatchsetDetail, ApiError>> + Send + 'async_trait>>

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

Full patchset detail (patches, reviews, thread, baseline).

fn patchset_summary<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<PatchsetDetail, ApiError>> + Send + 'async_trait>>

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

Patchset summary (lighter than patch_detail).

fn message_detail<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<EmailMessage, ApiError>> + Send + 'async_trait>>

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

Single message detail with thread.

fn review<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ReviewQuery, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review detail. One of id or patchset_id required.

fn review_log<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ReviewQuery, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review detail with logs.

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ServerStats, ApiError>> + Send + 'async_trait>>

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

Server status and counts.

fn stats_timeline<'life0, 'async_trait>( &'life0 self, subsystem_id: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Timeline data per day, optionally filtered by subsystem.

fn stats_reviews<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review statistics by provider/model/status.

fn stats_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Tool usage statistics.

fn clear_cache(&self)

Clear any cached responses. Default no-op; overridden by CachingClient.