Struct lance::io::object_writer::ObjectWriter

pub struct ObjectWriter { /* private fields */ }

AsyncWrite with the capability to tell the position the data is written.

Implementations

impl ObjectWriter

pub async fn new(object_store: &ObjectStore, path: &Path) -> Result<Self>

pub fn tell(&self) -> usize

Tell the current position (file size).

pub async fn write_protobuf(&mut self, msg: &impl Message) -> Result<usize>

Write a protobuf message to the object, and returns the file position of the protobuf.

pub async fn write_struct<'b, M: Message + From<&'b T>, T: ProtoStruct<Proto = M> + 'b>(
&mut self,
obj: &'b T
) -> Result<usize>

pub async fn write_plain_encoded_array(
&mut self,
array: &dyn Array
) -> Result<usize>

Write an array using plain encoding.

Returns the file position if success.

pub async fn write_magics(&mut self, pos: usize) -> Result<()>

Write magics to the tail of a file before closing the file.

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

Trait Implementations

impl AsyncWrite for ObjectWriter

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<()>>

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<'pin> Unpin for ObjectWriterwhere
__ObjectWriter<'pin>: Unpin,