winterbaume-iotdataplane 0.1.0

IoT Data Plane service implementation for winterbaume
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136

//! Auto-generated types from Smithy models.
//! Do not edit manually. Regenerate with:
//!   smithy-codegen gen-serializers winterbaume-iot-data-plane

#![allow(non_camel_case_types, clippy::upper_case_acronyms, dead_code)]

use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct DeleteConnectionRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct DeleteThingShadowRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct DeleteThingShadowResponse {
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<String>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct GetRetainedMessageRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct GetRetainedMessageResponse {
    #[serde(rename = "lastModifiedTime")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub last_modified_time: Option<i64>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<String>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub qos: Option<i32>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub topic: Option<String>,
    #[serde(rename = "userProperties")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub user_properties: Option<String>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct GetThingShadowRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct GetThingShadowResponse {
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<String>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct ListNamedShadowsForThingRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct ListNamedShadowsForThingResponse {
    #[serde(rename = "nextToken")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub next_token: Option<String>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub results: Option<Vec<String>>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timestamp: Option<i64>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct ListRetainedMessagesRequest {}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct ListRetainedMessagesResponse {
    #[serde(rename = "nextToken")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub next_token: Option<String>,
    #[serde(rename = "retainedTopics")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub retained_topics: Option<Vec<RetainedMessageSummary>>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct RetainedMessageSummary {
    #[serde(rename = "lastModifiedTime")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub last_modified_time: Option<i64>,
    #[serde(rename = "payloadSize")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload_size: Option<i64>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub qos: Option<i32>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub topic: Option<String>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct PublishRequest {
    #[serde(rename = "correlationData")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub correlation_data: Option<String>,
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<String>,
    #[serde(rename = "payloadFormatIndicator")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload_format_indicator: Option<String>,
    #[serde(rename = "userProperties")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub user_properties: Option<String>,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct UpdateThingShadowRequest {
    #[serde(default)]
    pub payload: String,
}

#[derive(Debug, Clone, Default, Deserialize, Serialize)]
pub struct UpdateThingShadowResponse {
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<String>,
}