Struct TBinaryProtocol 

pub struct TBinaryProtocol<T> { /* private fields */ }

Implementations

impl<T> TBinaryProtocol<T>

pub fn new(trans: T, zero_copy: bool) -> Self

zero_copy only takes effect when T is BytesMut for input and LinkedBytes for output.

Trait Implementations

impl TInputProtocol for TBinaryProtocol<&mut Bytes>

type Buf = Bytes

fn read_message_begin(&mut self) -> Result<TMessageIdentifier, ThriftException>

Read the beginning of a Thrift message.

fn read_message_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift message.

fn read_struct_begin( &mut self, ) -> Result<Option<TStructIdentifier>, ThriftException>

Read the beginning of a Thrift struct.

fn read_struct_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift struct.

fn read_field_begin(&mut self) -> Result<TFieldIdentifier, ThriftException>

Read the beginning of a Thrift struct field.

fn read_field_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift struct field.

fn read_bool(&mut self) -> Result<bool, ThriftException>

Read a bool.

fn read_bytes(&mut self) -> Result<Bytes, ThriftException>

Read a binary.

fn get_bytes( &mut self, ptr: Option<*const u8>, len: usize, ) -> Result<Bytes, ThriftException>

fn read_uuid(&mut self) -> Result<[u8; 16], ThriftException>

Read a uuid.

fn read_i8(&mut self) -> Result<i8, ThriftException>

Read a word.

fn read_i16(&mut self) -> Result<i16, ThriftException>

Read a 16-bit signed integer.

fn read_i32(&mut self) -> Result<i32, ThriftException>

Read a 32-bit signed integer.

fn read_i64(&mut self) -> Result<i64, ThriftException>

Read a 64-bit signed integer.

fn read_double(&mut self) -> Result<f64, ThriftException>

Read a 64-bit float.

fn read_string(&mut self) -> Result<String, ThriftException>

Read a fixed-length string (not null terminated).

fn read_faststr(&mut self) -> Result<FastStr, ThriftException>

Read a faststr.

fn read_list_begin(&mut self) -> Result<TListIdentifier, ThriftException>

Read the beginning of a list.

fn read_list_end(&mut self) -> Result<(), ThriftException>

Read the end of a list.

fn read_set_begin(&mut self) -> Result<TSetIdentifier, ThriftException>

Read the beginning of a set.

fn read_set_end(&mut self) -> Result<(), ThriftException>

Read the end of a set.

fn read_map_begin(&mut self) -> Result<TMapIdentifier, ThriftException>

Read the beginning of a map.

fn read_map_end(&mut self) -> Result<(), ThriftException>

Read the end of a map.

fn read_byte(&mut self) -> Result<u8, ThriftException>

Read an unsigned byte.

fn read_bytes_vec(&mut self) -> Result<Vec<u8>, ThriftException>

Read a Vec.

fn skip(&mut self, field_type: TType) -> Result<usize, ThriftException>

Skip a field with type field_type recursively until the default maximum skip depth is reached.

fn skip_till_depth( &mut self, field_type: TType, depth: i8, ) -> Result<usize, ThriftException>

Skip a field with type field_type recursively up to depth levels.

impl<T> TLengthProtocol for TBinaryProtocol<T>

fn message_begin_len(&mut self, identifier: &TMessageIdentifier) -> usize

fn message_end_len(&mut self) -> usize

fn struct_begin_len(&mut self, _identifier: &TStructIdentifier) -> usize

fn struct_end_len(&mut self) -> usize

fn field_begin_len(&mut self, _field_type: TType, _id: Option<i16>) -> usize

fn field_end_len(&mut self) -> usize

fn field_stop_len(&mut self) -> usize

fn bool_len(&mut self, _b: bool) -> usize

fn bytes_len(&mut self, b: &[u8]) -> usize

fn byte_len(&mut self, _b: u8) -> usize

fn uuid_len(&mut self, _u: [u8; 16]) -> usize

fn i8_len(&mut self, _i: i8) -> usize

fn i16_len(&mut self, _i: i16) -> usize

fn i32_len(&mut self, _i: i32) -> usize

fn i64_len(&mut self, _i: i64) -> usize

fn double_len(&mut self, _d: f64) -> usize

fn string_len(&mut self, s: &str) -> usize

fn faststr_len(&mut self, s: &FastStr) -> usize

fn list_begin_len(&mut self, _identifier: TListIdentifier) -> usize

fn list_end_len(&mut self) -> usize

fn set_begin_len(&mut self, _identifier: TSetIdentifier) -> usize

fn set_end_len(&mut self) -> usize

fn map_begin_len(&mut self, _identifier: TMapIdentifier) -> usize

fn map_end_len(&mut self) -> usize

fn bytes_vec_len(&mut self, b: &[u8]) -> usize

fn zero_copy_len(&mut self) -> usize

The zero copy length used to calculate the recommended malloc length.

fn reset(&mut self)

Resets the zero copy length counter.

impl TOutputProtocol for TBinaryProtocol<&mut BytesMut>

type BufMut = BytesMut

