1#[allow(unused_imports)]
18use super::*;
19
20impl std::fmt::Debug for super::MessageStoragePolicy {
21 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
22 let mut debug_struct = f.debug_struct("MessageStoragePolicy");
23 debug_struct.field(
24 "allowed_persistence_regions",
25 &self.allowed_persistence_regions,
26 );
27 debug_struct.field("enforce_in_transit", &self.enforce_in_transit);
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::SchemaSettings {
36 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
37 let mut debug_struct = f.debug_struct("SchemaSettings");
38 debug_struct.field("schema", &self.schema);
39 debug_struct.field("encoding", &self.encoding);
40 debug_struct.field("first_revision_id", &self.first_revision_id);
41 debug_struct.field("last_revision_id", &self.last_revision_id);
42 if !self._unknown_fields.is_empty() {
43 debug_struct.field("_unknown_fields", &self._unknown_fields);
44 }
45 debug_struct.finish()
46 }
47}
48
49impl std::fmt::Debug for super::IngestionDataSourceSettings {
50 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
51 let mut debug_struct = f.debug_struct("IngestionDataSourceSettings");
52 debug_struct.field("platform_logs_settings", &self.platform_logs_settings);
53 debug_struct.field("source", &self.source);
54 if !self._unknown_fields.is_empty() {
55 debug_struct.field("_unknown_fields", &self._unknown_fields);
56 }
57 debug_struct.finish()
58 }
59}
60
61impl std::fmt::Debug for super::ingestion_data_source_settings::AwsKinesis {
62 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
63 let mut debug_struct = f.debug_struct("AwsKinesis");
64 debug_struct.field("state", &self.state);
65 debug_struct.field("stream_arn", &self.stream_arn);
66 debug_struct.field("consumer_arn", &self.consumer_arn);
67 debug_struct.field("aws_role_arn", &self.aws_role_arn);
68 debug_struct.field("gcp_service_account", &self.gcp_service_account);
69 if !self._unknown_fields.is_empty() {
70 debug_struct.field("_unknown_fields", &self._unknown_fields);
71 }
72 debug_struct.finish()
73 }
74}
75
76impl std::fmt::Debug for super::ingestion_data_source_settings::CloudStorage {
77 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
78 let mut debug_struct = f.debug_struct("CloudStorage");
79 debug_struct.field("state", &self.state);
80 debug_struct.field("bucket", &self.bucket);
81 debug_struct.field(
82 "minimum_object_create_time",
83 &self.minimum_object_create_time,
84 );
85 debug_struct.field("match_glob", &self.match_glob);
86 debug_struct.field("input_format", &self.input_format);
87 if !self._unknown_fields.is_empty() {
88 debug_struct.field("_unknown_fields", &self._unknown_fields);
89 }
90 debug_struct.finish()
91 }
92}
93
94impl std::fmt::Debug for super::ingestion_data_source_settings::cloud_storage::TextFormat {
95 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
96 let mut debug_struct = f.debug_struct("TextFormat");
97 debug_struct.field("delimiter", &self.delimiter);
98 if !self._unknown_fields.is_empty() {
99 debug_struct.field("_unknown_fields", &self._unknown_fields);
100 }
101 debug_struct.finish()
102 }
103}
104
105impl std::fmt::Debug for super::ingestion_data_source_settings::cloud_storage::AvroFormat {
106 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
107 let mut debug_struct = f.debug_struct("AvroFormat");
108 if !self._unknown_fields.is_empty() {
109 debug_struct.field("_unknown_fields", &self._unknown_fields);
110 }
111 debug_struct.finish()
112 }
113}
114
115impl std::fmt::Debug for super::ingestion_data_source_settings::cloud_storage::PubSubAvroFormat {
116 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
117 let mut debug_struct = f.debug_struct("PubSubAvroFormat");
118 if !self._unknown_fields.is_empty() {
119 debug_struct.field("_unknown_fields", &self._unknown_fields);
120 }
121 debug_struct.finish()
122 }
123}
124
125impl std::fmt::Debug for super::ingestion_data_source_settings::AzureEventHubs {
126 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
127 let mut debug_struct = f.debug_struct("AzureEventHubs");
128 debug_struct.field("state", &self.state);
129 debug_struct.field("resource_group", &self.resource_group);
130 debug_struct.field("namespace", &self.namespace);
131 debug_struct.field("event_hub", &self.event_hub);
132 debug_struct.field("client_id", &self.client_id);
133 debug_struct.field("tenant_id", &self.tenant_id);
134 debug_struct.field("subscription_id", &self.subscription_id);
135 debug_struct.field("gcp_service_account", &self.gcp_service_account);
136 if !self._unknown_fields.is_empty() {
137 debug_struct.field("_unknown_fields", &self._unknown_fields);
138 }
139 debug_struct.finish()
140 }
141}
142
143impl std::fmt::Debug for super::ingestion_data_source_settings::AwsMsk {
144 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
145 let mut debug_struct = f.debug_struct("AwsMsk");
146 debug_struct.field("state", &self.state);
147 debug_struct.field("cluster_arn", &self.cluster_arn);
148 debug_struct.field("topic", &self.topic);
149 debug_struct.field("aws_role_arn", &self.aws_role_arn);
150 debug_struct.field("gcp_service_account", &self.gcp_service_account);
151 if !self._unknown_fields.is_empty() {
152 debug_struct.field("_unknown_fields", &self._unknown_fields);
153 }
154 debug_struct.finish()
155 }
156}
157
158impl std::fmt::Debug for super::ingestion_data_source_settings::ConfluentCloud {
159 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
160 let mut debug_struct = f.debug_struct("ConfluentCloud");
161 debug_struct.field("state", &self.state);
162 debug_struct.field("bootstrap_server", &self.bootstrap_server);
163 debug_struct.field("cluster_id", &self.cluster_id);
164 debug_struct.field("topic", &self.topic);
165 debug_struct.field("identity_pool_id", &self.identity_pool_id);
166 debug_struct.field("gcp_service_account", &self.gcp_service_account);
167 if !self._unknown_fields.is_empty() {
168 debug_struct.field("_unknown_fields", &self._unknown_fields);
169 }
170 debug_struct.finish()
171 }
172}
173
174impl std::fmt::Debug for super::PlatformLogsSettings {
175 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
176 let mut debug_struct = f.debug_struct("PlatformLogsSettings");
177 debug_struct.field("severity", &self.severity);
178 if !self._unknown_fields.is_empty() {
179 debug_struct.field("_unknown_fields", &self._unknown_fields);
180 }
181 debug_struct.finish()
182 }
183}
184
185impl std::fmt::Debug for super::JavaScriptUDF {
186 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
187 let mut debug_struct = f.debug_struct("JavaScriptUDF");
188 debug_struct.field("function_name", &self.function_name);
189 debug_struct.field("code", &self.code);
190 if !self._unknown_fields.is_empty() {
191 debug_struct.field("_unknown_fields", &self._unknown_fields);
192 }
193 debug_struct.finish()
194 }
195}
196
197impl std::fmt::Debug for super::AIInference {
198 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
199 let mut debug_struct = f.debug_struct("AIInference");
200 debug_struct.field("endpoint", &self.endpoint);
201 debug_struct.field("service_account_email", &self.service_account_email);
202 debug_struct.field("inference_mode", &self.inference_mode);
203 if !self._unknown_fields.is_empty() {
204 debug_struct.field("_unknown_fields", &self._unknown_fields);
205 }
206 debug_struct.finish()
207 }
208}
209
210impl std::fmt::Debug for super::ai_inference::UnstructuredInference {
211 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
212 let mut debug_struct = f.debug_struct("UnstructuredInference");
213 debug_struct.field("parameters", &self.parameters);
214 if !self._unknown_fields.is_empty() {
215 debug_struct.field("_unknown_fields", &self._unknown_fields);
216 }
217 debug_struct.finish()
218 }
219}
220
221impl std::fmt::Debug for super::MessageTransform {
222 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
223 let mut debug_struct = f.debug_struct("MessageTransform");
224 debug_struct.field("enabled", &self.enabled);
225 debug_struct.field("disabled", &self.disabled);
226 debug_struct.field("transform", &self.transform);
227 if !self._unknown_fields.is_empty() {
228 debug_struct.field("_unknown_fields", &self._unknown_fields);
229 }
230 debug_struct.finish()
231 }
232}
233
234impl std::fmt::Debug for super::Topic {
235 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
236 let mut debug_struct = f.debug_struct("Topic");
237 debug_struct.field("name", &self.name);
238 debug_struct.field("labels", &self.labels);
239 debug_struct.field("message_storage_policy", &self.message_storage_policy);
240 debug_struct.field("kms_key_name", &self.kms_key_name);
241 debug_struct.field("schema_settings", &self.schema_settings);
242 debug_struct.field("satisfies_pzs", &self.satisfies_pzs);
243 debug_struct.field(
244 "message_retention_duration",
245 &self.message_retention_duration,
246 );
247 debug_struct.field("state", &self.state);
248 debug_struct.field(
249 "ingestion_data_source_settings",
250 &self.ingestion_data_source_settings,
251 );
252 debug_struct.field("message_transforms", &self.message_transforms);
253 debug_struct.field("tags", &self.tags);
254 if !self._unknown_fields.is_empty() {
255 debug_struct.field("_unknown_fields", &self._unknown_fields);
256 }
257 debug_struct.finish()
258 }
259}
260
261impl std::fmt::Debug for super::GetTopicRequest {
262 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
263 let mut debug_struct = f.debug_struct("GetTopicRequest");
264 debug_struct.field("topic", &self.topic);
265 if !self._unknown_fields.is_empty() {
266 debug_struct.field("_unknown_fields", &self._unknown_fields);
267 }
268 debug_struct.finish()
269 }
270}
271
272impl std::fmt::Debug for super::UpdateTopicRequest {
273 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
274 let mut debug_struct = f.debug_struct("UpdateTopicRequest");
275 debug_struct.field("topic", &self.topic);
276 debug_struct.field("update_mask", &self.update_mask);
277 if !self._unknown_fields.is_empty() {
278 debug_struct.field("_unknown_fields", &self._unknown_fields);
279 }
280 debug_struct.finish()
281 }
282}
283
284impl std::fmt::Debug for super::ListTopicsRequest {
285 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
286 let mut debug_struct = f.debug_struct("ListTopicsRequest");
287 debug_struct.field("project", &self.project);
288 debug_struct.field("page_size", &self.page_size);
289 debug_struct.field("page_token", &self.page_token);
290 if !self._unknown_fields.is_empty() {
291 debug_struct.field("_unknown_fields", &self._unknown_fields);
292 }
293 debug_struct.finish()
294 }
295}
296
297impl std::fmt::Debug for super::ListTopicsResponse {
298 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
299 let mut debug_struct = f.debug_struct("ListTopicsResponse");
300 debug_struct.field("topics", &self.topics);
301 debug_struct.field("next_page_token", &self.next_page_token);
302 if !self._unknown_fields.is_empty() {
303 debug_struct.field("_unknown_fields", &self._unknown_fields);
304 }
305 debug_struct.finish()
306 }
307}
308
309impl std::fmt::Debug for super::ListTopicSubscriptionsRequest {
310 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
311 let mut debug_struct = f.debug_struct("ListTopicSubscriptionsRequest");
312 debug_struct.field("topic", &self.topic);
313 debug_struct.field("page_size", &self.page_size);
314 debug_struct.field("page_token", &self.page_token);
315 if !self._unknown_fields.is_empty() {
316 debug_struct.field("_unknown_fields", &self._unknown_fields);
317 }
318 debug_struct.finish()
319 }
320}
321
322impl std::fmt::Debug for super::ListTopicSubscriptionsResponse {
323 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
324 let mut debug_struct = f.debug_struct("ListTopicSubscriptionsResponse");
325 debug_struct.field("subscriptions", &self.subscriptions);
326 debug_struct.field("next_page_token", &self.next_page_token);
327 if !self._unknown_fields.is_empty() {
328 debug_struct.field("_unknown_fields", &self._unknown_fields);
329 }
330 debug_struct.finish()
331 }
332}
333
334impl std::fmt::Debug for super::ListTopicSnapshotsRequest {
335 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
336 let mut debug_struct = f.debug_struct("ListTopicSnapshotsRequest");
337 debug_struct.field("topic", &self.topic);
338 debug_struct.field("page_size", &self.page_size);
339 debug_struct.field("page_token", &self.page_token);
340 if !self._unknown_fields.is_empty() {
341 debug_struct.field("_unknown_fields", &self._unknown_fields);
342 }
343 debug_struct.finish()
344 }
345}
346
347impl std::fmt::Debug for super::ListTopicSnapshotsResponse {
348 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
349 let mut debug_struct = f.debug_struct("ListTopicSnapshotsResponse");
350 debug_struct.field("snapshots", &self.snapshots);
351 debug_struct.field("next_page_token", &self.next_page_token);
352 if !self._unknown_fields.is_empty() {
353 debug_struct.field("_unknown_fields", &self._unknown_fields);
354 }
355 debug_struct.finish()
356 }
357}
358
359impl std::fmt::Debug for super::DeleteTopicRequest {
360 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
361 let mut debug_struct = f.debug_struct("DeleteTopicRequest");
362 debug_struct.field("topic", &self.topic);
363 if !self._unknown_fields.is_empty() {
364 debug_struct.field("_unknown_fields", &self._unknown_fields);
365 }
366 debug_struct.finish()
367 }
368}
369
370impl std::fmt::Debug for super::DetachSubscriptionRequest {
371 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
372 let mut debug_struct = f.debug_struct("DetachSubscriptionRequest");
373 debug_struct.field("subscription", &self.subscription);
374 if !self._unknown_fields.is_empty() {
375 debug_struct.field("_unknown_fields", &self._unknown_fields);
376 }
377 debug_struct.finish()
378 }
379}
380
381impl std::fmt::Debug for super::DetachSubscriptionResponse {
382 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
383 let mut debug_struct = f.debug_struct("DetachSubscriptionResponse");
384 if !self._unknown_fields.is_empty() {
385 debug_struct.field("_unknown_fields", &self._unknown_fields);
386 }
387 debug_struct.finish()
388 }
389}
390
391impl std::fmt::Debug for super::Subscription {
392 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
393 let mut debug_struct = f.debug_struct("Subscription");
394 debug_struct.field("name", &self.name);
395 debug_struct.field("topic", &self.topic);
396 debug_struct.field("push_config", &self.push_config);
397 debug_struct.field("bigquery_config", &self.bigquery_config);
398 debug_struct.field("cloud_storage_config", &self.cloud_storage_config);
399 debug_struct.field("bigtable_config", &self.bigtable_config);
400 debug_struct.field("ack_deadline_seconds", &self.ack_deadline_seconds);
401 debug_struct.field("retain_acked_messages", &self.retain_acked_messages);
402 debug_struct.field(
403 "message_retention_duration",
404 &self.message_retention_duration,
405 );
406 debug_struct.field("labels", &self.labels);
407 debug_struct.field("enable_message_ordering", &self.enable_message_ordering);
408 debug_struct.field("expiration_policy", &self.expiration_policy);
409 debug_struct.field("filter", &self.filter);
410 debug_struct.field("dead_letter_policy", &self.dead_letter_policy);
411 debug_struct.field("retry_policy", &self.retry_policy);
412 debug_struct.field("detached", &self.detached);
413 debug_struct.field(
414 "enable_exactly_once_delivery",
415 &self.enable_exactly_once_delivery,
416 );
417 debug_struct.field(
418 "topic_message_retention_duration",
419 &self.topic_message_retention_duration,
420 );
421 debug_struct.field("state", &self.state);
422 debug_struct.field(
423 "analytics_hub_subscription_info",
424 &self.analytics_hub_subscription_info,
425 );
426 debug_struct.field("message_transforms", &self.message_transforms);
427 debug_struct.field("tags", &self.tags);
428 if !self._unknown_fields.is_empty() {
429 debug_struct.field("_unknown_fields", &self._unknown_fields);
430 }
431 debug_struct.finish()
432 }
433}
434
435impl std::fmt::Debug for super::subscription::AnalyticsHubSubscriptionInfo {
436 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
437 let mut debug_struct = f.debug_struct("AnalyticsHubSubscriptionInfo");
438 debug_struct.field("listing", &self.listing);
439 debug_struct.field("subscription", &self.subscription);
440 if !self._unknown_fields.is_empty() {
441 debug_struct.field("_unknown_fields", &self._unknown_fields);
442 }
443 debug_struct.finish()
444 }
445}
446
447impl std::fmt::Debug for super::RetryPolicy {
448 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
449 let mut debug_struct = f.debug_struct("RetryPolicy");
450 debug_struct.field("minimum_backoff", &self.minimum_backoff);
451 debug_struct.field("maximum_backoff", &self.maximum_backoff);
452 if !self._unknown_fields.is_empty() {
453 debug_struct.field("_unknown_fields", &self._unknown_fields);
454 }
455 debug_struct.finish()
456 }
457}
458
459impl std::fmt::Debug for super::DeadLetterPolicy {
460 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
461 let mut debug_struct = f.debug_struct("DeadLetterPolicy");
462 debug_struct.field("dead_letter_topic", &self.dead_letter_topic);
463 debug_struct.field("max_delivery_attempts", &self.max_delivery_attempts);
464 if !self._unknown_fields.is_empty() {
465 debug_struct.field("_unknown_fields", &self._unknown_fields);
466 }
467 debug_struct.finish()
468 }
469}
470
471impl std::fmt::Debug for super::ExpirationPolicy {
472 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
473 let mut debug_struct = f.debug_struct("ExpirationPolicy");
474 debug_struct.field("ttl", &self.ttl);
475 if !self._unknown_fields.is_empty() {
476 debug_struct.field("_unknown_fields", &self._unknown_fields);
477 }
478 debug_struct.finish()
479 }
480}
481
482impl std::fmt::Debug for super::PushConfig {
483 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
484 let mut debug_struct = f.debug_struct("PushConfig");
485 debug_struct.field("push_endpoint", &self.push_endpoint);
486 debug_struct.field("attributes", &self.attributes);
487 debug_struct.field("authentication_method", &self.authentication_method);
488 debug_struct.field("wrapper", &self.wrapper);
489 if !self._unknown_fields.is_empty() {
490 debug_struct.field("_unknown_fields", &self._unknown_fields);
491 }
492 debug_struct.finish()
493 }
494}
495
496impl std::fmt::Debug for super::push_config::OidcToken {
497 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
498 let mut debug_struct = f.debug_struct("OidcToken");
499 debug_struct.field("service_account_email", &self.service_account_email);
500 debug_struct.field("audience", &self.audience);
501 if !self._unknown_fields.is_empty() {
502 debug_struct.field("_unknown_fields", &self._unknown_fields);
503 }
504 debug_struct.finish()
505 }
506}
507
508impl std::fmt::Debug for super::push_config::PubsubWrapper {
509 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
510 let mut debug_struct = f.debug_struct("PubsubWrapper");
511 if !self._unknown_fields.is_empty() {
512 debug_struct.field("_unknown_fields", &self._unknown_fields);
513 }
514 debug_struct.finish()
515 }
516}
517
518impl std::fmt::Debug for super::push_config::NoWrapper {
519 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
520 let mut debug_struct = f.debug_struct("NoWrapper");
521 debug_struct.field("write_metadata", &self.write_metadata);
522 if !self._unknown_fields.is_empty() {
523 debug_struct.field("_unknown_fields", &self._unknown_fields);
524 }
525 debug_struct.finish()
526 }
527}
528
529impl std::fmt::Debug for super::BigQueryConfig {
530 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
531 let mut debug_struct = f.debug_struct("BigQueryConfig");
532 debug_struct.field("table", &self.table);
533 debug_struct.field("use_topic_schema", &self.use_topic_schema);
534 debug_struct.field("write_metadata", &self.write_metadata);
535 debug_struct.field("drop_unknown_fields", &self.drop_unknown_fields);
536 debug_struct.field("state", &self.state);
537 debug_struct.field("use_table_schema", &self.use_table_schema);
538 debug_struct.field("service_account_email", &self.service_account_email);
539 if !self._unknown_fields.is_empty() {
540 debug_struct.field("_unknown_fields", &self._unknown_fields);
541 }
542 debug_struct.finish()
543 }
544}
545
546impl std::fmt::Debug for super::BigtableConfig {
547 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
548 let mut debug_struct = f.debug_struct("BigtableConfig");
549 debug_struct.field("table", &self.table);
550 debug_struct.field("app_profile_id", &self.app_profile_id);
551 debug_struct.field("service_account_email", &self.service_account_email);
552 debug_struct.field("write_metadata", &self.write_metadata);
553 debug_struct.field("state", &self.state);
554 if !self._unknown_fields.is_empty() {
555 debug_struct.field("_unknown_fields", &self._unknown_fields);
556 }
557 debug_struct.finish()
558 }
559}
560
561impl std::fmt::Debug for super::CloudStorageConfig {
562 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
563 let mut debug_struct = f.debug_struct("CloudStorageConfig");
564 debug_struct.field("bucket", &self.bucket);
565 debug_struct.field("filename_prefix", &self.filename_prefix);
566 debug_struct.field("filename_suffix", &self.filename_suffix);
567 debug_struct.field("filename_datetime_format", &self.filename_datetime_format);
568 debug_struct.field("max_duration", &self.max_duration);
569 debug_struct.field("max_bytes", &self.max_bytes);
570 debug_struct.field("max_messages", &self.max_messages);
571 debug_struct.field("state", &self.state);
572 debug_struct.field("service_account_email", &self.service_account_email);
573 debug_struct.field("output_format", &self.output_format);
574 if !self._unknown_fields.is_empty() {
575 debug_struct.field("_unknown_fields", &self._unknown_fields);
576 }
577 debug_struct.finish()
578 }
579}
580
581impl std::fmt::Debug for super::cloud_storage_config::TextConfig {
582 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
583 let mut debug_struct = f.debug_struct("TextConfig");
584 if !self._unknown_fields.is_empty() {
585 debug_struct.field("_unknown_fields", &self._unknown_fields);
586 }
587 debug_struct.finish()
588 }
589}
590
591impl std::fmt::Debug for super::cloud_storage_config::AvroConfig {
592 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
593 let mut debug_struct = f.debug_struct("AvroConfig");
594 debug_struct.field("write_metadata", &self.write_metadata);
595 debug_struct.field("use_topic_schema", &self.use_topic_schema);
596 if !self._unknown_fields.is_empty() {
597 debug_struct.field("_unknown_fields", &self._unknown_fields);
598 }
599 debug_struct.finish()
600 }
601}
602
603impl std::fmt::Debug for super::GetSubscriptionRequest {
604 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
605 let mut debug_struct = f.debug_struct("GetSubscriptionRequest");
606 debug_struct.field("subscription", &self.subscription);
607 if !self._unknown_fields.is_empty() {
608 debug_struct.field("_unknown_fields", &self._unknown_fields);
609 }
610 debug_struct.finish()
611 }
612}
613
614impl std::fmt::Debug for super::UpdateSubscriptionRequest {
615 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
616 let mut debug_struct = f.debug_struct("UpdateSubscriptionRequest");
617 debug_struct.field("subscription", &self.subscription);
618 debug_struct.field("update_mask", &self.update_mask);
619 if !self._unknown_fields.is_empty() {
620 debug_struct.field("_unknown_fields", &self._unknown_fields);
621 }
622 debug_struct.finish()
623 }
624}
625
626impl std::fmt::Debug for super::ListSubscriptionsRequest {
627 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
628 let mut debug_struct = f.debug_struct("ListSubscriptionsRequest");
629 debug_struct.field("project", &self.project);
630 debug_struct.field("page_size", &self.page_size);
631 debug_struct.field("page_token", &self.page_token);
632 if !self._unknown_fields.is_empty() {
633 debug_struct.field("_unknown_fields", &self._unknown_fields);
634 }
635 debug_struct.finish()
636 }
637}
638
639impl std::fmt::Debug for super::ListSubscriptionsResponse {
640 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
641 let mut debug_struct = f.debug_struct("ListSubscriptionsResponse");
642 debug_struct.field("subscriptions", &self.subscriptions);
643 debug_struct.field("next_page_token", &self.next_page_token);
644 if !self._unknown_fields.is_empty() {
645 debug_struct.field("_unknown_fields", &self._unknown_fields);
646 }
647 debug_struct.finish()
648 }
649}
650
651impl std::fmt::Debug for super::DeleteSubscriptionRequest {
652 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
653 let mut debug_struct = f.debug_struct("DeleteSubscriptionRequest");
654 debug_struct.field("subscription", &self.subscription);
655 if !self._unknown_fields.is_empty() {
656 debug_struct.field("_unknown_fields", &self._unknown_fields);
657 }
658 debug_struct.finish()
659 }
660}
661
662impl std::fmt::Debug for super::ModifyPushConfigRequest {
663 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
664 let mut debug_struct = f.debug_struct("ModifyPushConfigRequest");
665 debug_struct.field("subscription", &self.subscription);
666 debug_struct.field("push_config", &self.push_config);
667 if !self._unknown_fields.is_empty() {
668 debug_struct.field("_unknown_fields", &self._unknown_fields);
669 }
670 debug_struct.finish()
671 }
672}
673
674impl std::fmt::Debug for super::CreateSnapshotRequest {
675 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
676 let mut debug_struct = f.debug_struct("CreateSnapshotRequest");
677 debug_struct.field("name", &self.name);
678 debug_struct.field("subscription", &self.subscription);
679 debug_struct.field("labels", &self.labels);
680 debug_struct.field("tags", &self.tags);
681 if !self._unknown_fields.is_empty() {
682 debug_struct.field("_unknown_fields", &self._unknown_fields);
683 }
684 debug_struct.finish()
685 }
686}
687
688impl std::fmt::Debug for super::UpdateSnapshotRequest {
689 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
690 let mut debug_struct = f.debug_struct("UpdateSnapshotRequest");
691 debug_struct.field("snapshot", &self.snapshot);
692 debug_struct.field("update_mask", &self.update_mask);
693 if !self._unknown_fields.is_empty() {
694 debug_struct.field("_unknown_fields", &self._unknown_fields);
695 }
696 debug_struct.finish()
697 }
698}
699
700impl std::fmt::Debug for super::Snapshot {
701 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
702 let mut debug_struct = f.debug_struct("Snapshot");
703 debug_struct.field("name", &self.name);
704 debug_struct.field("topic", &self.topic);
705 debug_struct.field("expire_time", &self.expire_time);
706 debug_struct.field("labels", &self.labels);
707 if !self._unknown_fields.is_empty() {
708 debug_struct.field("_unknown_fields", &self._unknown_fields);
709 }
710 debug_struct.finish()
711 }
712}
713
714impl std::fmt::Debug for super::GetSnapshotRequest {
715 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
716 let mut debug_struct = f.debug_struct("GetSnapshotRequest");
717 debug_struct.field("snapshot", &self.snapshot);
718 if !self._unknown_fields.is_empty() {
719 debug_struct.field("_unknown_fields", &self._unknown_fields);
720 }
721 debug_struct.finish()
722 }
723}
724
725impl std::fmt::Debug for super::ListSnapshotsRequest {
726 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
727 let mut debug_struct = f.debug_struct("ListSnapshotsRequest");
728 debug_struct.field("project", &self.project);
729 debug_struct.field("page_size", &self.page_size);
730 debug_struct.field("page_token", &self.page_token);
731 if !self._unknown_fields.is_empty() {
732 debug_struct.field("_unknown_fields", &self._unknown_fields);
733 }
734 debug_struct.finish()
735 }
736}
737
738impl std::fmt::Debug for super::ListSnapshotsResponse {
739 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
740 let mut debug_struct = f.debug_struct("ListSnapshotsResponse");
741 debug_struct.field("snapshots", &self.snapshots);
742 debug_struct.field("next_page_token", &self.next_page_token);
743 if !self._unknown_fields.is_empty() {
744 debug_struct.field("_unknown_fields", &self._unknown_fields);
745 }
746 debug_struct.finish()
747 }
748}
749
750impl std::fmt::Debug for super::DeleteSnapshotRequest {
751 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
752 let mut debug_struct = f.debug_struct("DeleteSnapshotRequest");
753 debug_struct.field("snapshot", &self.snapshot);
754 if !self._unknown_fields.is_empty() {
755 debug_struct.field("_unknown_fields", &self._unknown_fields);
756 }
757 debug_struct.finish()
758 }
759}
760
761impl std::fmt::Debug for super::SeekRequest {
762 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
763 let mut debug_struct = f.debug_struct("SeekRequest");
764 debug_struct.field("subscription", &self.subscription);
765 debug_struct.field("target", &self.target);
766 if !self._unknown_fields.is_empty() {
767 debug_struct.field("_unknown_fields", &self._unknown_fields);
768 }
769 debug_struct.finish()
770 }
771}
772
773impl std::fmt::Debug for super::SeekResponse {
774 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
775 let mut debug_struct = f.debug_struct("SeekResponse");
776 if !self._unknown_fields.is_empty() {
777 debug_struct.field("_unknown_fields", &self._unknown_fields);
778 }
779 debug_struct.finish()
780 }
781}
782
783impl std::fmt::Debug for super::Schema {
784 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
785 let mut debug_struct = f.debug_struct("Schema");
786 debug_struct.field("name", &self.name);
787 debug_struct.field("r#type", &self.r#type);
788 debug_struct.field("definition", &self.definition);
789 debug_struct.field("revision_id", &self.revision_id);
790 debug_struct.field("revision_create_time", &self.revision_create_time);
791 if !self._unknown_fields.is_empty() {
792 debug_struct.field("_unknown_fields", &self._unknown_fields);
793 }
794 debug_struct.finish()
795 }
796}
797
798impl std::fmt::Debug for super::CreateSchemaRequest {
799 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
800 let mut debug_struct = f.debug_struct("CreateSchemaRequest");
801 debug_struct.field("parent", &self.parent);
802 debug_struct.field("schema", &self.schema);
803 debug_struct.field("schema_id", &self.schema_id);
804 if !self._unknown_fields.is_empty() {
805 debug_struct.field("_unknown_fields", &self._unknown_fields);
806 }
807 debug_struct.finish()
808 }
809}
810
811impl std::fmt::Debug for super::GetSchemaRequest {
812 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
813 let mut debug_struct = f.debug_struct("GetSchemaRequest");
814 debug_struct.field("name", &self.name);
815 debug_struct.field("view", &self.view);
816 if !self._unknown_fields.is_empty() {
817 debug_struct.field("_unknown_fields", &self._unknown_fields);
818 }
819 debug_struct.finish()
820 }
821}
822
823impl std::fmt::Debug for super::ListSchemasRequest {
824 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
825 let mut debug_struct = f.debug_struct("ListSchemasRequest");
826 debug_struct.field("parent", &self.parent);
827 debug_struct.field("view", &self.view);
828 debug_struct.field("page_size", &self.page_size);
829 debug_struct.field("page_token", &self.page_token);
830 if !self._unknown_fields.is_empty() {
831 debug_struct.field("_unknown_fields", &self._unknown_fields);
832 }
833 debug_struct.finish()
834 }
835}
836
837impl std::fmt::Debug for super::ListSchemasResponse {
838 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
839 let mut debug_struct = f.debug_struct("ListSchemasResponse");
840 debug_struct.field("schemas", &self.schemas);
841 debug_struct.field("next_page_token", &self.next_page_token);
842 if !self._unknown_fields.is_empty() {
843 debug_struct.field("_unknown_fields", &self._unknown_fields);
844 }
845 debug_struct.finish()
846 }
847}
848
849impl std::fmt::Debug for super::ListSchemaRevisionsRequest {
850 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
851 let mut debug_struct = f.debug_struct("ListSchemaRevisionsRequest");
852 debug_struct.field("name", &self.name);
853 debug_struct.field("view", &self.view);
854 debug_struct.field("page_size", &self.page_size);
855 debug_struct.field("page_token", &self.page_token);
856 if !self._unknown_fields.is_empty() {
857 debug_struct.field("_unknown_fields", &self._unknown_fields);
858 }
859 debug_struct.finish()
860 }
861}
862
863impl std::fmt::Debug for super::ListSchemaRevisionsResponse {
864 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
865 let mut debug_struct = f.debug_struct("ListSchemaRevisionsResponse");
866 debug_struct.field("schemas", &self.schemas);
867 debug_struct.field("next_page_token", &self.next_page_token);
868 if !self._unknown_fields.is_empty() {
869 debug_struct.field("_unknown_fields", &self._unknown_fields);
870 }
871 debug_struct.finish()
872 }
873}
874
875impl std::fmt::Debug for super::CommitSchemaRequest {
876 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
877 let mut debug_struct = f.debug_struct("CommitSchemaRequest");
878 debug_struct.field("name", &self.name);
879 debug_struct.field("schema", &self.schema);
880 if !self._unknown_fields.is_empty() {
881 debug_struct.field("_unknown_fields", &self._unknown_fields);
882 }
883 debug_struct.finish()
884 }
885}
886
887impl std::fmt::Debug for super::RollbackSchemaRequest {
888 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
889 let mut debug_struct = f.debug_struct("RollbackSchemaRequest");
890 debug_struct.field("name", &self.name);
891 debug_struct.field("revision_id", &self.revision_id);
892 if !self._unknown_fields.is_empty() {
893 debug_struct.field("_unknown_fields", &self._unknown_fields);
894 }
895 debug_struct.finish()
896 }
897}
898
899impl std::fmt::Debug for super::DeleteSchemaRevisionRequest {
900 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
901 let mut debug_struct = f.debug_struct("DeleteSchemaRevisionRequest");
902 debug_struct.field("name", &self.name);
903 debug_struct.field("revision_id", &self.revision_id);
904 if !self._unknown_fields.is_empty() {
905 debug_struct.field("_unknown_fields", &self._unknown_fields);
906 }
907 debug_struct.finish()
908 }
909}
910
911impl std::fmt::Debug for super::DeleteSchemaRequest {
912 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
913 let mut debug_struct = f.debug_struct("DeleteSchemaRequest");
914 debug_struct.field("name", &self.name);
915 if !self._unknown_fields.is_empty() {
916 debug_struct.field("_unknown_fields", &self._unknown_fields);
917 }
918 debug_struct.finish()
919 }
920}
921
922impl std::fmt::Debug for super::ValidateSchemaRequest {
923 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
924 let mut debug_struct = f.debug_struct("ValidateSchemaRequest");
925 debug_struct.field("parent", &self.parent);
926 debug_struct.field("schema", &self.schema);
927 if !self._unknown_fields.is_empty() {
928 debug_struct.field("_unknown_fields", &self._unknown_fields);
929 }
930 debug_struct.finish()
931 }
932}
933
934impl std::fmt::Debug for super::ValidateSchemaResponse {
935 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
936 let mut debug_struct = f.debug_struct("ValidateSchemaResponse");
937 if !self._unknown_fields.is_empty() {
938 debug_struct.field("_unknown_fields", &self._unknown_fields);
939 }
940 debug_struct.finish()
941 }
942}
943
944impl std::fmt::Debug for super::ValidateMessageRequest {
945 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
946 let mut debug_struct = f.debug_struct("ValidateMessageRequest");
947 debug_struct.field("parent", &self.parent);
948 debug_struct.field("message", &self.message);
949 debug_struct.field("encoding", &self.encoding);
950 debug_struct.field("schema_spec", &self.schema_spec);
951 if !self._unknown_fields.is_empty() {
952 debug_struct.field("_unknown_fields", &self._unknown_fields);
953 }
954 debug_struct.finish()
955 }
956}
957
958impl std::fmt::Debug for super::ValidateMessageResponse {
959 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
960 let mut debug_struct = f.debug_struct("ValidateMessageResponse");
961 if !self._unknown_fields.is_empty() {
962 debug_struct.field("_unknown_fields", &self._unknown_fields);
963 }
964 debug_struct.finish()
965 }
966}