Struct GraphqlApi 

pub struct GraphqlApi { /* private fields */ }

GraphQL HTTP data source. Cheap to clone — the inner reqwest::Client is Arc-wrapped.

dialect and filter_arg_name drive how the TableSource impl renders filter arguments — Hasura’s where: vs SpaceX-style find:, etc. Both default to the dialect’s natural choice (Generic + find).

Implementations

impl GraphqlApi

pub fn new(endpoint: impl Into<String>) -> Self

Connect to a GraphQL endpoint at endpoint (e.g. https://api.spacex.land/graphql/). Uses the default reqwest client; for finer control go through GraphqlApi::builder.

pub fn builder(endpoint: impl Into<String>) -> GraphqlApiBuilder

Start configuring a GraphqlApi.

pub fn endpoint(&self) -> &str

Endpoint URL the client posts to.

pub fn dialect(&self) -> FilterDialect

Filter dialect — controls how where: / find: arguments are rendered. Defaults to FilterDialect::Generic.

pub async fn post_graphql( &self, query: &str, variables: &Map<String, Value>, ) -> Result<Value>

Send a query document with variables. Returns the data payload from the GraphQL response, or an error if the request failed or the response carried a top-level errors array.

impl GraphqlApi

pub fn vista_factory(&self) -> GraphqlApiVistaFactory

Return a Vista factory bound to this GraphQL data source.

Trait Implementations

impl Clone for GraphqlApi

fn clone(&self) -> GraphqlApi

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataSource for GraphqlApi

impl Debug for GraphqlApi

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

Formats the value using the given formatter.

impl ExprDataSource<AnyGraphqlType> for GraphqlApi

async fn execute( &self, _expr: &Expression<AnyGraphqlType>, ) -> Result<AnyGraphqlType>

fn defer(&self, expr: Expression<AnyGraphqlType>) -> DeferredFn<AnyGraphqlType>

fn associate<R>( &self, expr: Expression<T>, ) -> AssociatedExpression<'_, Self, T, R>

where Self: Sized,

Create an associated expression with type-safe return type

impl SelectableDataSource<AnyGraphqlType, GraphqlCondition> for GraphqlApi

type Select = GraphqlSelect

fn select(&self) -> Self::Select

fn add_select_column( &self, select: &mut Self::Select, _expression: Expression<AnyGraphqlType>, alias: Option<&str>, )

Add a column expression to a select query with optional alias. Backends must override this if they support aliases.

async fn execute_select( &self, select: &Self::Select, ) -> Result<Vec<AnyGraphqlType>>

impl TableSource for GraphqlApi

fn eq_condition(field: &str, value: &str) -> Result<Self::Condition>

Stringy field == value helper for callers that only have text on hand (CLI, generic UIs). The value lands as a JSON string.

fn eq_value_condition( &self, field: &str, value: Self::Value, ) -> Result<Self::Condition>

Typed-value sibling of eq_condition. Used by Reference::resolve_from_row to push a row-derived AnyGraphqlType join value onto a child table without a string round-trip.

fn search_table_condition<E>( &self, table: &Table<Self, E>, search_value: &str, ) -> Self::Condition

where E: Entity<Self::Value>, Self: Sized,

Build an OR-of-ILIKEs across all of the table’s columns — the closest analogue to a SEARCH 'value' operator that survives across servers. Hasura speaks _ilike natively; Generic dialect rejects this at render time, which is the right failure mode (search doesn’t translate to flat-arg schemas).

fn get_table_value<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, table: &'life1 Table<Self, E>, id: &'life2 Self::Id, ) -> Pin<Box<dyn Future<Output = Result<Option<Record<Self::Value>>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Single-row fetch by id. Adds an id = <id> condition to the table’s existing filter and pulls the first row.

fn get_table_count<'life0, 'life1, 'async_trait, E>( &'life0 self, table: &'life1 Table<Self, E>, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Best-effort count — lists rows and counts them. Hasura users can override per-table once an aggregate path lands.

fn related_in_condition<SourceE: Entity<Self::Value> + 'static>( &self, target_field: &str, source_table: &Table<Self, SourceE>, source_column: &str, ) -> Self::Condition

where Self: Sized,

Build a child condition for with_many / with_one traversal.

Two paths, mirroring the REST adapter’s posture:

• Sync peek — if the parent already carries an eq-condition on source_column (the common with_many case where the source column is the parent’s id field narrowed via eq(<id>)), re-key the value onto target_field immediately so the child filter is fully concrete.
• Deferred fallback — otherwise (the with_one case where source_column is a foreign-key field that lives in the parent’s data, not its conditions), wrap resolution in a DeferredField that fetches the parent’s first row at fetch time and pulls source_column out of it.

Both paths render through FilterDialect, so Hasura schemas get { target_field: { _eq: v } } and Generic schemas get the flat { target_field: v } form.

This is the two-round-trip option; nested-selection (single round trip) is a future optimisation that requires going around the Table trait surface and is tracked separately.

