Trait casper_execution_engine::storage::transaction_source::TransactionSource

pub trait TransactionSource<'a> {
    type Error;
    type Handle;
    type ReadTransaction: Readable<Error = Self::Error, Handle = Self::Handle>;
    type ReadWriteTransaction: Readable<Error = Self::Error, Handle = Self::Handle> + Writable<Error = Self::Error, Handle = Self::Handle>;
    fn create_read_txn(&'a self) -> Result<Self::ReadTransaction, Self::Error>;
    fn create_read_write_txn(
        &'a self
    ) -> Result<Self::ReadWriteTransaction, Self::Error>;
}

A source of transactions e.g. values that implement Readable and/or Writable.

Associated Types

type Error

An error which can occur while creating a read or read-write transaction.

type Handle

An entity which is being read from or written to during a transaction.

type ReadTransaction: Readable<Error = Self::Error, Handle = Self::Handle>

Represents the type of read transactions.

type ReadWriteTransaction: Readable<Error = Self::Error, Handle = Self::Handle> + Writable<Error = Self::Error, Handle = Self::Handle>

Represents the type of read-write transactions.

Required methods

fn create_read_txn(&'a self) -> Result<Self::ReadTransaction, Self::Error>

Creates a read transaction.

fn create_read_write_txn(
    &'a self
) -> Result<Self::ReadWriteTransaction, Self::Error>

Creates a read-write transaction.

Implementors

impl<'a> TransactionSource<'a> for InMemoryEnvironment

type Error = Error

type Handle = Option<String>

type ReadTransaction = InMemoryReadTransaction

type ReadWriteTransaction = InMemoryReadWriteTransaction<'a>

fn create_read_txn(&'a self) -> Result<InMemoryReadTransaction, Self::Error>

fn create_read_write_txn(
    &'a self
) -> Result<InMemoryReadWriteTransaction<'a>, Self::Error>

impl<'a> TransactionSource<'a> for LmdbEnvironment

type Error = Error

type Handle = Database

type ReadTransaction = RoTransaction<'a>

type ReadWriteTransaction = RwTransaction<'a>

fn create_read_txn(&'a self) -> Result<RoTransaction<'a>, Self::Error>

fn create_read_write_txn(&'a self) -> Result<RwTransaction<'a>, Self::Error>