Get cached schema for a table
(&self, table_name: &str)
| 45 | |
| 46 | /// Get cached schema for a table |
| 47 | pub fn get(&self, table_name: &str) -> Option<TableSchema> { |
| 48 | let cache = self.cache.read().unwrap(); |
| 49 | |
| 50 | if let Some(entry) = cache.get(table_name) |
| 51 | && entry.cached_at.elapsed() < self.ttl { |
| 52 | return Some(entry.schema.clone()); |
| 53 | } |
| 54 | |
| 55 | None |
| 56 | } |
| 57 | |
| 58 | /// Cache schema for a table |
| 59 | pub fn insert(&self, table_name: String, schema: TableSchema) { |
no test coverage detected