fn write_message_begin( &mut self, identifier: &TMessageIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a Thrift message.

fn write_message_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift message.

fn write_struct_begin( &mut self, _: &TStructIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a Thrift struct.

fn write_struct_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift struct.

fn write_field_begin( &mut self, field_type: TType, id: i16, ) -> Result<(), ThriftException>

Write the beginning of a Thrift field.

fn write_field_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift field.

fn write_field_stop(&mut self) -> Result<(), ThriftException>

Write a STOP field indicating that all the fields in a struct have been written.

fn write_bool(&mut self, b: bool) -> Result<(), ThriftException>

Write a bool.

fn write_bytes(&mut self, b: Bytes) -> Result<(), ThriftException>

Write a fixed-length byte array.

fn write_bytes_without_len(&mut self, b: Bytes) -> Result<(), ThriftException>

fn write_byte(&mut self, b: u8) -> Result<(), ThriftException>

Write a byte.

fn write_uuid(&mut self, u: [u8; 16]) -> Result<(), ThriftException>

Write a uuid.

fn write_i8(&mut self, i: i8) -> Result<(), ThriftException>

Write an 8-bit signed integer.

fn write_i16(&mut self, i: i16) -> Result<(), ThriftException>

Write a 16-bit signed integer.

fn write_i32(&mut self, i: i32) -> Result<(), ThriftException>

Write a 32-bit signed integer.

fn write_i64(&mut self, i: i64) -> Result<(), ThriftException>

Write a 64-bit signed integer.

fn write_double(&mut self, d: f64) -> Result<(), ThriftException>

Write a 64-bit float.

fn write_string(&mut self, s: &str) -> Result<(), ThriftException>

Write a fixed-length string.

fn write_faststr(&mut self, s: FastStr) -> Result<(), ThriftException>

Write a fixed-length faststr.

fn write_list_begin( &mut self, identifier: TListIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a list.

fn write_list_end(&mut self) -> Result<(), ThriftException>

Write the end of a list.

fn write_set_begin( &mut self, identifier: TSetIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a set.

fn write_set_end(&mut self) -> Result<(), ThriftException>

Write the end of a set.

fn write_map_begin( &mut self, identifier: TMapIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a map.

fn write_map_end(&mut self) -> Result<(), ThriftException>

Write the end of a map.

fn flush(&mut self) -> Result<(), ThriftException>

Flush buffered bytes to the underlying transport.

fn write_bytes_vec(&mut self, b: &[u8]) -> Result<(), ThriftException>

Write a Vec.

impl TOutputProtocol for TBinaryProtocol<&mut LinkedBytes>

type BufMut = LinkedBytes

fn write_message_begin( &mut self, identifier: &TMessageIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a Thrift message.

fn write_message_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift message.

fn write_struct_begin( &mut self, _: &TStructIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a Thrift struct.

fn write_struct_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift struct.

fn write_field_begin( &mut self, field_type: TType, id: i16, ) -> Result<(), ThriftException>

Write the beginning of a Thrift field.

fn write_field_end(&mut self) -> Result<(), ThriftException>

Write the end of a Thrift field.

fn write_field_stop(&mut self) -> Result<(), ThriftException>

Write a STOP field indicating that all the fields in a struct have been written.

fn write_bool(&mut self, b: bool) -> Result<(), ThriftException>

Write a bool.

fn write_bytes(&mut self, b: Bytes) -> Result<(), ThriftException>

Write a fixed-length byte array.

fn write_bytes_without_len(&mut self, b: Bytes) -> Result<(), ThriftException>

fn write_byte(&mut self, b: u8) -> Result<(), ThriftException>

Write a byte.

fn write_uuid(&mut self, u: [u8; 16]) -> Result<(), ThriftException>

Write a uuid.

fn write_i8(&mut self, i: i8) -> Result<(), ThriftException>

Write an 8-bit signed integer.

fn write_i16(&mut self, i: i16) -> Result<(), ThriftException>

Write a 16-bit signed integer.

fn write_i32(&mut self, i: i32) -> Result<(), ThriftException>

Write a 32-bit signed integer.

fn write_i64(&mut self, i: i64) -> Result<(), ThriftException>

Write a 64-bit signed integer.

fn write_double(&mut self, d: f64) -> Result<(), ThriftException>

Write a 64-bit float.

fn write_string(&mut self, s: &str) -> Result<(), ThriftException>

Write a fixed-length string.

fn write_faststr(&mut self, s: FastStr) -> Result<(), ThriftException>

Write a fixed-length faststr.

fn write_list_begin( &mut self, identifier: TListIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a list.

fn write_list_end(&mut self) -> Result<(), ThriftException>

Write the end of a list.

fn write_set_begin( &mut self, identifier: TSetIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a set.

fn write_set_end(&mut self) -> Result<(), ThriftException>

Write the end of a set.

fn write_map_begin( &mut self, identifier: TMapIdentifier, ) -> Result<(), ThriftException>

Write the beginning of a map.

fn write_map_end(&mut self) -> Result<(), ThriftException>

Write the end of a map.

fn flush(&mut self) -> Result<(), ThriftException>

Flush buffered bytes to the underlying transport.

fn write_bytes_vec(&mut self, b: &[u8]) -> Result<(), ThriftException>

Write a Vec.