hanzo_client/models/
make_in.rs1use crate::models;
12use serde::{Deserialize, Serialize};
13
14#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
15pub struct MakeIn {
16 #[serde(rename = "ack_policy", skip_serializing_if = "Option::is_none")]
17 pub ack_policy: Option<String>,
18 #[serde(rename = "ack_wait", skip_serializing_if = "Option::is_none")]
19 pub ack_wait: Option<String>,
20 #[serde(rename = "deliver_policy", skip_serializing_if = "Option::is_none")]
21 pub deliver_policy: Option<String>,
22 #[serde(rename = "description", skip_serializing_if = "Option::is_none")]
23 pub description: Option<String>,
24 #[serde(rename = "durable_name", skip_serializing_if = "Option::is_none")]
25 pub durable_name: Option<String>,
26 #[serde(rename = "filter_subject", skip_serializing_if = "Option::is_none")]
27 pub filter_subject: Option<String>,
28 #[serde(rename = "max_ack_pending", skip_serializing_if = "Option::is_none")]
29 pub max_ack_pending: Option<i32>,
30 #[serde(rename = "max_deliver", skip_serializing_if = "Option::is_none")]
31 pub max_deliver: Option<i32>,
32 #[serde(rename = "opt_start_seq", skip_serializing_if = "Option::is_none")]
33 pub opt_start_seq: Option<i32>,
34 #[serde(rename = "opt_start_time", skip_serializing_if = "Option::is_none")]
35 pub opt_start_time: Option<String>,
36 #[serde(rename = "replay_policy", skip_serializing_if = "Option::is_none")]
37 pub replay_policy: Option<String>,
38 #[serde(rename = "stream", skip_serializing_if = "Option::is_none")]
40 pub stream: Option<String>,
41}
42
43impl MakeIn {
44 pub fn new() -> MakeIn {
45 MakeIn {
46 ack_policy: None,
47 ack_wait: None,
48 deliver_policy: None,
49 description: None,
50 durable_name: None,
51 filter_subject: None,
52 max_ack_pending: None,
53 max_deliver: None,
54 opt_start_seq: None,
55 opt_start_time: None,
56 replay_policy: None,
57 stream: None,
58 }
59 }
60}
61