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("ack_deadline_seconds", &self.ack_deadline_seconds);
400 debug_struct.field("retain_acked_messages", &self.retain_acked_messages);
401 debug_struct.field(
402 "message_retention_duration",
403 &self.message_retention_duration,
404 );
405 debug_struct.field("labels", &self.labels);
406 debug_struct.field("enable_message_ordering", &self.enable_message_ordering);
407 debug_struct.field("expiration_policy", &self.expiration_policy);
408 debug_struct.field("filter", &self.filter);
409 debug_struct.field("dead_letter_policy", &self.dead_letter_policy);
410 debug_struct.field("retry_policy", &self.retry_policy);
411 debug_struct.field("detached", &self.detached);
412 debug_struct.field(
413 "enable_exactly_once_delivery",
414 &self.enable_exactly_once_delivery,
415 );
416 debug_struct.field(
417 "topic_message_retention_duration",
418 &self.topic_message_retention_duration,
419 );
420 debug_struct.field("state", &self.state);
421 debug_struct.field(
422 "analytics_hub_subscription_info",
423 &self.analytics_hub_subscription_info,
424 );
425 debug_struct.field("message_transforms", &self.message_transforms);
426 debug_struct.field("tags", &self.tags);
427 if !self._unknown_fields.is_empty() {
428 debug_struct.field("_unknown_fields", &self._unknown_fields);
429 }
430 debug_struct.finish()
431 }
432}
433
434impl std::fmt::Debug for super::subscription::AnalyticsHubSubscriptionInfo {
435 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
436 let mut debug_struct = f.debug_struct("AnalyticsHubSubscriptionInfo");
437 debug_struct.field("listing", &self.listing);
438 debug_struct.field("subscription", &self.subscription);
439 if !self._unknown_fields.is_empty() {
440 debug_struct.field("_unknown_fields", &self._unknown_fields);
441 }
442 debug_struct.finish()
443 }
444}
445
446impl std::fmt::Debug for super::RetryPolicy {
447 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
448 let mut debug_struct = f.debug_struct("RetryPolicy");
449 debug_struct.field("minimum_backoff", &self.minimum_backoff);
450 debug_struct.field("maximum_backoff", &self.maximum_backoff);
451 if !self._unknown_fields.is_empty() {
452 debug_struct.field("_unknown_fields", &self._unknown_fields);
453 }
454 debug_struct.finish()
455 }
456}
457
458impl std::fmt::Debug for super::DeadLetterPolicy {
459 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
460 let mut debug_struct = f.debug_struct("DeadLetterPolicy");
461 debug_struct.field("dead_letter_topic", &self.dead_letter_topic);
462 debug_struct.field("max_delivery_attempts", &self.max_delivery_attempts);
463 if !self._unknown_fields.is_empty() {
464 debug_struct.field("_unknown_fields", &self._unknown_fields);
465 }
466 debug_struct.finish()
467 }
468}
469
470impl std::fmt::Debug for super::ExpirationPolicy {
471 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
472 let mut debug_struct = f.debug_struct("ExpirationPolicy");
473 debug_struct.field("ttl", &self.ttl);
474 if !self._unknown_fields.is_empty() {
475 debug_struct.field("_unknown_fields", &self._unknown_fields);
476 }
477 debug_struct.finish()
478 }
479}
480
481impl std::fmt::Debug for super::PushConfig {
482 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
483 let mut debug_struct = f.debug_struct("PushConfig");
484 debug_struct.field("push_endpoint", &self.push_endpoint);
485 debug_struct.field("attributes", &self.attributes);
486 debug_struct.field("authentication_method", &self.authentication_method);
487 debug_struct.field("wrapper", &self.wrapper);
488 if !self._unknown_fields.is_empty() {
489 debug_struct.field("_unknown_fields", &self._unknown_fields);
490 }
491 debug_struct.finish()
492 }
493}
494
495impl std::fmt::Debug for super::push_config::OidcToken {
496 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
497 let mut debug_struct = f.debug_struct("OidcToken");
498 debug_struct.field("service_account_email", &self.service_account_email);
499 debug_struct.field("audience", &self.audience);
500 if !self._unknown_fields.is_empty() {
501 debug_struct.field("_unknown_fields", &self._unknown_fields);
502 }
503 debug_struct.finish()
504 }
505}
506
507impl std::fmt::Debug for super::push_config::PubsubWrapper {
508 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
509 let mut debug_struct = f.debug_struct("PubsubWrapper");
510 if !self._unknown_fields.is_empty() {
511 debug_struct.field("_unknown_fields", &self._unknown_fields);
512 }
513 debug_struct.finish()
514 }
515}
516
517impl std::fmt::Debug for super::push_config::NoWrapper {
518 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
519 let mut debug_struct = f.debug_struct("NoWrapper");
520 debug_struct.field("write_metadata", &self.write_metadata);
521 if !self._unknown_fields.is_empty() {
522 debug_struct.field("_unknown_fields", &self._unknown_fields);
523 }
524 debug_struct.finish()
525 }
526}
527
528impl std::fmt::Debug for super::BigQueryConfig {
529 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
530 let mut debug_struct = f.debug_struct("BigQueryConfig");
531 debug_struct.field("table", &self.table);
532 debug_struct.field("use_topic_schema", &self.use_topic_schema);
533 debug_struct.field("write_metadata", &self.write_metadata);
534 debug_struct.field("drop_unknown_fields", &self.drop_unknown_fields);
535 debug_struct.field("state", &self.state);
536 debug_struct.field("use_table_schema", &self.use_table_schema);
537 debug_struct.field("service_account_email", &self.service_account_email);
538 if !self._unknown_fields.is_empty() {
539 debug_struct.field("_unknown_fields", &self._unknown_fields);
540 }
541 debug_struct.finish()
542 }
543}
544
545impl std::fmt::Debug for super::CloudStorageConfig {
546 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
547 let mut debug_struct = f.debug_struct("CloudStorageConfig");
548 debug_struct.field("bucket", &self.bucket);
549 debug_struct.field("filename_prefix", &self.filename_prefix);
550 debug_struct.field("filename_suffix", &self.filename_suffix);
551 debug_struct.field("filename_datetime_format", &self.filename_datetime_format);
552 debug_struct.field("max_duration", &self.max_duration);
553 debug_struct.field("max_bytes", &self.max_bytes);
554 debug_struct.field("max_messages", &self.max_messages);
555 debug_struct.field("state", &self.state);
556 debug_struct.field("service_account_email", &self.service_account_email);
557 debug_struct.field("output_format", &self.output_format);
558 if !self._unknown_fields.is_empty() {
559 debug_struct.field("_unknown_fields", &self._unknown_fields);
560 }
561 debug_struct.finish()
562 }
563}
564
565impl std::fmt::Debug for super::cloud_storage_config::TextConfig {
566 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
567 let mut debug_struct = f.debug_struct("TextConfig");
568 if !self._unknown_fields.is_empty() {
569 debug_struct.field("_unknown_fields", &self._unknown_fields);
570 }
571 debug_struct.finish()
572 }
573}
574
575impl std::fmt::Debug for super::cloud_storage_config::AvroConfig {
576 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
577 let mut debug_struct = f.debug_struct("AvroConfig");
578 debug_struct.field("write_metadata", &self.write_metadata);
579 debug_struct.field("use_topic_schema", &self.use_topic_schema);
580 if !self._unknown_fields.is_empty() {
581 debug_struct.field("_unknown_fields", &self._unknown_fields);
582 }
583 debug_struct.finish()
584 }
585}
586
587impl std::fmt::Debug for super::GetSubscriptionRequest {
588 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
589 let mut debug_struct = f.debug_struct("GetSubscriptionRequest");
590 debug_struct.field("subscription", &self.subscription);
591 if !self._unknown_fields.is_empty() {
592 debug_struct.field("_unknown_fields", &self._unknown_fields);
593 }
594 debug_struct.finish()
595 }
596}
597
598impl std::fmt::Debug for super::UpdateSubscriptionRequest {
599 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
600 let mut debug_struct = f.debug_struct("UpdateSubscriptionRequest");
601 debug_struct.field("subscription", &self.subscription);
602 debug_struct.field("update_mask", &self.update_mask);
603 if !self._unknown_fields.is_empty() {
604 debug_struct.field("_unknown_fields", &self._unknown_fields);
605 }
606 debug_struct.finish()
607 }
608}
609
610impl std::fmt::Debug for super::ListSubscriptionsRequest {
611 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
612 let mut debug_struct = f.debug_struct("ListSubscriptionsRequest");
613 debug_struct.field("project", &self.project);
614 debug_struct.field("page_size", &self.page_size);
615 debug_struct.field("page_token", &self.page_token);
616 if !self._unknown_fields.is_empty() {
617 debug_struct.field("_unknown_fields", &self._unknown_fields);
618 }
619 debug_struct.finish()
620 }
621}
622
623impl std::fmt::Debug for super::ListSubscriptionsResponse {
624 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
625 let mut debug_struct = f.debug_struct("ListSubscriptionsResponse");
626 debug_struct.field("subscriptions", &self.subscriptions);
627 debug_struct.field("next_page_token", &self.next_page_token);
628 if !self._unknown_fields.is_empty() {
629 debug_struct.field("_unknown_fields", &self._unknown_fields);
630 }
631 debug_struct.finish()
632 }
633}
634
635impl std::fmt::Debug for super::DeleteSubscriptionRequest {
636 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
637 let mut debug_struct = f.debug_struct("DeleteSubscriptionRequest");
638 debug_struct.field("subscription", &self.subscription);
639 if !self._unknown_fields.is_empty() {
640 debug_struct.field("_unknown_fields", &self._unknown_fields);
641 }
642 debug_struct.finish()
643 }
644}
645
646impl std::fmt::Debug for super::ModifyPushConfigRequest {
647 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
648 let mut debug_struct = f.debug_struct("ModifyPushConfigRequest");
649 debug_struct.field("subscription", &self.subscription);
650 debug_struct.field("push_config", &self.push_config);
651 if !self._unknown_fields.is_empty() {
652 debug_struct.field("_unknown_fields", &self._unknown_fields);
653 }
654 debug_struct.finish()
655 }
656}
657
658impl std::fmt::Debug for super::CreateSnapshotRequest {
659 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
660 let mut debug_struct = f.debug_struct("CreateSnapshotRequest");
661 debug_struct.field("name", &self.name);
662 debug_struct.field("subscription", &self.subscription);
663 debug_struct.field("labels", &self.labels);
664 debug_struct.field("tags", &self.tags);
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::UpdateSnapshotRequest {
673 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
674 let mut debug_struct = f.debug_struct("UpdateSnapshotRequest");
675 debug_struct.field("snapshot", &self.snapshot);
676 debug_struct.field("update_mask", &self.update_mask);
677 if !self._unknown_fields.is_empty() {
678 debug_struct.field("_unknown_fields", &self._unknown_fields);
679 }
680 debug_struct.finish()
681 }
682}
683
684impl std::fmt::Debug for super::Snapshot {
685 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
686 let mut debug_struct = f.debug_struct("Snapshot");
687 debug_struct.field("name", &self.name);
688 debug_struct.field("topic", &self.topic);
689 debug_struct.field("expire_time", &self.expire_time);
690 debug_struct.field("labels", &self.labels);
691 if !self._unknown_fields.is_empty() {
692 debug_struct.field("_unknown_fields", &self._unknown_fields);
693 }
694 debug_struct.finish()
695 }
696}
697
698impl std::fmt::Debug for super::GetSnapshotRequest {
699 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
700 let mut debug_struct = f.debug_struct("GetSnapshotRequest");
701 debug_struct.field("snapshot", &self.snapshot);
702 if !self._unknown_fields.is_empty() {
703 debug_struct.field("_unknown_fields", &self._unknown_fields);
704 }
705 debug_struct.finish()
706 }
707}
708
709impl std::fmt::Debug for super::ListSnapshotsRequest {
710 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
711 let mut debug_struct = f.debug_struct("ListSnapshotsRequest");
712 debug_struct.field("project", &self.project);
713 debug_struct.field("page_size", &self.page_size);
714 debug_struct.field("page_token", &self.page_token);
715 if !self._unknown_fields.is_empty() {
716 debug_struct.field("_unknown_fields", &self._unknown_fields);
717 }
718 debug_struct.finish()
719 }
720}
721
722impl std::fmt::Debug for super::ListSnapshotsResponse {
723 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
724 let mut debug_struct = f.debug_struct("ListSnapshotsResponse");
725 debug_struct.field("snapshots", &self.snapshots);
726 debug_struct.field("next_page_token", &self.next_page_token);
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::DeleteSnapshotRequest {
735 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
736 let mut debug_struct = f.debug_struct("DeleteSnapshotRequest");
737 debug_struct.field("snapshot", &self.snapshot);
738 if !self._unknown_fields.is_empty() {
739 debug_struct.field("_unknown_fields", &self._unknown_fields);
740 }
741 debug_struct.finish()
742 }
743}
744
745impl std::fmt::Debug for super::SeekRequest {
746 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
747 let mut debug_struct = f.debug_struct("SeekRequest");
748 debug_struct.field("subscription", &self.subscription);
749 debug_struct.field("target", &self.target);
750 if !self._unknown_fields.is_empty() {
751 debug_struct.field("_unknown_fields", &self._unknown_fields);
752 }
753 debug_struct.finish()
754 }
755}
756
757impl std::fmt::Debug for super::SeekResponse {
758 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
759 let mut debug_struct = f.debug_struct("SeekResponse");
760 if !self._unknown_fields.is_empty() {
761 debug_struct.field("_unknown_fields", &self._unknown_fields);
762 }
763 debug_struct.finish()
764 }
765}
766
767impl std::fmt::Debug for super::Schema {
768 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
769 let mut debug_struct = f.debug_struct("Schema");
770 debug_struct.field("name", &self.name);
771 debug_struct.field("r#type", &self.r#type);
772 debug_struct.field("definition", &self.definition);
773 debug_struct.field("revision_id", &self.revision_id);
774 debug_struct.field("revision_create_time", &self.revision_create_time);
775 if !self._unknown_fields.is_empty() {
776 debug_struct.field("_unknown_fields", &self._unknown_fields);
777 }
778 debug_struct.finish()
779 }
780}
781
782impl std::fmt::Debug for super::CreateSchemaRequest {
783 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
784 let mut debug_struct = f.debug_struct("CreateSchemaRequest");
785 debug_struct.field("parent", &self.parent);
786 debug_struct.field("schema", &self.schema);
787 debug_struct.field("schema_id", &self.schema_id);
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::GetSchemaRequest {
796 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
797 let mut debug_struct = f.debug_struct("GetSchemaRequest");
798 debug_struct.field("name", &self.name);
799 debug_struct.field("view", &self.view);
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::ListSchemasRequest {
808 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
809 let mut debug_struct = f.debug_struct("ListSchemasRequest");
810 debug_struct.field("parent", &self.parent);
811 debug_struct.field("view", &self.view);
812 debug_struct.field("page_size", &self.page_size);
813 debug_struct.field("page_token", &self.page_token);
814 if !self._unknown_fields.is_empty() {
815 debug_struct.field("_unknown_fields", &self._unknown_fields);
816 }
817 debug_struct.finish()
818 }
819}
820
821impl std::fmt::Debug for super::ListSchemasResponse {
822 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
823 let mut debug_struct = f.debug_struct("ListSchemasResponse");
824 debug_struct.field("schemas", &self.schemas);
825 debug_struct.field("next_page_token", &self.next_page_token);
826 if !self._unknown_fields.is_empty() {
827 debug_struct.field("_unknown_fields", &self._unknown_fields);
828 }
829 debug_struct.finish()
830 }
831}
832
833impl std::fmt::Debug for super::ListSchemaRevisionsRequest {
834 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
835 let mut debug_struct = f.debug_struct("ListSchemaRevisionsRequest");
836 debug_struct.field("name", &self.name);
837 debug_struct.field("view", &self.view);
838 debug_struct.field("page_size", &self.page_size);
839 debug_struct.field("page_token", &self.page_token);
840 if !self._unknown_fields.is_empty() {
841 debug_struct.field("_unknown_fields", &self._unknown_fields);
842 }
843 debug_struct.finish()
844 }
845}
846
847impl std::fmt::Debug for super::ListSchemaRevisionsResponse {
848 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
849 let mut debug_struct = f.debug_struct("ListSchemaRevisionsResponse");
850 debug_struct.field("schemas", &self.schemas);
851 debug_struct.field("next_page_token", &self.next_page_token);
852 if !self._unknown_fields.is_empty() {
853 debug_struct.field("_unknown_fields", &self._unknown_fields);
854 }
855 debug_struct.finish()
856 }
857}
858
859impl std::fmt::Debug for super::CommitSchemaRequest {
860 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
861 let mut debug_struct = f.debug_struct("CommitSchemaRequest");
862 debug_struct.field("name", &self.name);
863 debug_struct.field("schema", &self.schema);
864 if !self._unknown_fields.is_empty() {
865 debug_struct.field("_unknown_fields", &self._unknown_fields);
866 }
867 debug_struct.finish()
868 }
869}
870
871impl std::fmt::Debug for super::RollbackSchemaRequest {
872 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
873 let mut debug_struct = f.debug_struct("RollbackSchemaRequest");
874 debug_struct.field("name", &self.name);
875 debug_struct.field("revision_id", &self.revision_id);
876 if !self._unknown_fields.is_empty() {
877 debug_struct.field("_unknown_fields", &self._unknown_fields);
878 }
879 debug_struct.finish()
880 }
881}
882
883impl std::fmt::Debug for super::DeleteSchemaRevisionRequest {
884 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
885 let mut debug_struct = f.debug_struct("DeleteSchemaRevisionRequest");
886 debug_struct.field("name", &self.name);
887 debug_struct.field("revision_id", &self.revision_id);
888 if !self._unknown_fields.is_empty() {
889 debug_struct.field("_unknown_fields", &self._unknown_fields);
890 }
891 debug_struct.finish()
892 }
893}
894
895impl std::fmt::Debug for super::DeleteSchemaRequest {
896 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
897 let mut debug_struct = f.debug_struct("DeleteSchemaRequest");
898 debug_struct.field("name", &self.name);
899 if !self._unknown_fields.is_empty() {
900 debug_struct.field("_unknown_fields", &self._unknown_fields);
901 }
902 debug_struct.finish()
903 }
904}
905
906impl std::fmt::Debug for super::ValidateSchemaRequest {
907 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
908 let mut debug_struct = f.debug_struct("ValidateSchemaRequest");
909 debug_struct.field("parent", &self.parent);
910 debug_struct.field("schema", &self.schema);
911 if !self._unknown_fields.is_empty() {
912 debug_struct.field("_unknown_fields", &self._unknown_fields);
913 }
914 debug_struct.finish()
915 }
916}
917
918impl std::fmt::Debug for super::ValidateSchemaResponse {
919 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
920 let mut debug_struct = f.debug_struct("ValidateSchemaResponse");
921 if !self._unknown_fields.is_empty() {
922 debug_struct.field("_unknown_fields", &self._unknown_fields);
923 }
924 debug_struct.finish()
925 }
926}
927
928impl std::fmt::Debug for super::ValidateMessageRequest {
929 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
930 let mut debug_struct = f.debug_struct("ValidateMessageRequest");
931 debug_struct.field("parent", &self.parent);
932 debug_struct.field("message", &self.message);
933 debug_struct.field("encoding", &self.encoding);
934 debug_struct.field("schema_spec", &self.schema_spec);
935 if !self._unknown_fields.is_empty() {
936 debug_struct.field("_unknown_fields", &self._unknown_fields);
937 }
938 debug_struct.finish()
939 }
940}
941
942impl std::fmt::Debug for super::ValidateMessageResponse {
943 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
944 let mut debug_struct = f.debug_struct("ValidateMessageResponse");
945 if !self._unknown_fields.is_empty() {
946 debug_struct.field("_unknown_fields", &self._unknown_fields);
947 }
948 debug_struct.finish()
949 }
950}