Struct AirbyteStream 

pub struct AirbyteStream {
    pub name: String,
    pub json_schema: Option<Value>,
    pub supported_sync_modes: Option<Vec<SyncMode>>,
    pub source_defined_cursor: Option<bool>,
    pub default_cursor_field: Option<Vec<String>>,
    pub source_defined_primary_key: Option<Vec<Vec<String>>>,
    pub namespace: Option<String>,
}

AirbyteStream : the immutable schema defined by the source

Fields

name: String

Stream’s name.

json_schema: Option<Value>

Stream schema using Json Schema specs.

supported_sync_modes: Option<Vec<SyncMode>>

source_defined_cursor: Option<bool>

If the source defines the cursor field, then any other cursor field inputs will be ignored. If it does not, either the user_provided one is used, or the default one is used as a backup.

default_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. If not provided by the source, the end user will have to specify the comparable themselves.

source_defined_primary_key: Option<Vec<Vec<String>>>

If the source defines the primary key, paths to the fields that will be used as a primary key. If not provided by the source, the end user will have to specify the primary key themselves.

namespace: Option<String>

Optional Source-defined namespace. Airbyte streams from the same sources should have the same namespace. Currently only used by JDBC destinations to determine what schema to write to.

Implementations

impl AirbyteStream

pub fn new(name: String) -> AirbyteStream

the immutable schema defined by the source

Trait Implementations

impl Clone for AirbyteStream

fn clone(&self) -> AirbyteStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AirbyteStream

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

Formats the value using the given formatter.

impl Default for AirbyteStream

fn default() -> AirbyteStream

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AirbyteStream

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AirbyteStream

fn eq(&self, other: &AirbyteStream) -> 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 AirbyteStream

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 AirbyteStream