Trait deno_kv::Database

pub trait Database {
    type QMH: QueueMessageHandle + 'static;

    // Required methods
    fn snapshot_read<'life0, 'async_trait>(
        &'life0 self,
        state: Rc<RefCell<OpState>>,
        requests: Vec<ReadRange>,
        options: SnapshotReadOptions
    ) -> Pin<Box<dyn Future<Output = Result<Vec<ReadRangeOutput>, AnyError>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn atomic_write<'life0, 'async_trait>(
        &'life0 self,
        state: Rc<RefCell<OpState>>,
        write: AtomicWrite
    ) -> Pin<Box<dyn Future<Output = Result<Option<CommitResult>, AnyError>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn dequeue_next_message<'life0, 'async_trait>(
        &'life0 self,
        state: Rc<RefCell<OpState>>
    ) -> Pin<Box<dyn Future<Output = Result<Option<Self::QMH>, AnyError>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn close(&self);
}

Required Associated Types

type QMH: QueueMessageHandle + 'static

Required Methods

fn snapshot_read<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>>, requests: Vec<ReadRange>, options: SnapshotReadOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<ReadRangeOutput>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn atomic_write<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>>, write: AtomicWrite ) -> Pin<Box<dyn Future<Output = Result<Option<CommitResult>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn dequeue_next_message<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>> ) -> Pin<Box<dyn Future<Output = Result<Option<Self::QMH>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn close(&self)

Implementations on Foreign Types

impl Database for Box<dyn DynamicDb>

type QMH = Box<dyn QueueMessageHandle, Global>

fn snapshot_read<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>>, requests: Vec<ReadRange>, options: SnapshotReadOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<ReadRangeOutput>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn atomic_write<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>>, write: AtomicWrite ) -> Pin<Box<dyn Future<Output = Result<Option<CommitResult>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn dequeue_next_message<'life0, 'async_trait>( &'life0 self, state: Rc<RefCell<OpState>> ) -> Pin<Box<dyn Future<Output = Result<Option<Box<dyn QueueMessageHandle>>, AnyError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn close(&self)

Implementors

impl Database for SqliteDb

type QMH = DequeuedMessage

impl<P: RemoteDbHandlerPermissions> Database for RemoteDb<P>

type QMH = DummyQueueMessageHandle