google_cloud_pubsub/generated/gapic_dataplane/model/
debug.rs1#[allow(unused_imports)]
18use super::*;
19
20impl std::fmt::Debug for super::PubsubMessage {
21 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
22 let mut debug_struct = f.debug_struct("PubsubMessage");
23 debug_struct.field("data", &self.data);
24 debug_struct.field("attributes", &self.attributes);
25 debug_struct.field("message_id", &self.message_id);
26 debug_struct.field("publish_time", &self.publish_time);
27 debug_struct.field("ordering_key", &self.ordering_key);
28 if !self._unknown_fields.is_empty() {
29 debug_struct.field("_unknown_fields", &self._unknown_fields);
30 }
31 debug_struct.finish()
32 }
33}
34
35impl std::fmt::Debug for super::PublishRequest {
36 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
37 let mut debug_struct = f.debug_struct("PublishRequest");
38 debug_struct.field("topic", &self.topic);
39 debug_struct.field("messages", &self.messages);
40 if !self._unknown_fields.is_empty() {
41 debug_struct.field("_unknown_fields", &self._unknown_fields);
42 }
43 debug_struct.finish()
44 }
45}
46
47impl std::fmt::Debug for super::PublishResponse {
48 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
49 let mut debug_struct = f.debug_struct("PublishResponse");
50 debug_struct.field("message_ids", &self.message_ids);
51 if !self._unknown_fields.is_empty() {
52 debug_struct.field("_unknown_fields", &self._unknown_fields);
53 }
54 debug_struct.finish()
55 }
56}
57
58impl std::fmt::Debug for super::ReceivedMessage {
59 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
60 let mut debug_struct = f.debug_struct("ReceivedMessage");
61 debug_struct.field("ack_id", &self.ack_id);
62 debug_struct.field("message", &self.message);
63 debug_struct.field("delivery_attempt", &self.delivery_attempt);
64 if !self._unknown_fields.is_empty() {
65 debug_struct.field("_unknown_fields", &self._unknown_fields);
66 }
67 debug_struct.finish()
68 }
69}
70
71impl std::fmt::Debug for super::ModifyAckDeadlineRequest {
72 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
73 let mut debug_struct = f.debug_struct("ModifyAckDeadlineRequest");
74 debug_struct.field("subscription", &self.subscription);
75 debug_struct.field("ack_ids", &self.ack_ids);
76 debug_struct.field("ack_deadline_seconds", &self.ack_deadline_seconds);
77 if !self._unknown_fields.is_empty() {
78 debug_struct.field("_unknown_fields", &self._unknown_fields);
79 }
80 debug_struct.finish()
81 }
82}
83
84impl std::fmt::Debug for super::AcknowledgeRequest {
85 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
86 let mut debug_struct = f.debug_struct("AcknowledgeRequest");
87 debug_struct.field("subscription", &self.subscription);
88 debug_struct.field("ack_ids", &self.ack_ids);
89 if !self._unknown_fields.is_empty() {
90 debug_struct.field("_unknown_fields", &self._unknown_fields);
91 }
92 debug_struct.finish()
93 }
94}
95
96impl std::fmt::Debug for super::StreamingPullRequest {
97 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
98 let mut debug_struct = f.debug_struct("StreamingPullRequest");
99 debug_struct.field("subscription", &self.subscription);
100 debug_struct.field("ack_ids", &self.ack_ids);
101 debug_struct.field("modify_deadline_seconds", &self.modify_deadline_seconds);
102 debug_struct.field("modify_deadline_ack_ids", &self.modify_deadline_ack_ids);
103 debug_struct.field(
104 "stream_ack_deadline_seconds",
105 &self.stream_ack_deadline_seconds,
106 );
107 debug_struct.field("client_id", &self.client_id);
108 debug_struct.field("max_outstanding_messages", &self.max_outstanding_messages);
109 debug_struct.field("max_outstanding_bytes", &self.max_outstanding_bytes);
110 debug_struct.field("protocol_version", &self.protocol_version);
111 if !self._unknown_fields.is_empty() {
112 debug_struct.field("_unknown_fields", &self._unknown_fields);
113 }
114 debug_struct.finish()
115 }
116}
117
118impl std::fmt::Debug for super::StreamingPullResponse {
119 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
120 let mut debug_struct = f.debug_struct("StreamingPullResponse");
121 debug_struct.field("received_messages", &self.received_messages);
122 debug_struct.field("acknowledge_confirmation", &self.acknowledge_confirmation);
123 debug_struct.field(
124 "modify_ack_deadline_confirmation",
125 &self.modify_ack_deadline_confirmation,
126 );
127 debug_struct.field("subscription_properties", &self.subscription_properties);
128 if !self._unknown_fields.is_empty() {
129 debug_struct.field("_unknown_fields", &self._unknown_fields);
130 }
131 debug_struct.finish()
132 }
133}
134
135impl std::fmt::Debug for super::streaming_pull_response::AcknowledgeConfirmation {
136 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
137 let mut debug_struct = f.debug_struct("AcknowledgeConfirmation");
138 debug_struct.field("ack_ids", &self.ack_ids);
139 debug_struct.field("invalid_ack_ids", &self.invalid_ack_ids);
140 debug_struct.field("unordered_ack_ids", &self.unordered_ack_ids);
141 debug_struct.field("temporary_failed_ack_ids", &self.temporary_failed_ack_ids);
142 if !self._unknown_fields.is_empty() {
143 debug_struct.field("_unknown_fields", &self._unknown_fields);
144 }
145 debug_struct.finish()
146 }
147}
148
149impl std::fmt::Debug for super::streaming_pull_response::ModifyAckDeadlineConfirmation {
150 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
151 let mut debug_struct = f.debug_struct("ModifyAckDeadlineConfirmation");
152 debug_struct.field("ack_ids", &self.ack_ids);
153 debug_struct.field("invalid_ack_ids", &self.invalid_ack_ids);
154 debug_struct.field("temporary_failed_ack_ids", &self.temporary_failed_ack_ids);
155 if !self._unknown_fields.is_empty() {
156 debug_struct.field("_unknown_fields", &self._unknown_fields);
157 }
158 debug_struct.finish()
159 }
160}
161
162impl std::fmt::Debug for super::streaming_pull_response::SubscriptionProperties {
163 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
164 let mut debug_struct = f.debug_struct("SubscriptionProperties");
165 debug_struct.field(
166 "exactly_once_delivery_enabled",
167 &self.exactly_once_delivery_enabled,
168 );
169 debug_struct.field("message_ordering_enabled", &self.message_ordering_enabled);
170 if !self._unknown_fields.is_empty() {
171 debug_struct.field("_unknown_fields", &self._unknown_fields);
172 }
173 debug_struct.finish()
174 }
175}