Struct opendal::Appender

pub struct Appender { /* private fields */ }

Appender is designed to append data into given path in an asynchronous manner.

Notes

Please make sure either `close`` has been called before dropping the appender otherwise the data could be lost.

Notes

Appender always append data into the end of the file, so it’s not possible to overwrite existing data.

Appender did not know the size of the data to be written, so it will always be unsized.

Implementations

impl Appender

pub async fn append(&mut self, bs: impl Into<Bytes>) -> Result<()>

Write into inner appender.

pub async fn close(&mut self) -> Result<()>

Close the appender and make sure all data have been committed.

Notes

Close should only be called when the appender is not closed, otherwise an unexpected error could be returned.

Trait Implementations

impl AsyncWrite for Appender

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>, _: &mut Context<'_>) -> Poll<Result<()>>

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

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

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

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl AsyncWrite for Appender

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>, _: &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 Sync for Appender

Safety

Appender will only be accessed by &mut Self