Trait IOBackend 

pub trait IOBackend: Send + Sync {
    // Required methods
    fn schedule_read(
        &self,
        page_id: PageId,
    ) -> QuillSQLResult<DiskCommandResultReceiver<BytesMut>>;
    fn schedule_read_pages(
        &self,
        page_ids: Vec<PageId>,
    ) -> QuillSQLResult<DiskCommandResultReceiver<Vec<BytesMut>>>;
    fn schedule_write(
        &self,
        page_id: PageId,
        data: Bytes,
    ) -> QuillSQLResult<DiskCommandResultReceiver<()>>;
    fn schedule_allocate(
        &self,
    ) -> QuillSQLResult<DiskCommandResultReceiver<PageId>>;
    fn schedule_deallocate(
        &self,
        page_id: PageId,
    ) -> QuillSQLResult<DiskCommandResultReceiver<()>>;
}

IO backend abstraction for DiskScheduler. Implementations are responsible for request routing and graceful shutdown.

Required Methods

fn schedule_read( &self, page_id: PageId, ) -> QuillSQLResult<DiskCommandResultReceiver<BytesMut>>

Schedule single-page read.

fn schedule_read_pages( &self, page_ids: Vec<PageId>, ) -> QuillSQLResult<DiskCommandResultReceiver<Vec<BytesMut>>>

Schedule batch reads, preserving order of input page_ids in the output.

fn schedule_write( &self, page_id: PageId, data: Bytes, ) -> QuillSQLResult<DiskCommandResultReceiver<()>>

Schedule single-page write (exact PAGE_SIZE bytes).

fn schedule_allocate(&self) -> QuillSQLResult<DiskCommandResultReceiver<PageId>>

Allocate a new page id.

fn schedule_deallocate( &self, page_id: PageId, ) -> QuillSQLResult<DiskCommandResultReceiver<()>>

Deallocate a page id (zeroing on disk, then freelist push).

Implementors

impl IOBackend for DiskScheduler

impl IOBackend for ThreadPoolBackend