Struct mithril_signer::services::AggregatorHTTPClient

pub struct AggregatorHTTPClient { /* private fields */ }

AggregatorHTTPClient is a http client for an aggregator

Implementations

impl AggregatorHTTPClient

pub fn new( cardano_network: CardanoNetwork, aggregator_endpoint: String, relay_endpoint: Option<String>, api_version_provider: Arc<APIVersionProvider>, timeout_duration: Option<Duration>, logger: Logger, ) -> Self

AggregatorHTTPClient factory

pub fn prepare_request_builder( &self, request_builder: RequestBuilder, ) -> RequestBuilder

Forge a client request adding protocol version in the headers.

Trait Implementations

impl AggregatorClient for AggregatorHTTPClient

fn retrieve_epoch_settings<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<SignerEpochSettings>, AggregatorClientError>> + Send + 'async_trait>>

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

Retrieves epoch settings from the aggregator

fn register_signer<'life0, 'life1, 'async_trait>( &'life0 self, epoch: Epoch, signer: &'life1 Signer, ) -> Pin<Box<dyn Future<Output = Result<(), AggregatorClientError>> + Send + 'async_trait>>

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

Registers signer with the aggregator.

fn register_signatures<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, signed_entity_type: &'life1 SignedEntityType, signatures: &'life2 SingleSignatures, protocol_message: &'life3 ProtocolMessage, ) -> Pin<Box<dyn Future<Output = Result<(), AggregatorClientError>> + Send + 'async_trait>>

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

Registers single signatures with the aggregator.

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

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

Retrieves aggregator features message from the aggregator