Struct SqliteStorage 

pub struct SqliteStorage { /* private fields */ }

SQLite-backed storage implementation.

Wraps an r2d2 connection pool. Use new for file-backed storage or new_in_memory for testing with isolated in-memory databases.

Implementations

impl SqliteStorage

pub fn new(path: &Path) -> Result<Self, StorageError>

Opens a file-backed SQLite database at path.

Errors

Returns StorageError::Connection if the database file cannot be opened or the pool cannot be created.

pub fn new_in_memory() -> Result<Self, StorageError>

Opens an in-memory SQLite database with shared cache.

Suitable for testing — each call creates an isolated database.

Errors

Returns StorageError::Connection if the pool cannot be created.

Trait Implementations

impl Clone for SqliteStorage

fn clone(&self) -> SqliteStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteStorage

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

Formats the value using the given formatter.

impl SeedManager for SqliteStorage

fn seed_init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SeedStatus, StorageError>> + Send + 'async_trait>>

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

Initialize seed data from the embedded fallback (compile-time JSON).

fn seed_refresh<'life0, 'life1, 'async_trait>( &'life0 self, url: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<SeedStatus, StorageError>> + Send + 'async_trait>>

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

Fetch and apply seed data from a remote URL.

fn seed_status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SeedStatus, StorageError>> + Send + 'async_trait>>

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

Query the current seed data status without fetching.

fn seed_check_remote<'life0, 'life1, 'async_trait>( &'life0 self, url: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<SeedStatus, StorageError>> + Send + 'async_trait>>

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

Fetch the remote manifest and compare with local status, but do NOT apply any changes. Used by the admin API ?remote=true query parameter.

impl Storage for SqliteStorage

fn list_providers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Provider>, StorageError>> + Send + 'async_trait>>

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

List all providers.

fn get_provider<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Provider>, StorageError>> + Send + 'async_trait>>

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

Get a single provider by ID.

fn list_models<'life0, 'life1, 'async_trait>( &'life0 self, provider_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Model>, StorageError>> + Send + 'async_trait>>

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

List models, optionally filtered by provider.

fn get_model<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Model>, StorageError>> + Send + 'async_trait>>

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

Get a single model by ID.

fn list_channels<'life0, 'life1, 'async_trait>( &'life0 self, model_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Channel>, StorageError>> + Send + 'async_trait>>

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

List all channels, optionally filtered by model ID.

fn get_channel<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Channel>, StorageError>> + Send + 'async_trait>>

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

Get a single channel by ID.

fn upsert_channel<'life0, 'life1, 'async_trait>( &'life0 self, channel: &'life1 Channel, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Insert or replace a channel (upsert).

fn set_channel_enabled<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, enabled: bool, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Toggle a channel enabled/disabled.

fn set_channel_api_key<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, key: &'life2 SecretString, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Update just the API key for a channel.

fn update_channel<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, id: &'life1 str, name: Option<&'life2 str>, enabled: Option<bool>, priority: Option<u32>, monthly_quota: Option<u64>, quota_policy: Option<&'life3 str>, protocols: Option<&'life4 str>, force_protocol: Option<&'life5 str>, ) -> Pin<Box<dyn Future<Output = Result<Channel, StorageError>> + Send + 'async_trait>>

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

Update channel fields (name, enabled, priority, quota, protocols, force_protocol).

fn delete_channel<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a channel and its model mappings (cascade).

fn mark_channel_healthy<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Mark a channel as healthy (reset failures).

fn record_channel_failure<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Record a channel failure (increments counter, may set Degraded/Cooldown).

fn list_mappings<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ModelMapping>, StorageError>> + Send + 'async_trait>>

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

List all model mappings for a channel.

fn upsert_mapping<'life0, 'life1, 'async_trait>( &'life0 self, mapping: &'life1 ModelMapping, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Upsert a single model mapping.

fn set_mapping_enabled<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, enabled: bool, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Toggle a model mapping enabled/disabled.

fn delete_mapping<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a model mapping.

fn list_all_mappings<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ModelMapping>, StorageError>> + Send + 'async_trait>>

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

List all model mappings.

fn insert_cost_record<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 CostRecord, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Record a completed request.

fn query_cost_records<'life0, 'async_trait>( &'life0 self, filter: CostFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<CostRecord>, StorageError>> + Send + 'async_trait>>

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

Query cost records with optional filters.

fn aggregate_costs<'life0, 'async_trait>( &'life0 self, group_by: CostGroupBy, range: TimeRange, ) -> Pin<Box<dyn Future<Output = Result<Vec<CostAggregate>, StorageError>> + Send + 'async_trait>>

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

Aggregate costs grouped by the given dimension within a time range.

fn prune_cost_records<'life0, 'async_trait>( &'life0 self, older_than_days: u32, ) -> Pin<Box<dyn Future<Output = Result<u64, StorageError>> + Send + 'async_trait>>

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

Delete records older than N days, returning the count of deleted rows.

fn list_projects<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StorageError>> + Send + 'async_trait>>

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

List distinct project paths from cost records, sorted alphabetically.

fn insert_switch_log<'life0, 'life1, 'async_trait>( &'life0 self, log: &'life1 SwitchLog, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Record a channel switch event.

fn insert_subscription_fee<'life0, 'life1, 'async_trait>( &'life0 self, fee: &'life1 SubscriptionFee, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Record a monthly subscription fee.

fn query_subscription_fees<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, channel: Option<&'life1 str>, month: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SubscriptionFee>, StorageError>> + Send + 'async_trait>>

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

Query subscription fees optionally filtered by channel and/or month.

fn query_switch_logs<'life0, 'async_trait>( &'life0 self, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SwitchLog>, StorageError>> + Send + 'async_trait>>

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

Query recent switch logs, optionally limited.

fn list_available_channels<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<AvailableChannelInfo>, StorageError>> + Send + 'async_trait>>

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

List all enabled channels with their bound models. Used by token-fleet-switch for Claude direct-connect mode.

fn migrate<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Run migrations / schema init. Idempotent — safe to call on every startup.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

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

Health check — returns true if the backend is reachable.

fn max_connections(&self) -> usize

Maximum number of concurrent connections this backend supports.