Struct sc_statement_store::Store

pub struct Store { /* private fields */ }

Statement store.

Implementations

impl Store

pub fn new_shared<Block, Client>( path: &Path, options: Options, client: Arc<Client>, keystore: Arc<LocalKeystore>, prometheus: Option<&PrometheusRegistry>, task_spawner: &dyn SpawnNamed ) -> Result<Arc<Store>>

where Block: BlockT, Block::Hash: From<BlockHash>, Client: ProvideRuntimeApi<Block> + HeaderBackend<Block> + ExecutorProvider<Block> + Send + Sync + 'static, Client::Api: ValidateStatement<Block>,

Create a new shared store instance. There should only be one per process. path will be used to open a statement database or create a new one if it does not exist.

pub fn maintain(&self)

Perform periodic store maintenance

pub fn as_statement_store_ext(self: Arc<Self>) -> StatementStoreExt

Returns self as StatementStoreExt.

Trait Implementations

impl StatementStore for Store

fn statements(&self) -> Result<Vec<(Hash, Statement)>>

Return all statements.

fn statement(&self, hash: &Hash) -> Result<Option<Statement>>

Returns a statement by hash.

fn broadcasts(&self, match_all_topics: &[Topic]) -> Result<Vec<Vec<u8>>>

Return the data of all known statements which include all topics and have no DecryptionKey field.

fn posted( &self, match_all_topics: &[Topic], dest: [u8; 32] ) -> Result<Vec<Vec<u8>>>

Return the data of all known statements whose decryption key is identified as dest (this will generally be the public key or a hash thereof for symmetric ciphers, or a hash of the private key for symmetric ciphers).

fn posted_clear( &self, match_all_topics: &[Topic], dest: [u8; 32] ) -> Result<Vec<Vec<u8>>>

Return the decrypted data of all known statements whose decryption key is identified as dest. The key must be available to the client.

fn submit(&self, statement: Statement, source: StatementSource) -> SubmitResult

Submit a statement to the store. Validates the statement and returns validation result.

fn remove(&self, hash: &Hash) -> Result<()>

Remove a statement by hash.