kafka_wire_protocol/schema/delete_groups_response/
v0.rs

1// This file was generated. Do not edit.
2
3use std::io::{Read, Result, Write};
4
5use serde::{Deserialize, Serialize};
6#[cfg(test)] use proptest_derive::Arbitrary;
7
8use crate::arrays::{read_array, write_array};
9use crate::markers::{ApiMessage, Response};
10use crate::readable_writable::{Readable, Writable};
11#[cfg(test)] use crate::test_utils::proptest_strategies;
12
13/// DeleteGroupsResponse, version 0.
14#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
15#[cfg_attr(test, derive(Arbitrary))]
16pub struct DeleteGroupsResponse {
17    /// The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
18    pub throttle_time_ms: i32,
19    /// The deletion results.
20    #[cfg_attr(test, proptest(strategy = "proptest_strategies::vec()"))]
21    pub results: Vec<DeletableGroupResult>,
22}
23
24impl ApiMessage for DeleteGroupsResponse {
25    fn api_key(&self) -> i16 {
26        42
27    }
28    
29    fn version(&self) -> i16 {
30        0
31    }
32}
33
34impl Response for DeleteGroupsResponse { }
35
36impl Default for DeleteGroupsResponse {
37    fn default() -> Self {
38        DeleteGroupsResponse {
39            throttle_time_ms: 0_i32,
40            results: Vec::<DeletableGroupResult>::new(),
41        }
42    }
43}
44
45impl DeleteGroupsResponse {
46    pub fn new(throttle_time_ms: i32, results: Vec<DeletableGroupResult>) -> Self {
47        Self {
48            throttle_time_ms,
49            results,
50        }
51    }
52}
53
54#[cfg(test)]
55mod tests_delete_groups_response_new_and_default {
56    use super::*;
57    
58    #[test]
59    fn test() {
60        let d = DeleteGroupsResponse::new(
61            0_i32,
62            Vec::<DeletableGroupResult>::new(),
63        );
64        assert_eq!(d, DeleteGroupsResponse::default());
65    }
66}
67
68impl Readable for DeleteGroupsResponse {
69    fn read(#[allow(unused)] input: &mut impl Read) -> Result<Self> {
70        let throttle_time_ms = i32::read(input)?;
71        let results = read_array::<DeletableGroupResult>(input, "results", false)?;
72        Ok(DeleteGroupsResponse {
73            throttle_time_ms, results
74        })
75    }
76}
77
78impl Writable for DeleteGroupsResponse {
79    fn write(&self, #[allow(unused)] output: &mut impl Write) -> Result<()> {
80        self.throttle_time_ms.write(output)?;
81        write_array(output, "self.results", &self.results, false)?;
82        Ok(())
83    }
84}
85
86/// DeletableGroupResult, version 0.
87#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
88#[cfg_attr(test, derive(Arbitrary))]
89pub struct DeletableGroupResult {
90    /// The group id.
91    #[cfg_attr(test, proptest(strategy = "proptest_strategies::string()"))]
92    pub group_id: String,
93    /// The deletion error, or 0 if the deletion succeeded.
94    pub error_code: i16,
95}
96
97impl Default for DeletableGroupResult {
98    fn default() -> Self {
99        DeletableGroupResult {
100            group_id: String::from(""),
101            error_code: 0_i16,
102        }
103    }
104}
105
106impl DeletableGroupResult {
107    pub fn new<S1: AsRef<str>>(group_id: S1, error_code: i16) -> Self {
108        Self {
109            group_id: group_id.as_ref().to_string(),
110            error_code,
111        }
112    }
113}
114
115#[cfg(test)]
116mod tests_deletable_group_result_new_and_default {
117    use super::*;
118    
119    #[test]
120    fn test() {
121        let d = DeletableGroupResult::new(
122            String::from(""),
123            0_i16,
124        );
125        assert_eq!(d, DeletableGroupResult::default());
126    }
127}
128
129impl Readable for DeletableGroupResult {
130    fn read(#[allow(unused)] input: &mut impl Read) -> Result<Self> {
131        let group_id = String::read_ext(input, "group_id", false)?;
132        let error_code = i16::read(input)?;
133        Ok(DeletableGroupResult {
134            group_id, error_code
135        })
136    }
137}
138
139impl Writable for DeletableGroupResult {
140    fn write(&self, #[allow(unused)] output: &mut impl Write) -> Result<()> {
141        self.group_id.write_ext(output, "self.group_id", false)?;
142        self.error_code.write(output)?;
143        Ok(())
144    }
145}
146
147#[cfg(test)]
148mod tests {
149    use super::*;
150    use proptest::prelude::*;
151    
152    #[test]
153    fn test_java_default() {
154        crate::test_utils::test_java_default::<DeleteGroupsResponse>("DeleteGroupsResponse", 0);
155    }
156    
157    proptest! {
158        #[test]
159        fn test_serde(data: DeleteGroupsResponse) {
160            crate::test_utils::test_serde(&data)?;
161        }
162    }
163    
164    proptest! {
165        #[test]
166        fn test_java_arbitrary(data: DeleteGroupsResponse) {
167            crate::test_utils::test_java_arbitrary(&data, "DeleteGroupsResponse", 0);
168        }
169    }
170}
kafka_wire_protocol/schema/delete_groups_response/v0.rs

kafka_wire_protocol/schema/delete_groups_response/
v0.rs
