Struct TursoPersistence 

pub struct TursoPersistence {
    source: Source,
    table_prefix: String,
}

Available on crate feature turso only.

Configures session persistence backed by a turso database.

Build one with new to share a database the caller already owns, or open to let finmqtt manage a local database file, then pass it to ClientBuilder::persistence.

Fields

source: Source

table_prefix: String

Implementations

impl TursoPersistence

pub fn new(database: Database) -> Self

Persists session state to database, using the default finmqtt_ table prefix.

finmqtt opens its own connection from database; the caller keeps ownership and may share it with its own tables.

pub fn open(path: impl Into<PathBuf>) -> Self

Persists session state to a local turso database file at path, which finmqtt opens and owns, using the default finmqtt_ table prefix.

fn with_source(source: Source) -> Self

pub fn table_prefix(self, prefix: impl Into<String>) -> Self

Overrides the prefix applied to every table name finmqtt creates.

Must consist only of ASCII alphanumeric characters and underscores and must not begin with a digit (it forms part of a SQL identifier).

pub(crate) async fn build(self) -> Result<(JournaledSession, TursoStore)>

Opens the store and loads any persisted session.

Trait Implementations

impl From<TursoPersistence> for SessionPersistence

fn from(config: TursoPersistence) -> Self

Converts to this type from the input type.