Struct fluvio_future::fs::BoundedFileSink

pub struct BoundedFileSink { /* private fields */ }

File Sink that tracks how much byte it has written This file will not block write operation. It is up to writer to check if maximum file has size is reached since AsyncWrite return IoError

Implementations

impl BoundedFileSink

pub async fn create<P>( path: P, option: BoundedFileOption ) -> Result<Self, Error>

where P: AsRef<Path>,

pub async fn open_write<P>( path: P, option: BoundedFileOption ) -> Result<Self, Error>

where P: AsRef<Path>,

pub async fn open_append<P>( path: P, option: BoundedFileOption ) -> Result<Self, Error>

where P: AsRef<Path>,

pub fn get_current_len(&self) -> u64

pub fn can_be_appended(&self, buf_len: u64) -> bool

check if buf_len can be written

pub fn get_path(&self) -> &Path

pub fn inner(&self) -> &File

pub fn mut_inner(&mut self) -> &mut File

pub fn slice_from( &self, position: u64, len: u64 ) -> Result<AsyncFileSlice, IoError>

Trait Implementations

impl AsyncWrite for BoundedFileSink

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8] ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>] ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl Unpin for BoundedFileSink