Struct PgBinary 

pub struct PgBinary;

A value read back from an executed Postgres query in binary result format, tagged with the catalog’s semantic type for the column.

Unlike the CDC sources, the semantic type is not recoverable from the raw bytes (binary int4 and float4 are both four opaque bytes), so the payload carries the WireType explicitly, supplied by the caller from its catalog. This makes decoder dispatch deterministic and makes the caller choose the type the same way CDC does, which is what guarantees representation parity with the CDC paths.

Trait Implementations

impl Clone for PgBinary

fn clone(&self) -> PgBinary

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PgBinary

impl Debug for PgBinary

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

Formats the value using the given formatter.

impl<S, B> Decoder<PgBinary, S, B> for NullDecoder

fn decode( &self, _payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for BoolDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for IntDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for RealDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for TextDecoder

where S: From<String>,

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for PgByteaBinaryDecoder

where B: From<Vec<u8>>,

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for UuidBlob16Decoder

where B: From<Vec<u8>>,

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for DecimalTextDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for TimestampVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for TimestampTzVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for DateVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for TimeVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for IntervalVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl<S, B> Decoder<PgBinary, S, B> for JsonVerbatimDecoder

fn decode( &self, payload: PgBinaryColumn<'_>, ) -> Result<Value<S, B>, DecodeError>

Decode one payload.

impl Default for PgBinary

fn default() -> PgBinary

Returns the “default value” for a type.

impl<S, B> TypeMapDefaults<S, B> for PgBinary

where S: From<String>, B: From<Vec<u8>>,

fn defaults() -> TypeMap<Self, S, B>

Registry pre-populated with every default mapping for this source.

impl WireSource for PgBinary

type Payload<'a> = PgBinaryColumn<'a>

Per-column payload the format hands to a decoder.

fn wire_type(payload: &Self::Payload<'_>) -> WireType

Semantic type of the column carried by the payload, used for decoder dispatch.

fn column_name<'a>(payload: &'a Self::Payload<'_>) -> &'a str

Extract the column name from a payload for diagnostic messages.