common_meta::key::flow::flownode_addr_helper

Function get_flownode_addresses

Source
pub(crate) async fn get_flownode_addresses(
    kv_backend: &KvBackendRef,
    keys: Vec<NodeAddressKey>,
) -> Result<HashMap<u64, NodeAddressValue>>
Expand description

Get the addresses of the flownodes. The result is a map: node_id -> NodeAddressValue