Struct ImmutableClient 

pub struct ImmutableClient<H: Hasher, K: AsRef<[u8]> + Codec, V: Codec + Send + Sync> { /* private fields */ }

Implementations

impl<H, K, V> ImmutableClient<H, K, V>

where H: Hasher, K: Array + Codec + Clone + AsRef<[u8]>, V: Codec + Clone + Send + Sync, V::Cfg: Clone, K::Cfg: Clone, Operation<K, V>: Encode + Decode<Cfg = V::Cfg> + Clone,

pub fn new( url: &str, value_cfg: V::Cfg, update_row_cfg: (K::Cfg, V::Cfg), ) -> Self

pub fn from_client( client: StoreClient, value_cfg: V::Cfg, update_row_cfg: (K::Cfg, V::Cfg), ) -> Self

pub fn with_query_visible_sequence(self, seq: Arc<AtomicU64>) -> Self

pub fn inner(&self) -> &StoreClient

pub fn sequence_number(&self) -> u64

pub async fn writer_location_watermark( &self, ) -> Result<Option<Location>, QmdbError>

pub async fn upload_operations( &self, latest_location: Location, operations: &[ImmutableOperation<K, V>], ) -> Result<UploadReceipt, QmdbError>

pub async fn publish_writer_location_watermark( &self, location: Location, ) -> Result<Location, QmdbError>

pub async fn root_at(&self, watermark: Location) -> Result<H::Digest, QmdbError>

pub async fn get_at( &self, key: &K, watermark: Location, ) -> Result<Option<VersionedValue<K, V>>, QmdbError>

pub async fn operation_range_proof( &self, watermark: Location, start_location: Location, max_locations: u32, ) -> Result<AuthenticatedOperationRangeProof<H::Digest, ImmutableOperation<K, V>>, QmdbError>

Trait Implementations

impl<H: Clone + Hasher, K: Clone + AsRef<[u8]> + Codec, V: Clone + Codec + Send + Sync> Clone for ImmutableClient<H, K, V>

where V::Cfg: Clone, K::Cfg: Clone,

fn clone(&self) -> ImmutableClient<H, K, V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: Debug + Hasher, K: Debug + AsRef<[u8]> + Codec, V: Debug + Codec + Send + Sync> Debug for ImmutableClient<H, K, V>

where V::Cfg: Debug, K::Cfg: Debug,

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

Formats the value using the given formatter.