rocketmq_client_v4/protocols/body/
topic_route_data.rs

1use crate::protocols::body::broker_data::BrokerData;
2use crate::protocols::body::queue_data::QueueData;
3use serde::{Deserialize, Serialize};
4use std::collections::HashMap;
5
6#[derive(Debug, Serialize, Deserialize)]
7#[allow(non_snake_case)]
8pub struct TopicRouteData {
9    pub orderTopicConf: Option<String>,
10    pub queueDatas: Vec<QueueData>,
11    pub brokerDatas: Vec<BrokerData>,
12    pub filterServerTable: HashMap<String, Vec<String>>,
13    //HashMap<String/* brokerAddr */, List<String>/* Filter Server */> filterServerTable;
14}