Struct HttpAsyncWitnessClient 

pub struct HttpAsyncWitnessClient { /* private fields */ }

HTTP-based witness client implementing AsyncWitnessProvider.

Communicates with a KERI witness server over HTTP to submit events, retrieve receipts, and check identity heads.

Usage:

use auths_infra_http::HttpAsyncWitnessClient;

let client = HttpAsyncWitnessClient::new("http://localhost:3000", 2)
    .with_timeout(std::time::Duration::from_secs(10));

Implementations

impl HttpAsyncWitnessClient

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

Creates a new HTTP async witness client.

Args:

• base_url: The witness server base URL (e.g., "http://localhost:3000").
• quorum_size: Minimum receipts required for this witness.

Usage:

let client = HttpAsyncWitnessClient::new("http://witness:3000", 1);

pub fn with_timeout(self, timeout: Duration) -> Self

Sets a custom timeout for HTTP requests.

Args:

• timeout: The request timeout duration.

Usage:

let client = HttpAsyncWitnessClient::new("http://witness:3000", 1)
    .with_timeout(Duration::from_secs(30));

Trait Implementations

impl AsyncWitnessProvider for HttpAsyncWitnessClient

fn submit_event<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, prefix: &'life1 Prefix, event_json: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<Receipt, WitnessError>> + Send + 'async_trait>>

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

Submit an event to the witness for receipting.

fn observe_identity_head<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 Prefix, ) -> Pin<Box<dyn Future<Output = Result<Option<EventHash>, WitnessError>> + Send + 'async_trait>>

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

Query the current observed head for an identity.

fn get_receipt<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, prefix: &'life1 Prefix, event_said: &'life2 Said, ) -> Pin<Box<dyn Future<Output = Result<Option<Receipt>, WitnessError>> + Send + 'async_trait>>

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

Retrieve a previously issued receipt.

fn quorum(&self) -> usize

Get the minimum quorum required for consistency.

fn timeout_ms(&self) -> u64

Get the timeout for operations in milliseconds.

fn is_available<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, WitnessError>> + Send + 'async_trait>>

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

Check if this provider is currently available.

impl Clone for HttpAsyncWitnessClient

fn clone(&self) -> HttpAsyncWitnessClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpAsyncWitnessClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.