Struct EtcdStorage

pub struct EtcdStorage { /* private fields */ }

Implementations

impl EtcdStorage

pub fn new(value: &str) -> Result<Self, Error>

Create a new etcd storage for config. Connection url format: etcd://host1:port1,host2:port2/pingap?timeout=10s&connect_timeout=5s&user=&password=

Trait Implementations

impl ConfigStorage for EtcdStorage

fn load_config<'life0, 'async_trait>( &'life0 self, opts: LoadConfigOptions, ) -> Pin<Box<dyn Future<Output = Result<PingapConf, Error>> + Send + 'async_trait>>

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

Load config from etcd by fetching all keys under the base path

fn save_config<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, conf: &'life1 PingapConf, category: &'life2 str, name: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Save config to etcd, optionally separating by category/name If separation is enabled and name is provided, saves individual sections Otherwise saves the entire category as one entry

fn support_observer(&self) -> bool

Indicates that this storage supports watching for changes

fn observe<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Observer, Error>> + Send + 'async_trait>>

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

Sets up a watch on the config path to observe changes Note: May miss changes if processing takes too long between updates Should be used with periodic full fetches to ensure consistency

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Save key-value data under the base path

fn load<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Error>> + Send + 'async_trait>>

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

Load key-value data from under the base path