Struct unleash_api_client::client::Client

pub struct Client<C: HttpClient> { /* fields omitted */ }

Implementations

impl<C: HttpClient + Default> Client<C>

pub fn new(
    api_url: &str,
    app_name: &str,
    instance_id: &str,
    authorization: Option<String>
) -> Result<Self, Error>

pub fn is_enabled(
    &self,
    feature_name: &str,
    context: Option<&Context>,
    default: bool
) -> bool

pub fn memoize(
    &self,
    features: Vec<Feature>
) -> Result<Option<Metrics>, Box<dyn Error>>

Memoize new features into the cached state

Interior mutability is used, via the arc-swap crate.

Note that this is primarily public to facilitate benchmarking; poll_for_updates is the usual way in which memoize will be called.

pub async fn poll_for_updates<'_>(&'_ self)

Query the API endpoint for features and push metrics

Immediately and then every self.interval milliseconds the API server is queryed for features and the previous cycles metrics are uploaded.

May be dropped, or will terminate at the next polling cycle after stop_poll is called().

pub async fn register<'_>(
    &'_ self
) -> Result<(), Box<dyn Error + Send + Sync + 'static>>

Register this client with the API endpoint.

pub async fn stop_poll<'_>(&'_ self)

stop the poll_for_updates() function.

If poll is not running, will wait-loop until poll_for_updates is running, then signal it to stop, then return. Will wait for ever if poll_for_updates never starts running.

Trait Implementations

impl<C: HttpClient + Default> Sync for Client<C>