fn column_table_values_expr<'a, E, Type: ColumnType>( &'a self, table: &Table<Self, E>, column: &Self::Column<Type>, ) -> AssociatedExpression<'a, Self, Self::Value, Vec<Type>>

where E: Entity<Self::Value> + 'static, Self: Sized,

Defer to a query that selects just column. Used by the Table::with_one / Table::with_many plumbing when it wants a list of values from another table (e.g. all FK ids).

We implement the deferred path via the existing list_table_values machinery — fetch all parent rows, extract the column. For Hasura schemas this could be replaced with a proper sub-select; for SpaceX-style generic schemas, list-and-extract is the only viable path anyway.

type Column<Type> = Column<Type> where Type: ColumnType

type AnyType = AnyGraphqlType

type Value = AnyGraphqlType

type Id = String

type Condition = GraphqlCondition

The condition type stored by Table. SQL/SurrealDB backends use Expression<Self::Value>; document-oriented backends like MongoDB can use a native filter type (e.g. bson::Document).

type Source = String

How this backend names its source. Most backends use String; SQL/SurrealDB backends use SelectSource<Self::Select> so a table can be sourced from an arbitrary sub-SELECT. See crate::source.

fn create_column<Type: ColumnType>(&self, name: &str) -> Self::Column<Type>

Create a new column with the given name

fn to_any_column<Type: ColumnType>( &self, column: Self::Column<Type>, ) -> Self::Column<Self::AnyType>

Convert a typed column to type-erased column

fn convert_any_column<Type: ColumnType>( &self, any_column: Self::Column<Self::AnyType>, ) -> Option<Self::Column<Type>>

Attempt to convert a type-erased column back to typed column

fn expr( &self, template: impl Into<String>, parameters: Vec<ExpressiveEnum<Self::Value>>, ) -> Expression<Self::Value>

Create an expression from a template and parameters, similar to Expression::new

fn list_table_values<'life0, 'life1, 'async_trait, E>( &'life0 self, table: &'life1 Table<Self, E>, ) -> Pin<Box<dyn Future<Output = Result<IndexMap<Self::Id, Record<Self::Value>>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all data from a table as Record values with IDs (for ReadableValueSet implementation)

fn get_table_some_value<'life0, 'life1, 'async_trait, E>( &'life0 self, table: &'life1 Table<Self, E>, ) -> Pin<Box<dyn Future<Output = Result<Option<(Self::Id, Record<Self::Value>)>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get some data from a table as Record value with ID (for ReadableValueSet implementation)

fn get_table_sum<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _column: &'life2 Self::Column<Self::AnyType>, ) -> Pin<Box<dyn Future<Output = Result<Self::Value>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get sum of a column in the table (returns native value type)

fn get_table_max<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _column: &'life2 Self::Column<Self::AnyType>, ) -> Pin<Box<dyn Future<Output = Result<Self::Value>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get maximum value of a column in the table (returns native value type)

fn get_table_min<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _column: &'life2 Self::Column<Self::AnyType>, ) -> Pin<Box<dyn Future<Output = Result<Self::Value>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get minimum value of a column in the table (returns native value type)

fn insert_table_value<'life0, 'life1, 'life2, 'life3, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _id: &'life2 Self::Id, _record: &'life3 Record<Self::Value>, ) -> Pin<Box<dyn Future<Output = Result<Record<Self::Value>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Insert a record as Record value (for WritableValueSet implementation)

fn replace_table_value<'life0, 'life1, 'life2, 'life3, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _id: &'life2 Self::Id, _record: &'life3 Record<Self::Value>, ) -> Pin<Box<dyn Future<Output = Result<Record<Self::Value>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Replace a record as Record value (for WritableValueSet implementation)

fn patch_table_value<'life0, 'life1, 'life2, 'life3, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _id: &'life2 Self::Id, _partial: &'life3 Record<Self::Value>, ) -> Pin<Box<dyn Future<Output = Result<Record<Self::Value>>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Patch a record as Record value (for WritableValueSet implementation)

fn delete_table_value<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _id: &'life2 Self::Id, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete a record by ID (for WritableValueSet implementation)

fn delete_table_all_values<'life0, 'life1, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete all records (for WritableValueSet implementation)

fn insert_table_return_id_value<'life0, 'life1, 'life2, 'async_trait, E>( &'life0 self, _table: &'life1 Table<Self, E>, _record: &'life2 Record<Self::Value>, ) -> Pin<Box<dyn Future<Output = Result<Self::Id>> + Send + 'async_trait>>

where E: Entity<Self::Value> + 'async_trait, Self: Sized + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Insert a record and return generated ID (for InsertableValueSet implementation)

fn stream_table_values<'a, E>( &'a self, table: &Table<Self, E>, ) -> Pin<Box<dyn Stream<Item = Result<(Self::Id, Record<Self::Value>), VantageError>> + Send + 'a>>

where E: Entity<Self::Value> + 'a, Self: Sized,

Stream all records from a table as (Id, Record) pairs.

fn related_correlated_condition( &self, target_table: &str, target_field: &str, source_table: &str, source_column: &str, ) -> Self::Condition

Build a correlated condition: target_table.target_field = source_table.source_column.