fusionauth_rust_client/models/
kafka_messenger_configuration.rs1use crate::models;
12use serde::{Deserialize, Serialize};
13
14#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
16pub struct KafkaMessengerConfiguration {
17 #[serde(rename = "defaultTopic", skip_serializing_if = "Option::is_none")]
18 pub default_topic: Option<String>,
19 #[serde(rename = "producer", skip_serializing_if = "Option::is_none")]
20 pub producer: Option<std::collections::HashMap<String, String>>,
21 #[serde(rename = "data", skip_serializing_if = "Option::is_none")]
22 pub data: Option<std::collections::HashMap<String, serde_json::Value>>,
23 #[serde(rename = "debug", skip_serializing_if = "Option::is_none")]
24 pub debug: Option<bool>,
25 #[serde(rename = "id", skip_serializing_if = "Option::is_none")]
26 pub id: Option<uuid::Uuid>,
27 #[serde(rename = "insertInstant", skip_serializing_if = "Option::is_none")]
29 pub insert_instant: Option<i64>,
30 #[serde(rename = "lastUpdateInstant", skip_serializing_if = "Option::is_none")]
32 pub last_update_instant: Option<i64>,
33 #[serde(rename = "name", skip_serializing_if = "Option::is_none")]
34 pub name: Option<String>,
35 #[serde(rename = "transport", skip_serializing_if = "Option::is_none")]
36 pub transport: Option<String>,
37 #[serde(rename = "type", skip_serializing_if = "Option::is_none")]
38 pub r#type: Option<models::MessengerType>,
39}
40
41impl KafkaMessengerConfiguration {
42 pub fn new() -> KafkaMessengerConfiguration {
44 KafkaMessengerConfiguration {
45 default_topic: None,
46 producer: None,
47 data: None,
48 debug: None,
49 id: None,
50 insert_instant: None,
51 last_update_instant: None,
52 name: None,
53 transport: None,
54 r#type: None,
55 }
56 }
57}
58