Struct HttpReplicationClient 

pub struct HttpReplicationClient { /* private fields */ }

HTTP replication client that implements ReplicationProtocol against an HttpReplicationServer.

Uses MessagePack (rmp-serde) for control messages and raw bytes for segment transfer.

Implementations

impl HttpReplicationClient

pub fn new(base_url: impl Into<String>) -> Self

Create a new client pointing at base_url (e.g. "http://127.0.0.1:8900").

Trait Implementations

impl ReplicationProtocol for HttpReplicationClient

fn merkle_root(&self) -> Result<[u8; 32], EdgestoreError>

Fetch the remote peer’s current Merkle root.

Calls GET {base_url}/merkle, deserializes MessagePack body as {root: Vec<u8>}, and converts to [u8; 32].

fn list_segments(&self) -> Result<Vec<SegmentRef>, EdgestoreError>

Fetch the remote peer’s full segment manifest.

Calls GET {base_url}/segments, deserializes MessagePack as a list of segment entries, and converts each to SegmentRef.

fn fetch_segment(&self, hash: &[u8; 32]) -> Result<Vec<u8>, EdgestoreError>

Fetch one segment’s raw bytes by content hash.

Calls GET {base_url}/segments/{hash_hex}, reads raw bytes from body. Caller MUST verify BLAKE3 before applying (T-04-01).