Struct HttpRecorderClient 

pub struct HttpRecorderClient { /* private fields */ }

Implementations

impl HttpRecorderClient

pub fn new( base_url: impl Into<String>, local_node_id: impl Into<String>, peer_token: impl Into<String>, ) -> Result<Self, ConfigError>

pub fn new_with_recovery_generation( base_url: impl Into<String>, local_node_id: impl Into<String>, peer_token: impl Into<String>, recovery_generation: u64, ) -> Result<Self, ConfigError>

pub fn with_recovery_generation( self, recovery_generation: u64, ) -> Result<Self, ConfigError>

Trait Implementations

impl Clone for HttpRecorderClient

fn clone(&self) -> HttpRecorderClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpRecorderClient

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

Formats the value using the given formatter.

impl RecorderRpc for HttpRecorderClient

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

fn store_command_for( &self, cluster_id: String, epoch: u64, config_id: u64, config_digest: LogHash, command_hash: LogHash, command: StoredCommand, ) -> Result<()>

fn fetch_command_for( &self, cluster_id: String, epoch: u64, config_id: u64, config_digest: LogHash, command_hash: LogHash, ) -> Result<Option<StoredCommand>>

fn record(&self, request: RecordRequest) -> Result<RecordSummary>

Performs one genuine QuePaxa Record operation.

fn install_decision_proof( &self, proof: DecisionProof, membership: &Membership, ) -> Result<()>

fn inspect_decision_proof(&self, slot: u64) -> Result<Option<DecisionProof>>

fn inspect_record_summary(&self, slot: u64) -> Result<Option<RecordSummary>>

fn supports_context_read_fence(&self) -> bool

Whether this recorder can atomically bind an exact slot observation to the durable maximum accepted-or-decided head and the requested config.

fn observe_read_fence( &self, request: ReadFenceRequest, ) -> Result<ReadFenceObservation>

fn store_command( &self, command_hash: LogHash, command: StoredCommand, ) -> Result<(), Error>

fn fetch_command( &self, command_hash: LogHash, ) -> Result<Option<StoredCommand>, Error>