Method dispatch

nodedb/tests/wal_catchup.rs:86–99

(&self, plan: PhysicalPlan, collection: &str)

    }

    async fn dispatch(&self, plan: PhysicalPlan, collection: &str) -> serde_json::Value {
        let resp = nodedb::control::server::dispatch_utils::dispatch_to_data_plane(
            &self.shared,
            TenantId::new(1),
            VShardId::from_collection_in_database(DatabaseId::DEFAULT, collection),
            plan,
            TraceId::ZERO,
        )
        .await
        .expect("dispatch failed");
        let json_str =
            nodedb::data::executor::response_codec::decode_payload_to_json(&resp.payload);
        serde_json::from_str(&json_str).unwrap_or(serde_json::Value::Null)
    }

    async fn query_count(&self, collection: &str) -> u64 {
        let resp = self