Method wave_kv_status

gateway/src/admin_service.rs:189–215

(self)

    }

    async fn wave_kv_status(self) -> Result<WaveKvStatusResponse> {
        let kv_store = self.state.kv_store();

        let persistent_status = kv_store.persistent().read().status();
        let ephemeral_status = kv_store.ephemeral().read().status();

        let get_peer_last_seen = |peer_id: u32| -> Vec<(u32, u64)> {
            kv_store
                .get_node_last_seen_by_all(peer_id)
                .into_iter()
                .collect()
        };

        Ok(WaveKvStatusResponse {
            enabled: self.state.config.sync.enabled,
            persistent: Some(build_store_status(
                "persistent",
                persistent_status,
                &get_peer_last_seen,
            )),
            ephemeral: Some(build_store_status(
                "ephemeral",
                ephemeral_status,
                &get_peer_last_seen,
            )),
        })
    }

    async fn get_instance_handshakes(
        self,