Struct ValuesWatcher 

pub struct ValuesWatcher { /* private fields */ }

Watches the values directory for changes, reloading if there are any. If the directory does not exist we do not panic

Does not do an initial fetch, assumes the caller has already loaded values. Child thread may panic if we run out of memory or cannot create more threads.

Uses polling for now, could use inotify or similar later on.

Some important notes:

• If the thread panics and dies, there is no built in mechanism to catch it and restart
• If a config map is unmounted, we won’t reload until the next file modification (because we don’t catch the deletion event)
• If any namespace fails validation, we keep all old values (even the namespaces that passed validation)
• If we have a steady stream of readers our writer may starve for a while trying to acquire the lock
• stop() will block until the thread gets joined

Implementations

impl ValuesWatcher

pub fn new( values_path: &Path, registry: Arc<SchemaRegistry>, values: Arc<RwLock<ValuesByNamespace>>, ) -> ValidationResult<Self>

Creates a new ValuesWatcher struct and spins up the watcher thread

pub fn stop(&mut self)

Stops the watcher thread, waiting for it to join. May take up to POLLING_DELAY seconds

pub fn is_alive(&self) -> bool

Returns whether the watcher thread is still running

Trait Implementations

impl Drop for ValuesWatcher

fn drop(&mut self)

Executes the destructor for this type.