Skip to main content

hanzo_client/models/
make_in.rs

1/*
2 * Hanzo Cloud API
3 *
4 * The Hanzo Cloud API as a customer calls it: every operation under /v1/ except the operator's admin product, relay routes, legacy spellings and capabilities still reached by flag. Tagged by product: the first path segment after /v1/.
5 *
6 * The version of the OpenAPI document: v1
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11use 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    /// Stream is the stream name, from the path.
39    #[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