risingwave_meta::barrier::rpc

Function merge_node_rpc_errors

source 
pub(super) fn merge_node_rpc_errors<E: Error + Send + Sync + 'static>(
    message: &str,
    errors: impl IntoIterator<Item = (WorkerId, E)>,
) -> MetaError