Struct GoogleCloudDatapipelinesV1Pipeline

pub struct GoogleCloudDatapipelinesV1Pipeline {
    pub create_time: Option<DateTime<Utc>>,
    pub display_name: Option<String>,
    pub job_count: Option<i32>,
    pub last_update_time: Option<DateTime<Utc>>,
    pub name: Option<String>,
    pub pipeline_sources: Option<HashMap<String, String>>,
    pub schedule_info: Option<GoogleCloudDatapipelinesV1ScheduleSpec>,
    pub scheduler_service_account_email: Option<String>,
    pub state: Option<String>,
    pub type_: Option<String>,
    pub workload: Option<GoogleCloudDatapipelinesV1Workload>,
}

The main pipeline entity and all the necessary metadata for launching and managing linked jobs.

Activities

This type is used in activities, which are methods you may call on this type or where this type is involved in. The list links the activity name, along with information about where it is used (one of request and response).

• locations pipelines create projects (request|response)
• locations pipelines get projects (response)
• locations pipelines patch projects (request|response)
• locations pipelines stop projects (response)

Fields

create_time: Option<DateTime<Utc>>

Output only. Immutable. The timestamp when the pipeline was initially created. Set by the Data Pipelines service.

display_name: Option<String>

Required. The display name of the pipeline. It can contain only letters ([A-Za-z]), numbers ([0-9]), hyphens (-), and underscores (_).

job_count: Option<i32>

Output only. Number of jobs.

last_update_time: Option<DateTime<Utc>>

Output only. Immutable. The timestamp when the pipeline was last modified. Set by the Data Pipelines service.

name: Option<String>

The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID. * PROJECT_ID can contain letters ([A-Za-z]), numbers ([0-9]), hyphens (-), colons (:), and periods (.). For more information, see Identifying projects. * LOCATION_ID is the canonical ID for the pipeline’s location. The list of available locations can be obtained by calling google.cloud.location.Locations.ListLocations. Note that the Data Pipelines service is not available in all regions. It depends on Cloud Scheduler, an App Engine application, so it’s only available in App Engine regions. * PIPELINE_ID is the ID of the pipeline. Must be unique for the selected project and location.

pipeline_sources: Option<HashMap<String, String>>

Immutable. The sources of the pipeline (for example, Dataplex). The keys and values are set by the corresponding sources during pipeline creation.

schedule_info: Option<GoogleCloudDatapipelinesV1ScheduleSpec>

Internal scheduling information for a pipeline. If this information is provided, periodic jobs will be created per the schedule. If not, users are responsible for creating jobs externally.

scheduler_service_account_email: Option<String>

Optional. A service account email to be used with the Cloud Scheduler job. If not specified, the default compute engine service account will be used.

state: Option<String>

Required. The state of the pipeline. When the pipeline is created, the state is set to ‘PIPELINE_STATE_ACTIVE’ by default. State changes can be requested by setting the state to stopping, paused, or resuming. State cannot be changed through UpdatePipeline requests.

type_: Option<String>

Required. The type of the pipeline. This field affects the scheduling of the pipeline and the type of metrics to show for the pipeline.

workload: Option<GoogleCloudDatapipelinesV1Workload>

Workload information for creating new jobs.

Trait Implementations

impl Clone for GoogleCloudDatapipelinesV1Pipeline

fn clone(&self) -> GoogleCloudDatapipelinesV1Pipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GoogleCloudDatapipelinesV1Pipeline

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

Formats the value using the given formatter.

impl Default for GoogleCloudDatapipelinesV1Pipeline

fn default() -> GoogleCloudDatapipelinesV1Pipeline

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GoogleCloudDatapipelinesV1Pipeline

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for GoogleCloudDatapipelinesV1Pipeline

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl RequestValue for GoogleCloudDatapipelinesV1Pipeline

impl ResponseResult for GoogleCloudDatapipelinesV1Pipeline