Struct ExtPipe 

pub struct ExtPipe {

    pub id: i64,
    pub external_id: String,
    pub name: String,
    pub description: Option<String>,
    pub data_set_id: i64,
    pub raw_tables: Option<Vec<ExtPipeRawTable>>,
    pub schedule: Option<String>,
    pub contacts: Option<Vec<ExtPipeContact>>,
    pub metadata: Option<HashMap<String, String>>,
    pub source: Option<String>,
    pub documentation: Option<String>,
    pub last_success: Option<i64>,
    pub last_failure: Option<i64>,
    pub last_message: Option<String>,
    pub last_seen: Option<i64>,
    pub created_time: i64,
    pub last_updated_time: i64,
    pub created_by: Option<String>,
}

An extraction pipeline.

Fields

id: i64

Internal ID

external_id: String

Extraction pipeline external ID. Must be unique accross all extraction pipelines in the project.

name: String

Extraction pipeline name.

description: Option<String>

Short description.

data_set_id: i64

Data set this extraction pipeline belongs to.

raw_tables: Option<Vec<ExtPipeRawTable>>

List of raw tables the extractor this extraction pipeline represents is documented to write to.

schedule: Option<String>

Documented schedule.

contacts: Option<Vec<ExtPipeContact>>

List of contacts.

metadata: Option<HashMap<String, String>>

Application specific metadata.

source: Option<String>

User provided source.

documentation: Option<String>

Long form documentation.

last_success: Option<i64>

Timestamp of last success, in milliseconds since epoch.

last_failure: Option<i64>

Timestamp of last failure, in milliseconds since epoch.

last_message: Option<String>

Last message received.

last_seen: Option<i64>

Timestamp of last event, in milliseconds since epoch.

created_time: i64

Time this extraction pipeline was created, in milliseconds since epoch.

last_updated_time: i64

Time this extraction pipeline was last updated, in milliseconds since epoch.

created_by: Option<String>

The user that created this extraction pipeline, if available.

Trait Implementations

impl Clone for ExtPipe

fn clone(&self) -> ExtPipe

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Create<AddExtPipe, ExtPipe> for ExtPipesResource

fn create( &self, creates: &[TCreate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Create a list of resources.

fn create_from( &self, creates: &[impl Into<TCreate> + Sync + Clone], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Create a list of resources, converting from a different type.

impl Debug for ExtPipe

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExtPipe

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FilterItems<ExtPipeFilter, ExtPipe> for ExtPipesResource

fn filter_items( &self, filter: TFilter, cursor: Option<String>, limit: Option<u32>, ) -> impl Future<Output = Result<ItemsVec<TResponse, Cursor>>> + Send

Filter resources using a simple filter. The response may contain a cursor that can be used to paginate results.

impl From<ExtPipe> for AddExtPipe

fn from(pipe: ExtPipe) -> Self

Converts to this type from the input type.

impl From<ExtPipe> for Patch<PatchExtPipe>

fn from(sequence: ExtPipe) -> Self

Converts to this type from the input type.

impl IntoPatch<Patch<PatchExtPipe>> for ExtPipe

fn patch(self, options: &UpsertOptions) -> Patch<PatchExtPipe>

Convert self into a patch, optionally ignoring null values.

impl<R> RetrieveWithIgnoreUnknownIds<IdentityList<R>, ExtPipe> for ExtPipesResource

where IdentityList<R>: Serialize, R: Send + Sync,

fn retrieve( &self, ids: impl Into<TIdt> + Send, ignore_unknown_ids: bool, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Retrieve a list of items from CDF. If ignore_unknown_ids is false, this will fail if any items are missing from CDF.

impl Serialize for ExtPipe

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Update<Patch<PatchExtPipe>, ExtPipe> for ExtPipesResource

fn update( &self, updates: &[TUpdate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Update a list of resources.

fn update_from<'a, T>( &self, updates: &'a [T], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where T: Sync + Clone + 'a, TUpdate: From<T>,

Update a list of resources by converting to the update from a different type.

fn update_ignore_unknown_ids( &self, updates: &[TUpdate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TUpdate: EqIdentity, TResponse: Send,

Update a list of resources, ignoring any that fail due to items missing in CDF.

fn update_from_ignore_unknown_ids<'a, T>( &self, updates: &'a [T], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where T: Sync + Clone + 'a, TUpdate: From<T> + EqIdentity, TResponse: Send,

Update a list of resources by converting from a different type, ignoring any that fail due items missing in CDF.