Module store 

Available on crate feature turso only.

The runtime turso store: a connection plus the prepared statements that flush ops and rebuild the session.

Structs

FilterColumns 🔒

The filter-table column values for a FilterState. The subscription options and id live on the Subscribing/Subscribed states or on an Unsubscribing state’s restore; columns a state does not carry are NULL.

Selects 🔒

The prepared SELECT statements used by TursoStore::load.

Statements 🔒

The mutating statements, prepared once and reused on every flush.

TursoStore

A turso-backed session store.

Functions

apply_packet_id_rows 🔒

Runs a no-parameter query whose rows are each a single packet id, applying ctor(packet_id) to session for every row (the shape shared by the pubrel and incoming-QoS-2 restore queries).

assert_persist_future_send 🔒

Compile-time guard that TursoStore::persist returns a Send future.

decode_filter_state 🔒

Decodes a filter row’s (options, subscription_id, state_tag, packet_id, filter_index, was_subscribed) columns (indices 1..=6) back into a FilterState, pulling the options and id onto the state that carries them.

exec_pid 🔒

Executes a prepared statement whose only bind parameter is a packet identifier (the shape shared by every single-key insert/delete).

filter_columns 🔒

Maps a FilterState onto the (options, subscription_id, state_tag, packet_id, filter_index, was_subscribed) filter-table columns.

options_value 🔒

prepare 🔒

row_index 🔒

Reads a filter index column as a u16.

row_options 🔒

sub_id_value 🔒