Skip to main content

Crate do_memory_storage_turso

Crate do_memory_storage_turso 

Source
Expand description

§Memory Storage - Turso

Turso/libSQL storage backend for durable persistence of episodes and patterns.

This crate provides:

  • Connection management for Turso databases
  • SQL schema creation and migration
  • CRUD operations for episodes, patterns, and heuristics
  • Query capabilities for analytical retrieval
  • Retry logic and circuit breaker pattern for resilience

§Example

use do_memory_storage_turso::TursoStorage;

let storage = TursoStorage::new("libsql://localhost:8080", "token").await?;
storage.initialize_schema().await?;

Re-exports§

pub use cache::query_cache::AdvancedCacheStats;
pub use cache::query_cache::AdvancedQueryCache;
pub use cache::query_cache::QueryKey;
pub use cache::AdaptiveTTLCache;
pub use cache::CacheConfig;
pub use cache::CacheEntry;
pub use cache::CacheStats;
pub use cache::CacheStatsSnapshot;
pub use cache::CachedTursoStorage;
pub use cache::TTLConfig;
pub use cache::TTLConfigError;
pub use pool::AdaptiveConnectionPool;
pub use pool::AdaptivePoolConfig;
pub use pool::AdaptivePoolMetrics;
pub use pool::AdaptivePooledConnection;
pub use pool::ConnectionPool;
pub use pool::PoolConfig;
pub use pool::PoolStatistics;
pub use pool::PooledConnection;
pub use prepared::PreparedCacheConfig;
pub use prepared::PreparedCacheStats;
pub use prepared::PreparedStatementCache;
pub use metrics::ExportConfig;
pub use metrics::ExportFormat;
pub use metrics::ExportStats;
pub use metrics::ExportTarget;
pub use metrics::ExportedMetric;
pub use metrics::MetricType;
pub use metrics::MetricValue;
pub use metrics::MetricsCollector;
pub use metrics::MetricsHttpServer;
pub use metrics::PrometheusExporter;
pub use metrics::TursoMetrics;
pub use storage::batch::episode_batch::BatchConfig;
pub use storage::capacity::CapacityStatistics;
pub use storage::episodes::EpisodeQuery;
pub use storage::patterns::PatternMetadata;
pub use storage::patterns::PatternQuery;
pub use trait_impls::StorageStatistics;

Modules§

cache
Cache integration for Turso storage
metrics
Performance Metrics & Observability
pool
Connection pool for Turso/libSQL database connections
prepared
Prepared Statement Cache
storage
Storage operations for episodes, patterns, and heuristics
trait_impls
Trait implementations for TursoStorage.
turso_config
Turso storage configuration and schema initialization.

Structs§

ResilientStorage
Resilient storage wrapper with circuit breaker protection
TursoConfig
Configuration for Turso storage
TursoStorage
Turso storage backend for durable persistence