Struct ProtobufStreamFormat 

pub struct ProtobufStreamFormat;

Available on crate feature protobuf only.

Protobuf messages, each preceded by its length as a LEB128 varint.

Implementations

impl ProtobufStreamFormat

pub fn new() -> Self

A length-prefixed protobuf format.

Trait Implementations

impl Clone for ProtobufStreamFormat

fn clone(&self) -> ProtobufStreamFormat

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for ProtobufStreamFormat

impl Debug for ProtobufStreamFormat

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ProtobufStreamFormat

fn default() -> ProtobufStreamFormat

Returns the “default value” for a type.

impl DefaultFormat for ProtobufStreamFormat

fn default_format() -> Self

The configuration to use when the caller supplied none.

impl StreamFormat for ProtobufStreamFormat

fn format_name(&self) -> &'static str

A short, stable name, reported as the format tracing field.

fn default_content_type(&self) -> &'static str

The Content-Type this format emits when encoding.

fn accepts_content_type(&self, ct: &ContentType<'_>) -> bool

Whether an incoming Content-Type should be accepted as this format.

impl<T> StreamFormatDecode<T> for ProtobufStreamFormat

where T: Message + Default,

type Frame = Result<T, StreamError>

One framed record, before deserialisation.

type Framer = ProtobufLenPrefixCodec<T>

Splits the body into records.

type Parser = IdentityParser

Deserialises framed records.

fn framer(&self, options: &DecodeOptions) -> Self::Framer

Build a framer for one body.

fn parser(&self) -> Self::Parser

Build a parser for one body.

impl<T> StreamFormatEncode<T> for ProtobufStreamFormat

where T: Message,

type Encoder = ProtobufEncoder

The per-stream encoder. A fresh one is built for every body, because framing state (item index, Arrow’s dictionary tracker, CSV’s header flag) is per-stream.

fn encoder(&self) -> Self::Encoder

Build an encoder for one body.