Struct UpstreamClient 

pub struct UpstreamClient { /* private fields */ }

HTTP client to ferra-server. No global request timeout — the watch connection is long-lived; per-request timeouts come from the tokio::time::timeout wrappers in the watch loop.

Implementations

impl UpstreamClient

pub fn new(base_url: String) -> Self

pub async fn snapshot(&self, prefix: &str) -> Result<Snapshot>

GET /v1/kv?prefix=...

pub async fn get_key(&self, key: &str) -> Result<Option<GetResponse>>

GET /v1/kv/{key} — returns None on 404 (key was deleted between the watch event and our follow-up GET).

pub async fn open_watch(&self, prefix: &str, since: i64) -> Result<Response>

GET /v1/watch?prefix=...&since=... — returns the open response; caller streams the body.

Trait Implementations

impl Clone for UpstreamClient

fn clone(&self) -> UpstreamClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.