Enum PostgresValue 

pub enum PostgresValue {
    Null,
    Bool(bool),
    Int2(i16),
    Int4(i32),
    Int8(i64),
    Float4(f32),
    Float8(f64),
    Numeric(Decimal),
    Text(String),
    Varchar(String),
    Char(String),
    Uuid(Uuid),
    Timestamp(NaiveDateTime),
    TimestampTz(DateTime<Utc>),
    Date(NaiveDate),
    Time(NaiveTime),
    Json(Value),
    Jsonb(Value),
    Array(Vec<PostgresValue>),
    Bytea(Vec<u8>),
    UnchangedToast,
}

Intermediate typed value shared by bootstrap and CDC paths.

Variants

Null

Bool(bool)

Int2(i16)

Int4(i32)

Int8(i64)

Float4(f32)

Float8(f64)

Numeric(Decimal)

Text(String)

Varchar(String)

Char(String)

Uuid(Uuid)

Timestamp(NaiveDateTime)

TimestampTz(DateTime<Utc>)

Date(NaiveDate)

Time(NaiveTime)

Json(Value)

Jsonb(Value)

Array(Vec<PostgresValue>)

Bytea(Vec<u8>)

UnchangedToast

Column present in a pgoutput tuple but value was not sent (unchanged TOAST). Must not be mapped to ElementValue::Null; property should be omitted so callers can preserve the previously stored value.

Implementations

impl PostgresValue

pub fn to_json(&self) -> JsonValue

Convert to JSON (lossy for temporals). Prefer [to_element_value] for Drasi paths.

pub fn to_element_value(&self) -> ElementValue

Canonical conversion used by both bootstrap and CDC.

Mapping:

• Timestamp → LocalDateTime, TimestampTz → ZonedDateTime
• Numeric → Float (always, including whole numbers)
• Date, Time, Uuid → String
• Json / Jsonb → String (compact JSON text)
• Bytea → String (base64 of raw bytes)
• Char is expected to already be trimmed by the decoder

pub fn is_null(&self) -> bool

Returns true if this value is PostgresValue::Null.

pub fn is_unchanged_toast(&self) -> bool

Returns true if this is an unchanged TOAST placeholder from pgoutput (b'u').

pub fn to_key_string(&self) -> Option<String>

Stable string form for element ID key parts.

Trait Implementations

impl Clone for PostgresValue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresValue

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

Formats the value using the given formatter.