Struct HttpTransport 

pub struct HttpTransport { /* private fields */ }

HTTP transport implementation using axum and reqwest.

Implementations

impl HttpTransport

pub const TRANSPORT_TYPE: &'static str = "http"

Transport type identifier for HTTP

pub fn new() -> Result<Self>

Create a new HTTP transport instance.

pub fn builder() -> HttpTransportBuilder

Create a builder for configuring the transport.

Trait Implementations

impl SyncTransport for HttpTransport

fn transport_type(&self) -> &'static str

Get the transport type identifier.

fn can_handle_address(&self, address: &Address) -> bool

Check if this transport can handle the given address

fn start_server<'life0, 'async_trait>( &'life0 mut self, handler: Arc<dyn SyncHandler>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start a server with the pre-configured bind address.

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

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

Stop the running server gracefully.

fn send_request<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, request: &'life2 SyncRequest, ) -> Pin<Box<dyn Future<Output = Result<SyncResponse>> + Send + 'async_trait>>

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

Send a sync request to a peer and receive a response.

fn is_server_running(&self) -> bool

Check if the server is currently running.

fn get_server_address(&self) -> Result<String>

Get the address the server is currently bound to.

fn send_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, entries: &'life2 [Entry], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send entries to a sync peer and ensure they are acknowledged.