Struct RequestExecutor 

pub(super) struct RequestExecutor {
    transport: Arc<dyn HttpTransport>,
    sleeper: Arc<dyn RetrySleeper>,
    sentinel_url: String,
    sentinel_host: String,
    signer: Arc<dyn RequestSigner>,
}

Fields

transport: Arc<dyn HttpTransport>

sleeper: Arc<dyn RetrySleeper>

sentinel_url: String

sentinel_host: String

signer: Arc<dyn RequestSigner>

Implementations

impl RequestExecutor

pub(super) fn new( target: ExecutorTarget, client: Client, signer: Arc<dyn RequestSigner>, ) -> Self

pub(super) async fn execute<T>( &self, request: NodeRequest<T>, ) -> Result<T, SentinelError>

where T: DeserializeOwned,

async fn execute_response<T>( &self, request: &NodeRequest<T>, ) -> Result<TransportResponse, SentinelError>

Trait Implementations

impl Clone for RequestExecutor

fn clone(&self) -> RequestExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestExecutor

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

Formats the value using the given formatter.