Struct TcpPostcardRecorderClient 

pub struct TcpPostcardRecorderClient { /* private fields */ }

Implementations

impl TcpPostcardRecorderClient

pub fn new( address: impl ToString, expected_recorder_id: impl Into<String>, local_node_id: impl Into<String>, peer_token: impl Into<String>, recovery_generation: u64, ) -> Result<Self, String>

pub fn new_tls( address: impl ToString, expected_recorder_id: impl Into<String>, local_node_id: impl Into<String>, peer_token: impl Into<String>, recovery_generation: u64, tls: RecorderTlsClientConfig, ) -> Result<Self, String>

Trait Implementations

impl Debug for TcpPostcardRecorderClient

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

Formats the value using the given formatter.

impl RecorderRpc for TcpPostcardRecorderClient

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>