pub struct AirbyteRecordMessage {
pub data: Value,
pub emitted_at: i64,
pub meta: Option<AirbyteRecordMessageMeta>,
pub namespace: Option<String>,
pub stream: String,
}
Fields§
§data: Value
record data
emitted_at: i64
when the data was emitted from the source. epoch in millisecond.
meta: Option<AirbyteRecordMessageMeta>
Information about this record added mid-sync
namespace: Option<String>
namespace the data is associated with
stream: String
stream the data is associated with
Trait Implementations§
Source§impl Clone for AirbyteRecordMessage
impl Clone for AirbyteRecordMessage
Source§fn clone(&self) -> AirbyteRecordMessage
fn clone(&self) -> AirbyteRecordMessage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for AirbyteRecordMessage
impl Debug for AirbyteRecordMessage
Source§impl<'de> Deserialize<'de> for AirbyteRecordMessage
impl<'de> Deserialize<'de> for AirbyteRecordMessage
Source§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
Source§impl PartialEq for AirbyteRecordMessage
impl PartialEq for AirbyteRecordMessage
Source§impl Serialize for AirbyteRecordMessage
impl Serialize for AirbyteRecordMessage
impl StructuralPartialEq for AirbyteRecordMessage
Auto Trait Implementations§
impl Freeze for AirbyteRecordMessage
impl RefUnwindSafe for AirbyteRecordMessage
impl Send for AirbyteRecordMessage
impl Sync for AirbyteRecordMessage
impl Unpin for AirbyteRecordMessage
impl UnwindSafe for AirbyteRecordMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more