Function build_store_status

gateway/src/admin_service.rs:700–730

(
    name: &str,
    status: WaveKvNodeStatus,
    get_peer_last_seen: &impl Fn(u32) -> Vec<(u32, u64)>,
)

}

fn build_store_status(
    name: &str,
    status: WaveKvNodeStatus,
    get_peer_last_seen: &impl Fn(u32) -> Vec<(u32, u64)>,
) -> StoreSyncStatus {
    StoreSyncStatus {
        name: name.to_string(),
        node_id: status.id,
        n_keys: status.n_kvs as u64,
        next_seq: status.next_seq,
        dirty: status.dirty,
        wal_enabled: status.wal,
        peers: status
            .peers
            .into_iter()
            .map(|p| {
                let last_seen = get_peer_last_seen(p.id)
                    .into_iter()
                    .map(|(node_id, timestamp)| LastSeenEntry { node_id, timestamp })
                    .collect();
                ProtoPeerSyncStatus {
                    id: p.id,
                    local_ack: p.ack,
                    peer_ack: p.pack,
                    buffered_logs: p.logs as u64,
                    last_seen,
                }
            })
            .collect(),
    }
}

impl RpcCall<Proxy> for AdminRpcHandler {
    type PrpcService = AdminServer<Self>;