Struct SqliteStoragePort 

pub struct SqliteStoragePort { /* private fields */ }

Embedded SQLite storage for the sqlite adapter tier.

Write-through persistence with in-memory live fanout. Enable the sqlite feature on the photon public crate and install via PhotonBuilder::storage_port.

Path / env: see module config (PHOTON_SQLITE_PATH).

Getting started: Embedded durable. Runnable: cargo run -p uf-photon --example embedded_sqlite --features runtime,sqlite.

Examples

Embedded host (publish + handlers)

One binary owns both publish and #[subscribe] dispatch via start_executor.

use std::sync::Arc;

use photon_backend_sqlite::SqliteStoragePort;
use photon_core::JsonIdentityFactory;
use photon_runtime::Photon;

let port = Arc::new(SqliteStoragePort::open("/var/lib/photon/events.db").await?);
let photon = Photon::builder()
    .storage_port(port)
    .auto_registry()
    .build()?;
photon.start_executor(Arc::new(JsonIdentityFactory))?;
// EventType { … }.publish_on(&photon).await?;

Implementations

impl SqliteStoragePort

pub async fn open(path: &str) -> Result<Self>

Open or create a database at path.

File-backed pools use WAL and a 5s busy timeout so concurrent checkpoint commits wait instead of failing immediately with SQLITE_BUSY.

Errors

Returns an error if the database cannot be opened or migrated.

pub async fn from_env() -> Result<Self>

Open using sqlite_path_from_env.

Errors

Returns an error if the database cannot be opened or migrated.

Trait Implementations

impl StoragePort for SqliteStoragePort

fn capabilities(&self) -> StorageCapabilities

Adapter capabilities for contract tests and telemetry.

fn append<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_key: Option<&'life2 str>, actor_json: Value, payload_json: Value, ) -> Pin<Box<dyn Future<Output = Result<Event>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append one event to a topic partition.

fn subscribe( &self, topic_name: String, topic_key_filter: Option<String>, after_seq: Option<i64>, ) -> Pin<Box<dyn Stream<Item = Result<Event>> + Send>>

Stream events for a topic partition, optionally replaying after after_seq.

fn get_event<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Point lookup by event id (optional — see StorageCapabilities::supports_get_event).

fn list_by_topic<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_key: Option<&'life2 str>, after_seq: Option<i64>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Bounded page of events for one topic (ops browse).

fn list_recent<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bounded cross-topic page of newest events (ops browse).

fn load_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_name: &'life1 str, topic_name: &'life2 str, topic_key: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<i64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Load durable subscription high-water seq.

fn commit_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_name: &'life1 str, topic_name: &'life2 str, topic_key: Option<&'life3 str>, last_seq: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Persist durable subscription high-water seq.

fn delivery_seq_pin<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_key: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Option<i64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Last delivered seq pin for retention watermarks (optional).

fn truncate_before<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_key: Option<&'life2 str>, truncate_bound: i64, ) -> Pin<Box<dyn Future<Output = Result<u64, PhotonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Trim events before truncate_bound for a partition (no-op when unsupported).