rocketmq_client_v4/protocols/body/
queue_data.rs

1use serde::{Deserialize, Serialize};
2
3#[derive(Debug, Serialize, Deserialize)]
4#[allow(non_snake_case)]
5pub struct QueueData {
6    pub brokerName: String,
7    pub readQueueNums: i32,
8    pub writeQueueNums: i32,
9    pub perm: i32,
10    pub topicSysFlag: i32,
11}