Struct MemoryProxyStore 

pub struct MemoryProxyStore { /* private fields */ }

In-memory implementation of ProxyStoragePort.

Uses a tokio::sync::RwLock-guarded HashMap for thread-safe access. Metrics are updated via atomic operations, so only a read lock is needed for update_metrics calls — write contention stays low even under heavy concurrent load.

Example

use stygian_proxy::storage::{MemoryProxyStore, ProxyStoragePort};
use stygian_proxy::types::{Proxy, ProxyType};

let store = MemoryProxyStore::default();
let proxy = Proxy { url: "http://proxy.example.com:8080".into(), proxy_type: ProxyType::Http,
                    username: None, password: None, weight: 1, tags: vec![] };
let record = store.add(proxy).await.unwrap();
assert_eq!(store.list().await.unwrap().len(), 1);
store.remove(record.id).await.unwrap();
assert!(store.list().await.unwrap().is_empty());

Implementations

impl MemoryProxyStore

pub async fn with_proxies(proxies: Vec<Proxy>) -> ProxyResult<Self>

Build a store pre-populated with proxies, validating each URL.

Returns an error on the first invalid URL encountered.

Trait Implementations

impl Clone for MemoryProxyStore

fn clone(&self) -> MemoryProxyStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryProxyStore

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

Formats the value using the given formatter.

impl Default for MemoryProxyStore

fn default() -> MemoryProxyStore

Returns the “default value” for a type.

impl ProxyStoragePort for MemoryProxyStore

fn add<'life0, 'async_trait>( &'life0 self, proxy: Proxy, ) -> Pin<Box<dyn Future<Output = ProxyResult<ProxyRecord>> + Send + 'async_trait>>

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

Add a new proxy to the store and return its ProxyRecord.

fn remove<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = ProxyResult<()>> + Send + 'async_trait>>

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

Remove a proxy by its UUID. Returns an error if the ID is not found.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProxyResult<Vec<ProxyRecord>>> + Send + 'async_trait>>

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

Return all stored proxy records.

fn get<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = ProxyResult<ProxyRecord>> + Send + 'async_trait>>

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

Fetch a single proxy record by UUID.

fn list_with_metrics<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProxyResult<Vec<(ProxyRecord, Arc<ProxyMetrics>)>>> + Send + 'async_trait>>

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

Return all stored proxy records paired with their live metrics reference.

fn update_metrics<'life0, 'async_trait>( &'life0 self, id: Uuid, success: bool, latency_ms: u64, ) -> Pin<Box<dyn Future<Output = ProxyResult<()>> + Send + 'async_trait>>

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

Record the outcome of a request through a proxy.