reinhardt-utils 0.1.0-rc.22

Utility functions aggregator for Reinhardt
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Internal cache entry structure

use serde::{Deserialize, Serialize};
use std::time::{Duration, SystemTime};

/// Cache entry with expiration and timestamp tracking
#[derive(Debug, Clone, Serialize, Deserialize)]
pub(crate) struct CacheEntry {
	pub(crate) value: Vec<u8>,
	pub(crate) expires_at: Option<SystemTime>,
	pub(crate) created_at: SystemTime,
	pub(crate) accessed_at: Option<SystemTime>,
}

impl CacheEntry {
	pub(crate) fn new(value: Vec<u8>, ttl: Option<Duration>) -> Self {
		let now = SystemTime::now();
		let expires_at = ttl.map(|d| now + d);
		Self {
			value,
			expires_at,
			created_at: now,
			accessed_at: None,
		}
	}

	pub(crate) fn is_expired(&self) -> bool {
		if let Some(expires_at) = self.expires_at {
			SystemTime::now() > expires_at
		} else {
			false
		}
	}

	/// Update the last accessed timestamp
	pub(crate) fn touch(&mut self) {
		self.accessed_at = Some(SystemTime::now());
	}
}