use running_process::broker::client_v2::{self, BrokerV2Error, ClientSession};
pub fn connect_v2_broker(wanted_version: &str) -> Result<ClientSession, BrokerV2Error> {
client_v2::connect("zccache", wanted_version)
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn connect_v2_broker_no_broker_returns_dial_error() {
let err = connect_v2_broker("0.0.0").expect_err("no broker => Dial error");
match err {
BrokerV2Error::Dial { socket_path, .. } => {
let v2_marker = if cfg!(windows) {
"rpb-v2-zccache-"
} else {
"broker-v2"
};
assert!(
socket_path.contains(v2_marker),
"Dial socket_path should reference the v2 broker namespace \
(expected substring `{v2_marker}`), got: {socket_path}"
);
}
other => panic!("expected BrokerV2Error::Dial, got: {other:?}"),
}
}
}