Struct WatchCache 

pub struct WatchCache<T> { /* private fields */ }

Watch cache for efficient list-then-watch

Implementations

impl<T: Clone + Send + Sync + 'static> WatchCache<T>

pub fn new(kind: ResourceKind, registry: Arc<WatchRegistry>) -> Self

Create new watch cache

pub fn set(&self, key: impl Into<String>, value: T, version: u64)

Add or update item

pub fn get(&self, key: &str) -> Option<T>

Get item

pub fn remove(&self, key: &str) -> Option<T>

Remove item

pub fn list(&self) -> Vec<T>

List all items

pub fn version(&self) -> u64

Get current version

pub fn watch(&self) -> WatchStream

Subscribe to changes