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::Compression {
198 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
199 let mut debug_struct = f.debug_struct("Compression");
200 debug_struct.field("compression_algorithm", &self.compression_algorithm);
201 debug_struct.field("compression_mode", &self.compression_mode);
202 if !self._unknown_fields.is_empty() {
203 debug_struct.field("_unknown_fields", &self._unknown_fields);
204 }
205 debug_struct.finish()
206 }
207}
208
209impl std::fmt::Debug for super::AIInference {
210 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
211 let mut debug_struct = f.debug_struct("AIInference");
212 debug_struct.field("endpoint", &self.endpoint);
213 debug_struct.field("service_account_email", &self.service_account_email);
214 debug_struct.field("inference_mode", &self.inference_mode);
215 if !self._unknown_fields.is_empty() {
216 debug_struct.field("_unknown_fields", &self._unknown_fields);
217 }
218 debug_struct.finish()
219 }
220}
221
222impl std::fmt::Debug for super::ai_inference::UnstructuredInference {
223 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
224 let mut debug_struct = f.debug_struct("UnstructuredInference");
225 debug_struct.field("parameters", &self.parameters);
226 if !self._unknown_fields.is_empty() {
227 debug_struct.field("_unknown_fields", &self._unknown_fields);
228 }
229 debug_struct.finish()
230 }
231}
232
233impl std::fmt::Debug for super::MessageTransform {
234 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
235 let mut debug_struct = f.debug_struct("MessageTransform");
236 debug_struct.field("enabled", &self.enabled);
237 debug_struct.field("disabled", &self.disabled);
238 debug_struct.field("transform", &self.transform);
239 if !self._unknown_fields.is_empty() {
240 debug_struct.field("_unknown_fields", &self._unknown_fields);
241 }
242 debug_struct.finish()
243 }
244}
245
246impl std::fmt::Debug for super::Topic {
247 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
248 let mut debug_struct = f.debug_struct("Topic");
249 debug_struct.field("name", &self.name);
250 debug_struct.field("labels", &self.labels);
251 debug_struct.field("message_storage_policy", &self.message_storage_policy);
252 debug_struct.field("kms_key_name", &self.kms_key_name);
253 debug_struct.field("schema_settings", &self.schema_settings);
254 debug_struct.field("satisfies_pzs", &self.satisfies_pzs);
255 debug_struct.field(
256 "message_retention_duration",
257 &self.message_retention_duration,
258 );
259 debug_struct.field("state", &self.state);
260 debug_struct.field(
261 "ingestion_data_source_settings",
262 &self.ingestion_data_source_settings,
263 );
264 debug_struct.field("message_transforms", &self.message_transforms);
265 debug_struct.field("tags", &self.tags);
266 if !self._unknown_fields.is_empty() {
267 debug_struct.field("_unknown_fields", &self._unknown_fields);
268 }
269 debug_struct.finish()
270 }
271}
272
273impl std::fmt::Debug for super::GetTopicRequest {
274 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
275 let mut debug_struct = f.debug_struct("GetTopicRequest");
276 debug_struct.field("topic", &self.topic);
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::UpdateTopicRequest {
285 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
286 let mut debug_struct = f.debug_struct("UpdateTopicRequest");
287 debug_struct.field("topic", &self.topic);
288 debug_struct.field("update_mask", &self.update_mask);
289 if !self._unknown_fields.is_empty() {
290 debug_struct.field("_unknown_fields", &self._unknown_fields);
291 }
292 debug_struct.finish()
293 }
294}
295
296impl std::fmt::Debug for super::ListTopicsRequest {
297 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
298 let mut debug_struct = f.debug_struct("ListTopicsRequest");
299 debug_struct.field("project", &self.project);
300 debug_struct.field("page_size", &self.page_size);
301 debug_struct.field("page_token", &self.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::ListTopicsResponse {
310 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
311 let mut debug_struct = f.debug_struct("ListTopicsResponse");
312 debug_struct.field("topics", &self.topics);
313 debug_struct.field("next_page_token", &self.next_page_token);
314 if !self._unknown_fields.is_empty() {
315 debug_struct.field("_unknown_fields", &self._unknown_fields);
316 }
317 debug_struct.finish()
318 }
319}
320
321impl std::fmt::Debug for super::ListTopicSubscriptionsRequest {
322 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
323 let mut debug_struct = f.debug_struct("ListTopicSubscriptionsRequest");
324 debug_struct.field("topic", &self.topic);
325 debug_struct.field("page_size", &self.page_size);
326 debug_struct.field("page_token", &self.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::ListTopicSubscriptionsResponse {
335 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
336 let mut debug_struct = f.debug_struct("ListTopicSubscriptionsResponse");
337 debug_struct.field("subscriptions", &self.subscriptions);
338 debug_struct.field("next_page_token", &self.next_page_token);
339 if !self._unknown_fields.is_empty() {
340 debug_struct.field("_unknown_fields", &self._unknown_fields);
341 }
342 debug_struct.finish()
343 }
344}
345
346impl std::fmt::Debug for super::ListTopicSnapshotsRequest {
347 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
348 let mut debug_struct = f.debug_struct("ListTopicSnapshotsRequest");
349 debug_struct.field("topic", &self.topic);
350 debug_struct.field("page_size", &self.page_size);
351 debug_struct.field("page_token", &self.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::ListTopicSnapshotsResponse {
360 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
361 let mut debug_struct = f.debug_struct("ListTopicSnapshotsResponse");
362 debug_struct.field("snapshots", &self.snapshots);
363 debug_struct.field("next_page_token", &self.next_page_token);
364 if !self._unknown_fields.is_empty() {
365 debug_struct.field("_unknown_fields", &self._unknown_fields);
366 }
367 debug_struct.finish()
368 }
369}
370
371impl std::fmt::Debug for super::DeleteTopicRequest {
372 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
373 let mut debug_struct = f.debug_struct("DeleteTopicRequest");
374 debug_struct.field("topic", &self.topic);
375 if !self._unknown_fields.is_empty() {
376 debug_struct.field("_unknown_fields", &self._unknown_fields);
377 }
378 debug_struct.finish()
379 }
380}
381
382impl std::fmt::Debug for super::DetachSubscriptionRequest {
383 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
384 let mut debug_struct = f.debug_struct("DetachSubscriptionRequest");
385 debug_struct.field("subscription", &self.subscription);
386 if !self._unknown_fields.is_empty() {
387 debug_struct.field("_unknown_fields", &self._unknown_fields);
388 }
389 debug_struct.finish()
390 }
391}
392
393impl std::fmt::Debug for super::DetachSubscriptionResponse {
394 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
395 let mut debug_struct = f.debug_struct("DetachSubscriptionResponse");
396 if !self._unknown_fields.is_empty() {
397 debug_struct.field("_unknown_fields", &self._unknown_fields);
398 }
399 debug_struct.finish()
400 }
401}
402
403impl std::fmt::Debug for super::Subscription {
404 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
405 let mut debug_struct = f.debug_struct("Subscription");
406 debug_struct.field("name", &self.name);
407 debug_struct.field("topic", &self.topic);
408 debug_struct.field("push_config", &self.push_config);
409 debug_struct.field("bigquery_config", &self.bigquery_config);
410 debug_struct.field("cloud_storage_config", &self.cloud_storage_config);
411 debug_struct.field("bigtable_config", &self.bigtable_config);
412 debug_struct.field("ack_deadline_seconds", &self.ack_deadline_seconds);
413 debug_struct.field("retain_acked_messages", &self.retain_acked_messages);
414 debug_struct.field(
415 "message_retention_duration",
416 &self.message_retention_duration,
417 );
418 debug_struct.field("labels", &self.labels);
419 debug_struct.field("enable_message_ordering", &self.enable_message_ordering);
420 debug_struct.field("expiration_policy", &self.expiration_policy);
421 debug_struct.field("filter", &self.filter);
422 debug_struct.field("dead_letter_policy", &self.dead_letter_policy);
423 debug_struct.field("retry_policy", &self.retry_policy);
424 debug_struct.field("detached", &self.detached);
425 debug_struct.field(
426 "enable_exactly_once_delivery",
427 &self.enable_exactly_once_delivery,
428 );
429 debug_struct.field(
430 "topic_message_retention_duration",
431 &self.topic_message_retention_duration,
432 );
433 debug_struct.field("state", &self.state);
434 debug_struct.field(
435 "analytics_hub_subscription_info",
436 &self.analytics_hub_subscription_info,
437 );
438 debug_struct.field("message_transforms", &self.message_transforms);
439 debug_struct.field("tags", &self.tags);
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::subscription::AnalyticsHubSubscriptionInfo {
448 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
449 let mut debug_struct = f.debug_struct("AnalyticsHubSubscriptionInfo");
450 debug_struct.field("listing", &self.listing);
451 debug_struct.field("subscription", &self.subscription);
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::RetryPolicy {
460 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
461 let mut debug_struct = f.debug_struct("RetryPolicy");
462 debug_struct.field("minimum_backoff", &self.minimum_backoff);
463 debug_struct.field("maximum_backoff", &self.maximum_backoff);
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::DeadLetterPolicy {
472 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
473 let mut debug_struct = f.debug_struct("DeadLetterPolicy");
474 debug_struct.field("dead_letter_topic", &self.dead_letter_topic);
475 debug_struct.field("max_delivery_attempts", &self.max_delivery_attempts);
476 if !self._unknown_fields.is_empty() {
477 debug_struct.field("_unknown_fields", &self._unknown_fields);
478 }
479 debug_struct.finish()
480 }
481}
482
483impl std::fmt::Debug for super::ExpirationPolicy {
484 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
485 let mut debug_struct = f.debug_struct("ExpirationPolicy");
486 debug_struct.field("ttl", &self.ttl);
487 if !self._unknown_fields.is_empty() {
488 debug_struct.field("_unknown_fields", &self._unknown_fields);
489 }
490 debug_struct.finish()
491 }
492}
493
494impl std::fmt::Debug for super::PushConfig {
495 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
496 let mut debug_struct = f.debug_struct("PushConfig");
497 debug_struct.field("push_endpoint", &self.push_endpoint);
498 debug_struct.field("attributes", &self.attributes);
499 debug_struct.field("authentication_method", &self.authentication_method);
500 debug_struct.field("wrapper", &self.wrapper);
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::OidcToken {
509 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
510 let mut debug_struct = f.debug_struct("OidcToken");
511 debug_struct.field("service_account_email", &self.service_account_email);
512 debug_struct.field("audience", &self.audience);
513 if !self._unknown_fields.is_empty() {
514 debug_struct.field("_unknown_fields", &self._unknown_fields);
515 }
516 debug_struct.finish()
517 }
518}
519
520impl std::fmt::Debug for super::push_config::PubsubWrapper {
521 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
522 let mut debug_struct = f.debug_struct("PubsubWrapper");
523 if !self._unknown_fields.is_empty() {
524 debug_struct.field("_unknown_fields", &self._unknown_fields);
525 }
526 debug_struct.finish()
527 }
528}
529
530impl std::fmt::Debug for super::push_config::NoWrapper {
531 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
532 let mut debug_struct = f.debug_struct("NoWrapper");
533 debug_struct.field("write_metadata", &self.write_metadata);
534 if !self._unknown_fields.is_empty() {
535 debug_struct.field("_unknown_fields", &self._unknown_fields);
536 }
537 debug_struct.finish()
538 }
539}
540
541impl std::fmt::Debug for super::BigQueryConfig {
542 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
543 let mut debug_struct = f.debug_struct("BigQueryConfig");
544 debug_struct.field("table", &self.table);
545 debug_struct.field("use_topic_schema", &self.use_topic_schema);
546 debug_struct.field("write_metadata", &self.write_metadata);
547 debug_struct.field("drop_unknown_fields", &self.drop_unknown_fields);
548 debug_struct.field("state", &self.state);
549 debug_struct.field("use_table_schema", &self.use_table_schema);
550 debug_struct.field("service_account_email", &self.service_account_email);
551 if !self._unknown_fields.is_empty() {
552 debug_struct.field("_unknown_fields", &self._unknown_fields);
553 }
554 debug_struct.finish()
555 }
556}
557
558impl std::fmt::Debug for super::BigtableConfig {
559 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
560 let mut debug_struct = f.debug_struct("BigtableConfig");
561 debug_struct.field("table", &self.table);
562 debug_struct.field("app_profile_id", &self.app_profile_id);
563 debug_struct.field("service_account_email", &self.service_account_email);
564 debug_struct.field("write_metadata", &self.write_metadata);
565 debug_struct.field("state", &self.state);
566 if !self._unknown_fields.is_empty() {
567 debug_struct.field("_unknown_fields", &self._unknown_fields);
568 }
569 debug_struct.finish()
570 }
571}
572
573impl std::fmt::Debug for super::CloudStorageConfig {
574 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
575 let mut debug_struct = f.debug_struct("CloudStorageConfig");
576 debug_struct.field("bucket", &self.bucket);
577 debug_struct.field("filename_prefix", &self.filename_prefix);
578 debug_struct.field("filename_suffix", &self.filename_suffix);
579 debug_struct.field("filename_datetime_format", &self.filename_datetime_format);
580 debug_struct.field("max_duration", &self.max_duration);
581 debug_struct.field("max_bytes", &self.max_bytes);
582 debug_struct.field("max_messages", &self.max_messages);
583 debug_struct.field("state", &self.state);
584 debug_struct.field("service_account_email", &self.service_account_email);
585 debug_struct.field("output_format", &self.output_format);
586 if !self._unknown_fields.is_empty() {
587 debug_struct.field("_unknown_fields", &self._unknown_fields);
588 }
589 debug_struct.finish()
590 }
591}
592
593impl std::fmt::Debug for super::cloud_storage_config::TextConfig {
594 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
595 let mut debug_struct = f.debug_struct("TextConfig");
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::cloud_storage_config::AvroConfig {
604 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
605 let mut debug_struct = f.debug_struct("AvroConfig");
606 debug_struct.field("write_metadata", &self.write_metadata);
607 debug_struct.field("use_topic_schema", &self.use_topic_schema);
608 if !self._unknown_fields.is_empty() {
609 debug_struct.field("_unknown_fields", &self._unknown_fields);
610 }
611 debug_struct.finish()
612 }
613}
614
615impl std::fmt::Debug for super::GetSubscriptionRequest {
616 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
617 let mut debug_struct = f.debug_struct("GetSubscriptionRequest");
618 debug_struct.field("subscription", &self.subscription);
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::UpdateSubscriptionRequest {
627 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
628 let mut debug_struct = f.debug_struct("UpdateSubscriptionRequest");
629 debug_struct.field("subscription", &self.subscription);
630 debug_struct.field("update_mask", &self.update_mask);
631 if !self._unknown_fields.is_empty() {
632 debug_struct.field("_unknown_fields", &self._unknown_fields);
633 }
634 debug_struct.finish()
635 }
636}
637
638impl std::fmt::Debug for super::ListSubscriptionsRequest {
639 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
640 let mut debug_struct = f.debug_struct("ListSubscriptionsRequest");
641 debug_struct.field("project", &self.project);
642 debug_struct.field("page_size", &self.page_size);
643 debug_struct.field("page_token", &self.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::ListSubscriptionsResponse {
652 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
653 let mut debug_struct = f.debug_struct("ListSubscriptionsResponse");
654 debug_struct.field("subscriptions", &self.subscriptions);
655 debug_struct.field("next_page_token", &self.next_page_token);
656 if !self._unknown_fields.is_empty() {
657 debug_struct.field("_unknown_fields", &self._unknown_fields);
658 }
659 debug_struct.finish()
660 }
661}
662
663impl std::fmt::Debug for super::DeleteSubscriptionRequest {
664 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
665 let mut debug_struct = f.debug_struct("DeleteSubscriptionRequest");
666 debug_struct.field("subscription", &self.subscription);
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::ModifyPushConfigRequest {
675 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
676 let mut debug_struct = f.debug_struct("ModifyPushConfigRequest");
677 debug_struct.field("subscription", &self.subscription);
678 debug_struct.field("push_config", &self.push_config);
679 if !self._unknown_fields.is_empty() {
680 debug_struct.field("_unknown_fields", &self._unknown_fields);
681 }
682 debug_struct.finish()
683 }
684}
685
686impl std::fmt::Debug for super::CreateSnapshotRequest {
687 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
688 let mut debug_struct = f.debug_struct("CreateSnapshotRequest");
689 debug_struct.field("name", &self.name);
690 debug_struct.field("subscription", &self.subscription);
691 debug_struct.field("labels", &self.labels);
692 debug_struct.field("tags", &self.tags);
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::UpdateSnapshotRequest {
701 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
702 let mut debug_struct = f.debug_struct("UpdateSnapshotRequest");
703 debug_struct.field("snapshot", &self.snapshot);
704 debug_struct.field("update_mask", &self.update_mask);
705 if !self._unknown_fields.is_empty() {
706 debug_struct.field("_unknown_fields", &self._unknown_fields);
707 }
708 debug_struct.finish()
709 }
710}
711
712impl std::fmt::Debug for super::Snapshot {
713 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
714 let mut debug_struct = f.debug_struct("Snapshot");
715 debug_struct.field("name", &self.name);
716 debug_struct.field("topic", &self.topic);
717 debug_struct.field("expire_time", &self.expire_time);
718 debug_struct.field("labels", &self.labels);
719 if !self._unknown_fields.is_empty() {
720 debug_struct.field("_unknown_fields", &self._unknown_fields);
721 }
722 debug_struct.finish()
723 }
724}
725
726impl std::fmt::Debug for super::GetSnapshotRequest {
727 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
728 let mut debug_struct = f.debug_struct("GetSnapshotRequest");
729 debug_struct.field("snapshot", &self.snapshot);
730 if !self._unknown_fields.is_empty() {
731 debug_struct.field("_unknown_fields", &self._unknown_fields);
732 }
733 debug_struct.finish()
734 }
735}
736
737impl std::fmt::Debug for super::ListSnapshotsRequest {
738 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
739 let mut debug_struct = f.debug_struct("ListSnapshotsRequest");
740 debug_struct.field("project", &self.project);
741 debug_struct.field("page_size", &self.page_size);
742 debug_struct.field("page_token", &self.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::ListSnapshotsResponse {
751 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
752 let mut debug_struct = f.debug_struct("ListSnapshotsResponse");
753 debug_struct.field("snapshots", &self.snapshots);
754 debug_struct.field("next_page_token", &self.next_page_token);
755 if !self._unknown_fields.is_empty() {
756 debug_struct.field("_unknown_fields", &self._unknown_fields);
757 }
758 debug_struct.finish()
759 }
760}
761
762impl std::fmt::Debug for super::DeleteSnapshotRequest {
763 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
764 let mut debug_struct = f.debug_struct("DeleteSnapshotRequest");
765 debug_struct.field("snapshot", &self.snapshot);
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::SeekRequest {
774 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
775 let mut debug_struct = f.debug_struct("SeekRequest");
776 debug_struct.field("subscription", &self.subscription);
777 debug_struct.field("target", &self.target);
778 if !self._unknown_fields.is_empty() {
779 debug_struct.field("_unknown_fields", &self._unknown_fields);
780 }
781 debug_struct.finish()
782 }
783}
784
785impl std::fmt::Debug for super::SeekResponse {
786 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
787 let mut debug_struct = f.debug_struct("SeekResponse");
788 if !self._unknown_fields.is_empty() {
789 debug_struct.field("_unknown_fields", &self._unknown_fields);
790 }
791 debug_struct.finish()
792 }
793}
794
795impl std::fmt::Debug for super::Schema {
796 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
797 let mut debug_struct = f.debug_struct("Schema");
798 debug_struct.field("name", &self.name);
799 debug_struct.field("r#type", &self.r#type);
800 debug_struct.field("definition", &self.definition);
801 debug_struct.field("revision_id", &self.revision_id);
802 debug_struct.field("revision_create_time", &self.revision_create_time);
803 debug_struct.field("configuration", &self.configuration);
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::CreateSchemaRequest {
812 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
813 let mut debug_struct = f.debug_struct("CreateSchemaRequest");
814 debug_struct.field("parent", &self.parent);
815 debug_struct.field("schema", &self.schema);
816 debug_struct.field("schema_id", &self.schema_id);
817 if !self._unknown_fields.is_empty() {
818 debug_struct.field("_unknown_fields", &self._unknown_fields);
819 }
820 debug_struct.finish()
821 }
822}
823
824impl std::fmt::Debug for super::GetSchemaRequest {
825 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
826 let mut debug_struct = f.debug_struct("GetSchemaRequest");
827 debug_struct.field("name", &self.name);
828 debug_struct.field("view", &self.view);
829 if !self._unknown_fields.is_empty() {
830 debug_struct.field("_unknown_fields", &self._unknown_fields);
831 }
832 debug_struct.finish()
833 }
834}
835
836impl std::fmt::Debug for super::ListSchemasRequest {
837 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
838 let mut debug_struct = f.debug_struct("ListSchemasRequest");
839 debug_struct.field("parent", &self.parent);
840 debug_struct.field("view", &self.view);
841 debug_struct.field("page_size", &self.page_size);
842 debug_struct.field("page_token", &self.page_token);
843 if !self._unknown_fields.is_empty() {
844 debug_struct.field("_unknown_fields", &self._unknown_fields);
845 }
846 debug_struct.finish()
847 }
848}
849
850impl std::fmt::Debug for super::ListSchemasResponse {
851 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
852 let mut debug_struct = f.debug_struct("ListSchemasResponse");
853 debug_struct.field("schemas", &self.schemas);
854 debug_struct.field("next_page_token", &self.next_page_token);
855 if !self._unknown_fields.is_empty() {
856 debug_struct.field("_unknown_fields", &self._unknown_fields);
857 }
858 debug_struct.finish()
859 }
860}
861
862impl std::fmt::Debug for super::ListSchemaRevisionsRequest {
863 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
864 let mut debug_struct = f.debug_struct("ListSchemaRevisionsRequest");
865 debug_struct.field("name", &self.name);
866 debug_struct.field("view", &self.view);
867 debug_struct.field("page_size", &self.page_size);
868 debug_struct.field("page_token", &self.page_token);
869 if !self._unknown_fields.is_empty() {
870 debug_struct.field("_unknown_fields", &self._unknown_fields);
871 }
872 debug_struct.finish()
873 }
874}
875
876impl std::fmt::Debug for super::ListSchemaRevisionsResponse {
877 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
878 let mut debug_struct = f.debug_struct("ListSchemaRevisionsResponse");
879 debug_struct.field("schemas", &self.schemas);
880 debug_struct.field("next_page_token", &self.next_page_token);
881 if !self._unknown_fields.is_empty() {
882 debug_struct.field("_unknown_fields", &self._unknown_fields);
883 }
884 debug_struct.finish()
885 }
886}
887
888impl std::fmt::Debug for super::CommitSchemaRequest {
889 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
890 let mut debug_struct = f.debug_struct("CommitSchemaRequest");
891 debug_struct.field("name", &self.name);
892 debug_struct.field("schema", &self.schema);
893 if !self._unknown_fields.is_empty() {
894 debug_struct.field("_unknown_fields", &self._unknown_fields);
895 }
896 debug_struct.finish()
897 }
898}
899
900impl std::fmt::Debug for super::RollbackSchemaRequest {
901 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
902 let mut debug_struct = f.debug_struct("RollbackSchemaRequest");
903 debug_struct.field("name", &self.name);
904 debug_struct.field("revision_id", &self.revision_id);
905 if !self._unknown_fields.is_empty() {
906 debug_struct.field("_unknown_fields", &self._unknown_fields);
907 }
908 debug_struct.finish()
909 }
910}
911
912impl std::fmt::Debug for super::DeleteSchemaRevisionRequest {
913 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
914 let mut debug_struct = f.debug_struct("DeleteSchemaRevisionRequest");
915 debug_struct.field("name", &self.name);
916 debug_struct.field("revision_id", &self.revision_id);
917 if !self._unknown_fields.is_empty() {
918 debug_struct.field("_unknown_fields", &self._unknown_fields);
919 }
920 debug_struct.finish()
921 }
922}
923
924impl std::fmt::Debug for super::DeleteSchemaRequest {
925 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
926 let mut debug_struct = f.debug_struct("DeleteSchemaRequest");
927 debug_struct.field("name", &self.name);
928 if !self._unknown_fields.is_empty() {
929 debug_struct.field("_unknown_fields", &self._unknown_fields);
930 }
931 debug_struct.finish()
932 }
933}
934
935impl std::fmt::Debug for super::ValidateSchemaRequest {
936 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
937 let mut debug_struct = f.debug_struct("ValidateSchemaRequest");
938 debug_struct.field("parent", &self.parent);
939 debug_struct.field("schema", &self.schema);
940 if !self._unknown_fields.is_empty() {
941 debug_struct.field("_unknown_fields", &self._unknown_fields);
942 }
943 debug_struct.finish()
944 }
945}
946
947impl std::fmt::Debug for super::ValidateSchemaResponse {
948 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
949 let mut debug_struct = f.debug_struct("ValidateSchemaResponse");
950 if !self._unknown_fields.is_empty() {
951 debug_struct.field("_unknown_fields", &self._unknown_fields);
952 }
953 debug_struct.finish()
954 }
955}
956
957impl std::fmt::Debug for super::ValidateMessageRequest {
958 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
959 let mut debug_struct = f.debug_struct("ValidateMessageRequest");
960 debug_struct.field("parent", &self.parent);
961 debug_struct.field("message", &self.message);
962 debug_struct.field("encoding", &self.encoding);
963 debug_struct.field("schema_spec", &self.schema_spec);
964 if !self._unknown_fields.is_empty() {
965 debug_struct.field("_unknown_fields", &self._unknown_fields);
966 }
967 debug_struct.finish()
968 }
969}
970
971impl std::fmt::Debug for super::ValidateMessageResponse {
972 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
973 let mut debug_struct = f.debug_struct("ValidateMessageResponse");
974 if !self._unknown_fields.is_empty() {
975 debug_struct.field("_unknown_fields", &self._unknown_fields);
976 }
977 debug_struct.finish()
978 }
979}
980
981impl std::fmt::Debug for super::CompiledProtoSchema {
982 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
983 let mut debug_struct = f.debug_struct("CompiledProtoSchema");
984 debug_struct.field("root_message", &self.root_message);
985 debug_struct.field("compiled_bytes", &self.compiled_bytes);
986 if !self._unknown_fields.is_empty() {
987 debug_struct.field("_unknown_fields", &self._unknown_fields);
988 }
989 debug_struct.finish()
990 }
991}