Struct EtcdConfigStore 

pub struct EtcdConfigStore {
    client: Arc<OutboundClient>,
    endpoints: Vec<String>,
    prefix: String,
    auth: Option<(String, String)>,
    token: Mutex<Option<String>>,
    timeout: Duration,
}

etcd config store over the v3 HTTP/JSON gateway.

Fields

client: Arc<OutboundClient>

endpoints: Vec<String>

etcd base URLs (v1 uses the first).

prefix: String

Key prefix (no trailing slash), e.g. /featherbit.

auth: Option<(String, String)>

token: Mutex<Option<String>>

Cached auth token, refreshed on 401.

timeout: Duration

Implementations

impl EtcdConfigStore

pub fn new(cfg: &EtcdConfig) -> Self

Builds the store from system.yaml’s etcd settings.

fn base(&self) -> Result<&str, String>

async fn call(&self, path: &str, body: &Value) -> Result<Value, String>

POSTs body to an etcd JSON endpoint, attaching the auth token and re-authenticating once on 401.

async fn call_once( &self, path: &str, body: &Value, ) -> Result<Value, EtcdCallError>

async fn authenticate(&self) -> Result<(), String>

Authenticates and caches the token.

async fn range_prefix(&self) -> Result<Vec<(String, Vec<u8>)>, String>

Ranges all keys under the prefix, returning (key, value_bytes) pairs.

async fn put(&self, key: &str, value: &[u8]) -> Result<(), String>

async fn delete(&self, key: &str) -> Result<(), String>

fn route_key(&self, name: &str) -> String

fn policy_key(&self, name: &str) -> String

fn consumer_key(&self, name: &str) -> String

async fn write_all(&self, gw: &GatewayConfig) -> Result<(), String>

Writes every resource in gw to etcd (used to seed an empty prefix).

Trait Implementations

impl ConfigStore for EtcdConfigStore

fn load_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<GatewayConfig, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads the full gateway config from the source.

fn commit<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 SharedState, candidate: GatewayConfig, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Persists a candidate config (the full desired GatewayConfig after an Admin API mutation) and makes it live.