Struct PgExperimentStore 

pub struct PgExperimentStore { /* private fields */ }

Postgres-backed ExperimentStore with a short-lived read-through cache.

Writes trigger pg_notify('autumn_experiments', name) so replicas can invalidate their caches quickly via a background poll listener.

Implementations

impl PgExperimentStore

pub const DEFAULT_CACHE_TTL: Duration

Default read-through cache lifetime.

pub fn new(database_url: impl Into<String>) -> Self

Create a store using the default 1 s read-through cache.

pub fn with_cache_ttl( database_url: impl Into<String>, cache_ttl: Duration, ) -> Self

Create a store with an explicit cache TTL. Use Duration::ZERO to disable caching.

pub fn from_database_config(config: &DatabaseConfig) -> Option<Self>

Create a store from Autumn’s primary database configuration.

pub fn spawn_poll_listener( store: Arc<Self>, poll_interval: Duration, ) -> JoinHandle<()>

Spawn a background thread that polls autumn_experiment_changes and invalidates this store’s cache for changed experiments.

The thread runs indefinitely; the returned handle can be detached.

Trait Implementations

impl Clone for PgExperimentStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgExperimentStore

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

Formats the value using the given formatter.

impl ExperimentStore for PgExperimentStore

fn get( &self, name: &str, ) -> Result<Option<ExperimentConfig>, ExperimentStoreError>

Return the current configuration for name, or None if unknown.

fn list(&self) -> Result<Vec<ExperimentConfig>, ExperimentStoreError>

Return all known experiments, sorted by name.

fn upsert(&self, config: ExperimentConfig) -> Result<(), ExperimentStoreError>

Insert or update an experiment configuration.

fn set_state( &self, name: &str, state: ExperimentState, winner: Option<&str>, ) -> Result<(), ExperimentStoreError>

Update the lifecycle state of an experiment.

fn set_variants( &self, name: &str, variants: Vec<VariantConfig>, actor: Option<&str>, ) -> Result<(), ExperimentStoreError>

Update the variants and weights for an experiment.

fn get_assignment( &self, experiment: &str, actor: &str, ) -> Result<Option<Assignment>, ExperimentStoreError>

Return the sticky assignment for (experiment, actor), or None.

fn record_assignment( &self, assignment: Assignment, ) -> Result<String, ExperimentStoreError>

Record a sticky assignment.

fn get_override( &self, experiment: &str, actor: &str, ) -> Result<Option<String>, ExperimentStoreError>

Return the override variant name for (experiment, actor), or None.

fn set_override( &self, experiment: &str, actor: &str, variant: &str, ) -> Result<(), ExperimentStoreError>

Pin actor to variant in experiment, bypassing weight-based bucketing.

fn has_assignment_in_group( &self, actor: &str, group: &str, exclude_experiment: &str, ) -> Result<bool, ExperimentStoreError>

Return true if actor has an existing assignment in any experiment belonging to group, excluding exclude_experiment itself.

fn history( &self, experiment: &str, limit: usize, ) -> Result<Vec<ChangeRecord>, ExperimentStoreError>

Return the change log for experiment (most-recent first), capped at limit entries. Returns an empty Vec for unknown experiments.