Struct aws_lambda_events::event::kafka::KafkaRecord [−][src]
pub struct KafkaRecord {
pub topic: Option<String>,
pub partition: i64,
pub offset: i64,
pub timestamp: MillisecondTimestamp,
pub timestamp_type: Option<String>,
pub key: Option<String>,
pub value: Option<String>,
pub headers: Vec<HashMap<String, Base64Data>>,
}
Fields
topic: Option<String>
partition: i64
offset: i64
timestamp: MillisecondTimestamp
timestamp_type: Option<String>
key: Option<String>
value: Option<String>
headers: Vec<HashMap<String, Base64Data>>
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for KafkaRecord
impl Send for KafkaRecord
impl Sync for KafkaRecord
impl Unpin for KafkaRecord
impl UnwindSafe for KafkaRecord
Blanket Implementations
Mutably borrows from an owned value. Read more