Enum testdrive::format::avro::Value[−][src]

pub enum Value {
Show 19 variants    Null,
    Boolean(bool),
    Int(i32),
    Long(i64),
    Float(f32),
    Double(f64),
    Date(NaiveDate),
    Timestamp(NaiveDateTime),
    Decimal(DecimalValue),
    Bytes(Vec<u8, Global>),
    String(String),
    Fixed(usize, Vec<u8, Global>),
    Enum(usize, String),
    Union {
        index: usize,
        inner: Box<Value, Global>,
        n_variants: usize,
        null_variant: Option<usize>,
    },
    Array(Vec<Value, Global>),
    Map(AvroMap),
    Record(Vec<(String, Value), Global>),
    Json(Value),
    Uuid(Uuid),
}

Expand description

Represents any valid Avro value More information about Avro values can be found in the Avro Specification

Variants

`Null`

A null Avro value.

`Boolean(bool)`

Tuple Fields

0: bool

A boolean Avro value.

`Int(i32)`

Tuple Fields

0: i32

A int Avro value.

`Long(i64)`

Tuple Fields

0: i64

A long Avro value.

`Float(f32)`

Tuple Fields

0: f32

A float Avro value.

`Double(f64)`

Tuple Fields

0: f64

A double Avro value.

`Date(NaiveDate)`

Tuple Fields

0: NaiveDate

A Date coming from an avro Logical Date

`Timestamp(NaiveDateTime)`

Tuple Fields

0: NaiveDateTime

A DateTime coming from an avro Logical Timestamp

`Decimal(DecimalValue)`

Tuple Fields

0: DecimalValue

A decimal Avro value

The value of the decimal can be computed as follows: unscaled × 10^-scale.

`Bytes(Vec<u8, Global>)`

Tuple Fields

0: Vec<u8, Global>

A bytes Avro value.

`String(String)`

Tuple Fields

0: String

A string Avro value.

`Fixed(usize, Vec<u8, Global>)`

Tuple Fields

0: usize

1: Vec<u8, Global>

A fixed Avro value. The size of the fixed value is represented as a usize.

`Enum(usize, String)`

Tuple Fields

0: usize

1: String

An enum Avro value.

An Enum is represented by a symbol and its position in the symbols list of its corresponding schema. This allows schema-less encoding, as well as schema resolution while reading values.

`Union`

Fields

index: usize

The index of this variant in the reader schema

inner: Box<Value, Global>

The value of the variant

n_variants: usize

The number of variants in the reader schema

null_variant: Option<usize>

Which variant is null in the reader schema.

An union Avro value.

`Array(Vec<Value, Global>)`

Tuple Fields

0: Vec<Value, Global>

An array Avro value.

`Map(AvroMap)`

Tuple Fields

0: AvroMap

A map Avro value.

`Record(Vec<(String, Value), Global>)`

Tuple Fields

0: Vec<(String, Value), Global>

A record Avro value.

A Record is represented by a vector of (<field name>, value). This allows schema-less encoding.

See Record for a more user-friendly support.

`Json(Value)`

Tuple Fields

0: Value

A string Avro value that has been interpreted as JSON.

This is not part of the Avro spec, but is emitted by Debezium, and distinguished by setting the "connect.name" property to "io.debezium.data.Json".

`Uuid(Uuid)`

Tuple Fields

0: Uuid

A Uuid coming from an avro Logical uuid.

Enum testdrive::format::avro::Value[−][src]

Variants

Null

Boolean(bool)

Tuple Fields

Int(i32)

Tuple Fields

Long(i64)

Tuple Fields

Float(f32)

Tuple Fields

Double(f64)

Tuple Fields

Date(NaiveDate)

Tuple Fields

Timestamp(NaiveDateTime)

Tuple Fields

Decimal(DecimalValue)

Tuple Fields

Bytes(Vec<u8, Global>)

Tuple Fields

String(String)

Tuple Fields

Fixed(usize, Vec<u8, Global>)

Tuple Fields

Enum(usize, String)

Tuple Fields

Union

Fields

Array(Vec<Value, Global>)

Tuple Fields

Map(AvroMap)

Tuple Fields

Record(Vec<(String, Value), Global>)

Tuple Fields

Json(Value)

Tuple Fields

Uuid(Uuid)

Tuple Fields

Implementations

impl Value

pub fn validate(&self, schema: SchemaNode<'_>) -> bool

pub fn into_string(self) -> Option<String>

pub fn into_nullable_bool(self) -> Option<bool>

pub fn into_integral(self) -> Option<i64>

pub fn into_usize(self) -> Option<usize>

Trait Implementations

impl<'a> AvroDeserializer for &'a Value

pub fn deserialize<R, D>( self, _r: &mut R, d: D) -> Result<<D as AvroDecode>::Out, Error> where R: AvroRead, D: AvroDecode,

impl Clone for Value

pub fn clone(&self) -> Value

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

impl Debug for Value

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

impl Default for Value

pub fn default() -> Value

impl From<Scalar> for Value

pub fn from(s: Scalar) -> Value

impl PartialEq<Value> for Value

pub fn eq(&self, other: &Value) -> bool

pub fn ne(&self, other: &Value) -> bool

impl ToAvro for Value

pub fn avro(self) -> Value

impl StructuralPartialEq for Value

Auto Trait Implementations

impl RefUnwindSafe for Value

impl Send for Value

impl Sync for Value

impl Unpin for Value

impl UnwindSafe for Value

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> Conv for T

fn conv<T>(self) -> T where Self: Into<T>,

impl<Choices> CoproductSubsetter<CNil, HNil> for Choices

`Null`

`Boolean(bool)`

`Int(i32)`

`Long(i64)`

`Float(f32)`

`Double(f64)`

`Date(NaiveDate)`

`Timestamp(NaiveDateTime)`

`Decimal(DecimalValue)`

`Bytes(Vec<u8, Global>)`

`String(String)`

`Fixed(usize, Vec<u8, Global>)`

`Enum(usize, String)`

`Union`

`Array(Vec<Value, Global>)`

`Map(AvroMap)`

`Record(Vec<(String, Value), Global>)`

`Json(Value)`

`Uuid(Uuid)`

pub fn deserialize<R, D>(
self,
_r: &mut R,
d: D
) -> Result<<D as AvroDecode>::Out, Error> where
R: AvroRead,
D: AvroDecode,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

fn conv<T>(self) -> T where
Self: Into<T>,

pub fn subset(
self
) -> Result<CNil, <Choices as CoproductSubsetter<CNil, HNil>>::Remainder>

fn fmt_binary(self) -> FmtBinary<Self> where
Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self> where
Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self> where
Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self> where
Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self> where
Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self> where
Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self> where
Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self> where
Self: UpperHex,

fn fmt_list(self) -> FmtList<Self> where
&'a Self: for<'a> IntoIterator,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U, I> LiftInto<U, I> for T where
U: LiftFrom<T, I>,

impl<T> Pipe for T where
T: ?Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where
R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where
R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where
Self: Borrow<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> R where
Self: BorrowMut<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where
Self: AsRef<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R where
Self: AsMut<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
Self: Deref<Target = T>,
T: 'a + ?Sized,
R: 'a,

fn pipe_deref_mut<'a, T, R>(
&'a mut self,
func: impl FnOnce(&'a mut T) -> R
) -> R where
Self: DerefMut<Target = T> + Deref,
T: 'a + ?Sized,
R: 'a,

impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,

pub fn sculpt(self) -> (HNil, <Source as Sculptor<HNil, HNil>>::Remainder )

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self where
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,