Struct laminarmq_io::fs::tokio_uring::TokioUringFile

pub struct TokioUringFile { /* private fields */ }

Implementations

impl TokioUringFile

pub async fn new<P: AsRef<Path>>(path: P) -> Result<Self, TokioUringFileError>

Trait Implementations

impl AsyncAppend for TokioUringFile

async fn append( &mut self, bytes: Bytes, ) -> Result<AppendInfo<Self::Position, Self::Size>, UnwrittenError<Self::Error>>

impl AsyncBufRead for TokioUringFile

async fn read_at_buf( &mut self, position: Self::Position, buffer: BytesMut, ) -> Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>

fn read_at_buf_sized( &mut self, position: Self::Position, size: Self::Size, buffer: BytesMut, ) -> impl Future<Output = Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>>

impl AsyncClose for TokioUringFile

async fn close(self) -> Result<(), Self::Error>

impl AsyncFlush for TokioUringFile

async fn flush(&mut self) -> Result<(), Self::Error>

impl AsyncRemove for TokioUringFile

async fn remove(self) -> Result<(), Self::Error>

impl FallibleEntity for TokioUringFile

type Error = TokioUringFileError

impl SizedEntity for TokioUringFile

type Position = u64

type Size = u64

fn size(&self) -> Self::Size

fn contains(&self, position: Self::Position) -> bool