Struct avro_rs::Writer
[−]
[src]
pub struct Writer<'a, W> { /* fields omitted */ }Main interface for writing Avro formatted values.
Methods
impl<'a, W: Write> Writer<'a, W>[src]
pub fn new(schema: &'a Schema, writer: W) -> Writer<'a, W>[src]
Creates a Writer given a Schema and something implementing the io::Write trait to write
to.
No compression Codec will be used.
pub fn with_codec(schema: &'a Schema, writer: W, codec: Codec) -> Writer<'a, W>[src]
Creates a Writer with a specific Codec given a Schema and something implementing the
io::Write trait to write to.
pub fn schema(&self) -> &'a Schema[src]
Get a reference to the Schema associated to a Writer.
pub fn append<T: ToAvro>(&mut self, value: T) -> Result<usize, Error>[src]
Append a compatible value (implementing the ToAvro trait) to a Writer, also performing
schema validation.
Return the number of bytes written (it might be 0, see below).
NOTE This function is not guaranteed to perform any actual write, since it relies on
internal buffering for performance reasons. If you want to be sure the value has been
written, then call flush.
pub fn append_ser<S: Serialize>(&mut self, value: S) -> Result<usize, Error>[src]
Append anything implementing the Serialize trait to a Writer for
serde compatibility, also performing schema
validation.
Return the number of bytes written.
NOTE This function is not guaranteed to perform any actual write, since it relies on
internal buffering for performance reasons. If you want to be sure the value has been
written, then call flush.
pub fn extend<I, T: ToAvro>(&mut self, values: I) -> Result<usize, Error> where
I: Iterator<Item = T>, [src]
I: Iterator<Item = T>,
Extend a Writer with an Iterator of compatible values (implementing the ToAvro
trait), also performing schema validation.
Return the number of bytes written.
NOTE This function is not guaranteed to perform any actual write, since it relies on
internal buffering for performance reasons. If you want to be sure the value has been
written, then call flush.
pub fn extend_ser<I, T: Serialize>(&mut self, values: I) -> Result<usize, Error> where
I: Iterator<Item = T>, [src]
I: Iterator<Item = T>,
Extend a Writer with an Iterator of anything implementing the Serialize trait for
serde compatibility, also performing schema
validation.
Return the number of bytes written.
NOTE This function is not guaranteed to perform any actual write, since it relies on
internal buffering for performance reasons. If you want to be sure the value has been
written, then call flush.
pub fn flush(&mut self) -> Result<usize, Error>[src]
Flush the content appended to a Writer. Call this function to make sure all the content
has been written before releasing the Writer.
Return the number of bytes written.
pub fn into_inner(self) -> W[src]
Return what the Writer is writing to, consuming the Writer itself.
NOTE This function doesn't guarantee that everything gets written before consuming the
buffer. Please call flush before.