Enum FlussoType 

pub enum FlussoType {
    Text,
    Identifier,
    Keyword,
    Enum,
    Uuid,
    Boolean,
    Short,
    Integer,
    Long,
    Float,
    Double,
    Decimal,
    Date,
    Timestamp,
    Binary,
    Json,
    GeoPoint,
    Custom {
        postgres: Vec<String>,
        opensearch: String,
    },
}

The declared type of a leaf field — the single vocabulary that bridges a Postgres column type and an OpenSearch mapping type.

A self-describing schema names one of these per scalar field, so the document shape (and the index mapping) is known without ever touching the database. A variant pins both ends: which Postgres types satisfy it (for validation, when a database is reachable) and which OpenSearch MappingType it emits. That is what lets the two disagree on purpose — an Enum is stored as text in Postgres but must be a keyword in OpenSearch.

Variants

Text

Analyzed natural-language full text — descriptions, bios, comments. The default analyzed type; carries the flusso_text analyzer (plain tokenize

• accent/case fold). PG text / varchar → OS text.

Identifier

Identifier-like short text — names, SKUs, codes, statuses. Analyzed with the flusso_code analyzer, which splits on punctuation/case so C-01234 is found by c01234 or 01234. PG text / varchar → OS text.

Keyword

Exact, aggregatable token. PG text / varchar → OS keyword.

Enum

A closed set of string values — stored as text in Postgres (a varchar or a PG enum), indexed exactly as a keyword.

Uuid

PG uuid → OS keyword.

Boolean

PG boolean → OS boolean.

Short

PG smallint / int2 → OS short.

Integer

PG integer / int4 → OS integer.

Long

PG bigint / int8 → OS long.

Float

PG real / float4 → OS float.

Double

PG double precision / float8 → OS double.

Decimal

PG numeric / decimal / money → OS double (lossy but searchable; declare Custom scaled_float when exactness matters).

Date

PG date → OS date.

Timestamp

PG timestamp / timestamptz / time → OS date.

Binary

PG bytea → OS binary.

Json

PG json / jsonb → OS object.

GeoPoint

A geographic point → OS geo_point.

The document is assembled server-side as JSON, so the source column must already hold a value OpenSearch accepts as a geo_point and that carries through JSON verbatim: json/jsonb shaped as {"lat": …, "lon": …} or [lon, lat], or text as "lat,lon". A PostGIS geometry or PG-native point is not accepted — it would serialize as WKB / (x,y); expose a generated jsonb/text column in that shape instead.

Custom

An escape hatch: an explicit OpenSearch type with the Postgres types it accepts, for anything the named variants don’t cover (geo_shape, scaled_float, …).

Fields

postgres: Vec<String>

opensearch: String

Implementations

impl FlussoType

pub fn opensearch(&self) -> MappingType

The OpenSearch MappingType this declared type maps to.

pub fn accepts_pg(&self, sql_type: &str) -> bool

Whether sql_type (a Postgres type name as format_type reports it, e.g. bigint, character varying(255), numeric(10,2), integer[]) is a Postgres type this declared type accepts. Used to validate a declared schema against a live database; with no database, it is never consulted.

Trait Implementations

impl Clone for FlussoType

fn clone(&self) -> FlussoType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlussoType

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FlussoType

fn deserialize<__D>( __deserializer: __D, ) -> Result<FlussoType, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for FlussoType

impl Hash for FlussoType

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for FlussoType

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for FlussoType

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FlussoType