Struct ConfiguredAirbyteStream

pub struct ConfiguredAirbyteStream {
    pub cursor_field: Option<Vec<String>>,
    pub destination_sync_mode: DestinationSyncMode,
    pub generation_id: Option<i64>,
    pub minimum_generation_id: Option<i64>,
    pub primary_key: Option<Vec<Vec<String>>>,
    pub stream: AirbyteStream,
    pub sync_id: Option<i64>,
    pub sync_mode: SyncMode,
}

Fields

cursor_field: Option<Vec<String>>

Path to the field that will be used to determine if a record is new or modified since the last sync. This field is REQUIRED if sync_mode is incremental. Otherwise it is ignored.

destination_sync_mode: DestinationSyncMode

generation_id: Option<i64>

Monotically increasing numeric id representing the current generation of a stream. This id can be shared across syncs. If this is null, it means that the platform is not supporting the refresh and it is expected that no extra id will be added to the records and no data from previous generation will be cleanup.

minimum_generation_id: Option<i64>

The minimum generation id which is needed in a stream. If it is present, the destination will try to delete the data that are part of a generation lower than this property. If the minimum generation is equals to 0, no data deletion is expected from the destiantion If this is null, it means that the platform is not supporting the refresh and it is expected that no extra id will be added to the records and no data from previous generation will be cleanup.

primary_key: Option<Vec<Vec<String>>>

Paths to the fields that will be used as primary key. This field is REQUIRED if destination_sync_mode is *_dedup. Otherwise it is ignored.

stream: AirbyteStream

sync_id: Option<i64>

Monotically increasing numeric id representing the current sync id. This is aimed to be unique per sync. If this is null, it means that the platform is not supporting the refresh and it is expected that no extra id will be added to the records and no data from previous generation will be cleanup.

sync_mode: SyncMode

Trait Implementations

impl Clone for ConfiguredAirbyteStream

fn clone(&self) -> ConfiguredAirbyteStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConfiguredAirbyteStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ConfiguredAirbyteStream

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConfiguredAirbyteStream

fn eq(&self, other: &ConfiguredAirbyteStream) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ConfiguredAirbyteStream

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConfiguredAirbyteStream