Struct EtcdDirectiveStore 

pub struct EtcdDirectiveStore { /* private fields */ }

A DirectiveStore whose snapshot is kept fresh by an etcd watch.

Construct with EtcdDirectiveStore::connect inside a Tokio runtime; it loads the initial set and spawns the background watch. Clone is cheap (shared snapshot) so the same store can be handed to the pipeline and an admin surface.

Implementations

impl EtcdDirectiveStore

pub async fn connect( endpoints: &[String], key: impl Into<String>, clock: Arc<dyn Clock>, ) -> Result<Self, EtcdError>

Connects to endpoints, reads the directive set at key, and spawns the background watch that keeps it fresh.

The value at key is the same JSON body the admin publish endpoint accepts ({"directives":[...]}). A missing key is a valid empty set (everything off). A malformed value at startup is treated as empty, fail-safe, the same as an unparseable later publish.

Errors

EtcdError::Connect if etcd cannot be reached or the initial read fails.

Trait Implementations

impl Clone for EtcdDirectiveStore

fn clone(&self) -> EtcdDirectiveStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EtcdDirectiveStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DirectiveStore for EtcdDirectiveStore

fn load(&self) -> Arc<DirectiveSet>

The currently active directive set. Called on the request hot path, so it must be cheap (an Arc clone of a cached snapshot), never blocking I/O.