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 debug_struct.field("message_mapping", &self.message_mapping);
567 if !self._unknown_fields.is_empty() {
568 debug_struct.field("_unknown_fields", &self._unknown_fields);
569 }
570 debug_struct.finish()
571 }
572}
573
574impl std::fmt::Debug for super::bigtable_config::ColumnFamilyMapping {
575 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
576 let mut debug_struct = f.debug_struct("ColumnFamilyMapping");
577 debug_struct.field("key_definition", &self.key_definition);
578 if !self._unknown_fields.is_empty() {
579 debug_struct.field("_unknown_fields", &self._unknown_fields);
580 }
581 debug_struct.finish()
582 }
583}
584
585impl std::fmt::Debug for super::bigtable_config::column_family_mapping::RowKeySchema {
586 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
587 let mut debug_struct = f.debug_struct("RowKeySchema");
588 if !self._unknown_fields.is_empty() {
589 debug_struct.field("_unknown_fields", &self._unknown_fields);
590 }
591 debug_struct.finish()
592 }
593}
594
595impl std::fmt::Debug for super::bigtable_config::column_family_mapping::DelimitedKey {
596 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
597 let mut debug_struct = f.debug_struct("DelimitedKey");
598 debug_struct.field("key_fields", &self.key_fields);
599 debug_struct.field("delimiter", &self.delimiter);
600 if !self._unknown_fields.is_empty() {
601 debug_struct.field("_unknown_fields", &self._unknown_fields);
602 }
603 debug_struct.finish()
604 }
605}
606
607impl std::fmt::Debug for super::CloudStorageConfig {
608 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
609 let mut debug_struct = f.debug_struct("CloudStorageConfig");
610 debug_struct.field("bucket", &self.bucket);
611 debug_struct.field("filename_prefix", &self.filename_prefix);
612 debug_struct.field("filename_suffix", &self.filename_suffix);
613 debug_struct.field("filename_datetime_format", &self.filename_datetime_format);
614 debug_struct.field("max_duration", &self.max_duration);
615 debug_struct.field("max_bytes", &self.max_bytes);
616 debug_struct.field("max_messages", &self.max_messages);
617 debug_struct.field("state", &self.state);
618 debug_struct.field("service_account_email", &self.service_account_email);
619 debug_struct.field("output_format", &self.output_format);
620 if !self._unknown_fields.is_empty() {
621 debug_struct.field("_unknown_fields", &self._unknown_fields);
622 }
623 debug_struct.finish()
624 }
625}
626
627impl std::fmt::Debug for super::cloud_storage_config::TextConfig {
628 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
629 let mut debug_struct = f.debug_struct("TextConfig");
630 if !self._unknown_fields.is_empty() {
631 debug_struct.field("_unknown_fields", &self._unknown_fields);
632 }
633 debug_struct.finish()
634 }
635}
636
637impl std::fmt::Debug for super::cloud_storage_config::AvroConfig {
638 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
639 let mut debug_struct = f.debug_struct("AvroConfig");
640 debug_struct.field("write_metadata", &self.write_metadata);
641 debug_struct.field("use_topic_schema", &self.use_topic_schema);
642 if !self._unknown_fields.is_empty() {
643 debug_struct.field("_unknown_fields", &self._unknown_fields);
644 }
645 debug_struct.finish()
646 }
647}
648
649impl std::fmt::Debug for super::GetSubscriptionRequest {
650 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
651 let mut debug_struct = f.debug_struct("GetSubscriptionRequest");
652 debug_struct.field("subscription", &self.subscription);
653 if !self._unknown_fields.is_empty() {
654 debug_struct.field("_unknown_fields", &self._unknown_fields);
655 }
656 debug_struct.finish()
657 }
658}
659
660impl std::fmt::Debug for super::UpdateSubscriptionRequest {
661 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
662 let mut debug_struct = f.debug_struct("UpdateSubscriptionRequest");
663 debug_struct.field("subscription", &self.subscription);
664 debug_struct.field("update_mask", &self.update_mask);
665 if !self._unknown_fields.is_empty() {
666 debug_struct.field("_unknown_fields", &self._unknown_fields);
667 }
668 debug_struct.finish()
669 }
670}
671
672impl std::fmt::Debug for super::ListSubscriptionsRequest {
673 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
674 let mut debug_struct = f.debug_struct("ListSubscriptionsRequest");
675 debug_struct.field("project", &self.project);
676 debug_struct.field("page_size", &self.page_size);
677 debug_struct.field("page_token", &self.page_token);
678 if !self._unknown_fields.is_empty() {
679 debug_struct.field("_unknown_fields", &self._unknown_fields);
680 }
681 debug_struct.finish()
682 }
683}
684
685impl std::fmt::Debug for super::ListSubscriptionsResponse {
686 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
687 let mut debug_struct = f.debug_struct("ListSubscriptionsResponse");
688 debug_struct.field("subscriptions", &self.subscriptions);
689 debug_struct.field("next_page_token", &self.next_page_token);
690 if !self._unknown_fields.is_empty() {
691 debug_struct.field("_unknown_fields", &self._unknown_fields);
692 }
693 debug_struct.finish()
694 }
695}
696
697impl std::fmt::Debug for super::DeleteSubscriptionRequest {
698 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
699 let mut debug_struct = f.debug_struct("DeleteSubscriptionRequest");
700 debug_struct.field("subscription", &self.subscription);
701 if !self._unknown_fields.is_empty() {
702 debug_struct.field("_unknown_fields", &self._unknown_fields);
703 }
704 debug_struct.finish()
705 }
706}
707
708impl std::fmt::Debug for super::ModifyPushConfigRequest {
709 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
710 let mut debug_struct = f.debug_struct("ModifyPushConfigRequest");
711 debug_struct.field("subscription", &self.subscription);
712 debug_struct.field("push_config", &self.push_config);
713 if !self._unknown_fields.is_empty() {
714 debug_struct.field("_unknown_fields", &self._unknown_fields);
715 }
716 debug_struct.finish()
717 }
718}
719
720impl std::fmt::Debug for super::CreateSnapshotRequest {
721 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
722 let mut debug_struct = f.debug_struct("CreateSnapshotRequest");
723 debug_struct.field("name", &self.name);
724 debug_struct.field("subscription", &self.subscription);
725 debug_struct.field("labels", &self.labels);
726 debug_struct.field("tags", &self.tags);
727 if !self._unknown_fields.is_empty() {
728 debug_struct.field("_unknown_fields", &self._unknown_fields);
729 }
730 debug_struct.finish()
731 }
732}
733
734impl std::fmt::Debug for super::UpdateSnapshotRequest {
735 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
736 let mut debug_struct = f.debug_struct("UpdateSnapshotRequest");
737 debug_struct.field("snapshot", &self.snapshot);
738 debug_struct.field("update_mask", &self.update_mask);
739 if !self._unknown_fields.is_empty() {
740 debug_struct.field("_unknown_fields", &self._unknown_fields);
741 }
742 debug_struct.finish()
743 }
744}
745
746impl std::fmt::Debug for super::Snapshot {
747 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
748 let mut debug_struct = f.debug_struct("Snapshot");
749 debug_struct.field("name", &self.name);
750 debug_struct.field("topic", &self.topic);
751 debug_struct.field("expire_time", &self.expire_time);
752 debug_struct.field("labels", &self.labels);
753 if !self._unknown_fields.is_empty() {
754 debug_struct.field("_unknown_fields", &self._unknown_fields);
755 }
756 debug_struct.finish()
757 }
758}
759
760impl std::fmt::Debug for super::GetSnapshotRequest {
761 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
762 let mut debug_struct = f.debug_struct("GetSnapshotRequest");
763 debug_struct.field("snapshot", &self.snapshot);
764 if !self._unknown_fields.is_empty() {
765 debug_struct.field("_unknown_fields", &self._unknown_fields);
766 }
767 debug_struct.finish()
768 }
769}
770
771impl std::fmt::Debug for super::ListSnapshotsRequest {
772 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
773 let mut debug_struct = f.debug_struct("ListSnapshotsRequest");
774 debug_struct.field("project", &self.project);
775 debug_struct.field("page_size", &self.page_size);
776 debug_struct.field("page_token", &self.page_token);
777 if !self._unknown_fields.is_empty() {
778 debug_struct.field("_unknown_fields", &self._unknown_fields);
779 }
780 debug_struct.finish()
781 }
782}
783
784impl std::fmt::Debug for super::ListSnapshotsResponse {
785 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
786 let mut debug_struct = f.debug_struct("ListSnapshotsResponse");
787 debug_struct.field("snapshots", &self.snapshots);
788 debug_struct.field("next_page_token", &self.next_page_token);
789 if !self._unknown_fields.is_empty() {
790 debug_struct.field("_unknown_fields", &self._unknown_fields);
791 }
792 debug_struct.finish()
793 }
794}
795
796impl std::fmt::Debug for super::DeleteSnapshotRequest {
797 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
798 let mut debug_struct = f.debug_struct("DeleteSnapshotRequest");
799 debug_struct.field("snapshot", &self.snapshot);
800 if !self._unknown_fields.is_empty() {
801 debug_struct.field("_unknown_fields", &self._unknown_fields);
802 }
803 debug_struct.finish()
804 }
805}
806
807impl std::fmt::Debug for super::SeekRequest {
808 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
809 let mut debug_struct = f.debug_struct("SeekRequest");
810 debug_struct.field("subscription", &self.subscription);
811 debug_struct.field("target", &self.target);
812 if !self._unknown_fields.is_empty() {
813 debug_struct.field("_unknown_fields", &self._unknown_fields);
814 }
815 debug_struct.finish()
816 }
817}
818
819impl std::fmt::Debug for super::SeekResponse {
820 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
821 let mut debug_struct = f.debug_struct("SeekResponse");
822 if !self._unknown_fields.is_empty() {
823 debug_struct.field("_unknown_fields", &self._unknown_fields);
824 }
825 debug_struct.finish()
826 }
827}
828
829impl std::fmt::Debug for super::Schema {
830 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
831 let mut debug_struct = f.debug_struct("Schema");
832 debug_struct.field("name", &self.name);
833 debug_struct.field("r#type", &self.r#type);
834 debug_struct.field("definition", &self.definition);
835 debug_struct.field("revision_id", &self.revision_id);
836 debug_struct.field("revision_create_time", &self.revision_create_time);
837 debug_struct.field("configuration", &self.configuration);
838 if !self._unknown_fields.is_empty() {
839 debug_struct.field("_unknown_fields", &self._unknown_fields);
840 }
841 debug_struct.finish()
842 }
843}
844
845impl std::fmt::Debug for super::CreateSchemaRequest {
846 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
847 let mut debug_struct = f.debug_struct("CreateSchemaRequest");
848 debug_struct.field("parent", &self.parent);
849 debug_struct.field("schema", &self.schema);
850 debug_struct.field("schema_id", &self.schema_id);
851 if !self._unknown_fields.is_empty() {
852 debug_struct.field("_unknown_fields", &self._unknown_fields);
853 }
854 debug_struct.finish()
855 }
856}
857
858impl std::fmt::Debug for super::GetSchemaRequest {
859 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
860 let mut debug_struct = f.debug_struct("GetSchemaRequest");
861 debug_struct.field("name", &self.name);
862 debug_struct.field("view", &self.view);
863 if !self._unknown_fields.is_empty() {
864 debug_struct.field("_unknown_fields", &self._unknown_fields);
865 }
866 debug_struct.finish()
867 }
868}
869
870impl std::fmt::Debug for super::ListSchemasRequest {
871 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
872 let mut debug_struct = f.debug_struct("ListSchemasRequest");
873 debug_struct.field("parent", &self.parent);
874 debug_struct.field("view", &self.view);
875 debug_struct.field("page_size", &self.page_size);
876 debug_struct.field("page_token", &self.page_token);
877 if !self._unknown_fields.is_empty() {
878 debug_struct.field("_unknown_fields", &self._unknown_fields);
879 }
880 debug_struct.finish()
881 }
882}
883
884impl std::fmt::Debug for super::ListSchemasResponse {
885 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
886 let mut debug_struct = f.debug_struct("ListSchemasResponse");
887 debug_struct.field("schemas", &self.schemas);
888 debug_struct.field("next_page_token", &self.next_page_token);
889 if !self._unknown_fields.is_empty() {
890 debug_struct.field("_unknown_fields", &self._unknown_fields);
891 }
892 debug_struct.finish()
893 }
894}
895
896impl std::fmt::Debug for super::ListSchemaRevisionsRequest {
897 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
898 let mut debug_struct = f.debug_struct("ListSchemaRevisionsRequest");
899 debug_struct.field("name", &self.name);
900 debug_struct.field("view", &self.view);
901 debug_struct.field("page_size", &self.page_size);
902 debug_struct.field("page_token", &self.page_token);
903 if !self._unknown_fields.is_empty() {
904 debug_struct.field("_unknown_fields", &self._unknown_fields);
905 }
906 debug_struct.finish()
907 }
908}
909
910impl std::fmt::Debug for super::ListSchemaRevisionsResponse {
911 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
912 let mut debug_struct = f.debug_struct("ListSchemaRevisionsResponse");
913 debug_struct.field("schemas", &self.schemas);
914 debug_struct.field("next_page_token", &self.next_page_token);
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::CommitSchemaRequest {
923 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
924 let mut debug_struct = f.debug_struct("CommitSchemaRequest");
925 debug_struct.field("name", &self.name);
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::RollbackSchemaRequest {
935 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
936 let mut debug_struct = f.debug_struct("RollbackSchemaRequest");
937 debug_struct.field("name", &self.name);
938 debug_struct.field("revision_id", &self.revision_id);
939 if !self._unknown_fields.is_empty() {
940 debug_struct.field("_unknown_fields", &self._unknown_fields);
941 }
942 debug_struct.finish()
943 }
944}
945
946impl std::fmt::Debug for super::DeleteSchemaRevisionRequest {
947 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
948 let mut debug_struct = f.debug_struct("DeleteSchemaRevisionRequest");
949 debug_struct.field("name", &self.name);
950 debug_struct.field("revision_id", &self.revision_id);
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::DeleteSchemaRequest {
959 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
960 let mut debug_struct = f.debug_struct("DeleteSchemaRequest");
961 debug_struct.field("name", &self.name);
962 if !self._unknown_fields.is_empty() {
963 debug_struct.field("_unknown_fields", &self._unknown_fields);
964 }
965 debug_struct.finish()
966 }
967}
968
969impl std::fmt::Debug for super::ValidateSchemaRequest {
970 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
971 let mut debug_struct = f.debug_struct("ValidateSchemaRequest");
972 debug_struct.field("parent", &self.parent);
973 debug_struct.field("schema", &self.schema);
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::ValidateSchemaResponse {
982 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
983 let mut debug_struct = f.debug_struct("ValidateSchemaResponse");
984 if !self._unknown_fields.is_empty() {
985 debug_struct.field("_unknown_fields", &self._unknown_fields);
986 }
987 debug_struct.finish()
988 }
989}
990
991impl std::fmt::Debug for super::ValidateMessageRequest {
992 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
993 let mut debug_struct = f.debug_struct("ValidateMessageRequest");
994 debug_struct.field("parent", &self.parent);
995 debug_struct.field("message", &self.message);
996 debug_struct.field("encoding", &self.encoding);
997 debug_struct.field("schema_spec", &self.schema_spec);
998 if !self._unknown_fields.is_empty() {
999 debug_struct.field("_unknown_fields", &self._unknown_fields);
1000 }
1001 debug_struct.finish()
1002 }
1003}
1004
1005impl std::fmt::Debug for super::ValidateMessageResponse {
1006 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
1007 let mut debug_struct = f.debug_struct("ValidateMessageResponse");
1008 if !self._unknown_fields.is_empty() {
1009 debug_struct.field("_unknown_fields", &self._unknown_fields);
1010 }
1011 debug_struct.finish()
1012 }
1013}
1014
1015impl std::fmt::Debug for super::CompiledProtoSchema {
1016 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
1017 let mut debug_struct = f.debug_struct("CompiledProtoSchema");
1018 debug_struct.field("root_message", &self.root_message);
1019 debug_struct.field("compiled_bytes", &self.compiled_bytes);
1020 if !self._unknown_fields.is_empty() {
1021 debug_struct.field("_unknown_fields", &self._unknown_fields);
1022 }
1023 debug_struct.finish()
1024 }
1025}