use serde::{Deserialize, Serialize};
#[derive(Clone, Debug, Default, PartialEq, Deserialize, Serialize)]
pub struct PollerV2MessageOut {
#[serde(skip_serializing_if = "Option::is_none")]
pub channels: Option<Vec<String>>,
#[serde(rename = "deliverAt")]
#[serde(skip_serializing_if = "Option::is_none")]
pub deliver_at: Option<String>,
#[serde(rename = "eventId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub event_id: Option<String>,
#[serde(rename = "eventType")]
pub event_type: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub headers: Option<std::collections::HashMap<String, String>>,
pub id: String,
pub offset: i32,
pub payload: serde_json::Value,
#[serde(skip_serializing_if = "Option::is_none")]
pub tags: Option<Vec<String>>,
pub timestamp: String,
}
impl PollerV2MessageOut {
pub fn new(
event_type: String,
id: String,
offset: i32,
payload: serde_json::Value,
timestamp: String,
) -> Self {
Self {
channels: None,
deliver_at: None,
event_id: None,
event_type,
headers: None,
id,
offset,
payload,
tags: None,
timestamp,
}
}
}