Trait WriteStore 

pub trait WriteStore: ReadStore {
    // Required methods
    fn try_insert_checkpoint(
        &self,
        checkpoint: &VerifiedCheckpoint,
    ) -> Result<()>;
    fn try_update_highest_synced_checkpoint(
        &self,
        checkpoint: &VerifiedCheckpoint,
    ) -> Result<()>;
    fn try_update_highest_verified_checkpoint(
        &self,
        checkpoint: &VerifiedCheckpoint,
    ) -> Result<()>;
    fn try_insert_checkpoint_contents(
        &self,
        checkpoint: &VerifiedCheckpoint,
        contents: VerifiedCheckpointContents,
    ) -> Result<()>;
    fn try_insert_committee(&self, new_committee: Committee) -> Result<()>;

    // Provided methods
    fn insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint) { ... }
    fn update_highest_synced_checkpoint(&self, checkpoint: &VerifiedCheckpoint) { ... }
    fn update_highest_verified_checkpoint(
        &self,
        checkpoint: &VerifiedCheckpoint,
    ) { ... }
    fn insert_checkpoint_contents(
        &self,
        checkpoint: &VerifiedCheckpoint,
        contents: VerifiedCheckpointContents,
    ) { ... }
    fn insert_committee(&self, new_committee: Committee) { ... }
    fn try_get_highest_executed_checkpoint_seq_number(
        &self,
    ) -> Result<Option<CheckpointSequenceNumber>> { ... }
    fn get_highest_executed_checkpoint_seq_number(
        &self,
    ) -> Option<CheckpointSequenceNumber> { ... }
    fn wait_for_executed_checkpoint(
        &self,
        _sequence_number: CheckpointSequenceNumber,
    ) -> impl Future<Output = ()> + Send { ... }
    fn try_insert_synced_checkpoints(
        &self,
        checkpoints: Vec<(VerifiedCheckpoint, VerifiedCheckpointContents)>,
    ) -> Result<()> { ... }
}

Required Methods

fn try_insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint) -> Result<()>

fn try_update_highest_synced_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_update_highest_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_insert_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, contents: VerifiedCheckpointContents, ) -> Result<()>

fn try_insert_committee(&self, new_committee: Committee) -> Result<()>

Provided Methods

fn insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint)

Non-fallible version of try_insert_checkpoint.

fn update_highest_synced_checkpoint(&self, checkpoint: &VerifiedCheckpoint)

Non-fallible version of try_update_highest_synced_checkpoint.

fn update_highest_verified_checkpoint(&self, checkpoint: &VerifiedCheckpoint)

Non-fallible version of try_update_highest_verified_checkpoint.

fn insert_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, contents: VerifiedCheckpointContents, )

Non-fallible version of try_insert_checkpoint_contents.

fn insert_committee(&self, new_committee: Committee)

Non-fallible version of try_insert_committee.

fn try_get_highest_executed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>>

The highest checkpoint whose transactions have been executed, when the store tracks execution progress. None when nothing has been executed yet or the store does not track execution (the default).

fn get_highest_executed_checkpoint_seq_number( &self, ) -> Option<CheckpointSequenceNumber>

Non-fallible version of try_get_highest_executed_checkpoint_seq_number.

fn wait_for_executed_checkpoint( &self, _sequence_number: CheckpointSequenceNumber, ) -> impl Future<Output = ()> + Send

Resolves once the store’s executed watermark has reached the given sequence number. Returns right away for stores that don’t track execution (the default), since their watermark never advances.

fn try_insert_synced_checkpoints( &self, checkpoints: Vec<(VerifiedCheckpoint, VerifiedCheckpointContents)>, ) -> Result<()>

Inserts a consecutive run of verified checkpoints with their full contents and advances the verified and synced watermarks past the last one.

The default implementation inserts the checkpoints one at a time; implementations can override it to batch the writes.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T: WriteStore + ?Sized> WriteStore for &T

fn try_insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint) -> Result<()>

fn try_update_highest_synced_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_update_highest_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_insert_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, contents: VerifiedCheckpointContents, ) -> Result<()>

fn try_insert_committee(&self, new_committee: Committee) -> Result<()>

fn try_get_highest_executed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>>

fn try_insert_synced_checkpoints( &self, checkpoints: Vec<(VerifiedCheckpoint, VerifiedCheckpointContents)>, ) -> Result<()>

fn wait_for_executed_checkpoint( &self, sequence_number: CheckpointSequenceNumber, ) -> impl Future<Output = ()> + Send

impl<T: WriteStore + ?Sized> WriteStore for Box<T>

fn try_insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint) -> Result<()>

fn try_update_highest_synced_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_update_highest_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_insert_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, contents: VerifiedCheckpointContents, ) -> Result<()>

fn try_insert_committee(&self, new_committee: Committee) -> Result<()>

fn try_get_highest_executed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>>

fn try_insert_synced_checkpoints( &self, checkpoints: Vec<(VerifiedCheckpoint, VerifiedCheckpointContents)>, ) -> Result<()>

fn wait_for_executed_checkpoint( &self, sequence_number: CheckpointSequenceNumber, ) -> impl Future<Output = ()> + Send

impl<T: WriteStore + ?Sized> WriteStore for Arc<T>

fn try_insert_checkpoint(&self, checkpoint: &VerifiedCheckpoint) -> Result<()>

fn try_update_highest_synced_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_update_highest_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<()>

fn try_insert_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, contents: VerifiedCheckpointContents, ) -> Result<()>

fn try_insert_committee(&self, new_committee: Committee) -> Result<()>

fn try_get_highest_executed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>>

fn try_insert_synced_checkpoints( &self, checkpoints: Vec<(VerifiedCheckpoint, VerifiedCheckpointContents)>, ) -> Result<()>

fn wait_for_executed_checkpoint( &self, sequence_number: CheckpointSequenceNumber, ) -> impl Future<Output = ()> + Send

Implementors

impl WriteStore for SharedInMemoryStore

impl WriteStore for SingleCheckpointSharedInMemoryStore