Struct TtlManager 

pub struct TtlManager<S: VectorStorage> { /* private fields */ }

TTL Manager for coordinating automatic vector expiration

Implementations

impl<S: VectorStorage + 'static> TtlManager<S>

pub fn new(storage: Arc<S>, config: TtlConfig) -> Self

Create a new TTL manager

pub fn with_defaults(storage: Arc<S>) -> Self

Create a new TTL manager with default config

pub fn config(&self) -> TtlConfig

Get current configuration

pub fn update_config(&self, config: TtlConfig)

Update configuration

pub fn set_policy(&self, namespace: &NamespaceId, policy: NamespaceTtlPolicy)

Set TTL policy for a namespace

pub fn get_policy(&self, namespace: &NamespaceId) -> Option<NamespaceTtlPolicy>

Get TTL policy for a namespace

pub fn remove_policy( &self, namespace: &NamespaceId, ) -> Option<NamespaceTtlPolicy>

Remove TTL policy for a namespace

pub fn list_policies(&self) -> HashMap<NamespaceId, NamespaceTtlPolicy>

Get all namespace policies

pub fn stats(&self) -> TtlStats

Get current statistics

pub fn is_running(&self) -> bool

Check if the cleanup service is running

pub fn validate_ttl( &self, namespace: &NamespaceId, ttl_seconds: Option<u64>, ) -> Result<Option<u64>>

Validate and apply TTL for a vector in a namespace

pub async fn run_cleanup(&self) -> Result<TtlCleanupResult>

Run cleanup once (manual trigger)

pub fn trigger_cleanup(&self)

Trigger an immediate cleanup (async, doesn’t wait)

pub fn shutdown(&self)

Shutdown the TTL service