Struct HttpClusterCommandForwarder 

pub struct HttpClusterCommandForwarder { /* private fields */ }

Implementations

impl HttpClusterCommandForwarder

pub fn new(region_targets: BTreeMap<String, String>) -> Self

pub fn with_region_target( self, region: impl Into<String>, endpoint_url: impl Into<String>, ) -> Self

pub fn with_bearer_token(self, token: impl Into<String>) -> Self

pub fn with_metrics(self, metrics: Arc<dyn RuntimeMetrics>) -> Self

pub fn with_outcome_store( self, store: Arc<dyn ClusterForwardOutcomeStore>, ) -> Self

pub fn with_retry_policy( self, max_attempts: u32, base_backoff_ms: u64, max_backoff_ms: u64, ) -> Self

pub fn with_idempotency_ttl(self, ttl: Duration) -> Self

Trait Implementations

impl Clone for HttpClusterCommandForwarder

fn clone(&self) -> HttpClusterCommandForwarder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterCommandForwarder for HttpClusterCommandForwarder

fn forward<'life0, 'async_trait>( &'life0 self, command: ClusterForwardCommand, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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