Struct RunningProxy 

pub struct RunningProxy {
    pub running_nodes: Vec<RunningNode>,
    /* private fields */
}

A handle that can be used to stop the proxy or change the rules.

Fields

running_nodes: Vec<RunningNode>

Implementations

impl RunningProxy

pub fn turn_off_rules(&mut self)

Disables all the rules in the proxy, effectively making it a pass-through-only proxy.

pub fn sanity_check(&mut self) -> Result<(), ProxyError>

Attempts to fetch the first error that has occurred in proxy since last check. If no errors occurred, returns Ok(()).

pub async fn wait_for_error(&mut self) -> Option<ProxyError>

Waits until an error occurs in proxy. If proxy finishes with no errors occurred, returns Err(()).

pub async fn finish(self) -> Result<(), ProxyError>

Requests termination of all proxy workers and awaits its completion. Returns the first error that occurred in proxy.

pub async fn wait_for_connection(&self)

Waits until at least one driver connection is active on any node in this proxy.

For single-node proxies (typical in client-routes tests), this waits until a driver has connected to the sole node. For multi-node proxies, returns as soon as any node receives a connection.