Struct google_datapipelines1::api::ProjectMethods

pub struct ProjectMethods<'a> { /* private fields */ }

A builder providing access to all methods supported on project resources. It is not used directly, but through the Datapipelines hub.

Example

Instantiate a resource builder

extern crate hyper;
extern crate hyper_rustls;
extern crate google_datapipelines1 as datapipelines1;
 
use std::default::Default;
use datapipelines1::{Datapipelines, oauth2, hyper, hyper_rustls};
 
let secret: oauth2::ApplicationSecret = Default::default();
let auth = oauth2::InstalledFlowAuthenticator::builder(
        secret,
        oauth2::InstalledFlowReturnMethod::HTTPRedirect,
    ).build().await.unwrap();
let mut hub = Datapipelines::new(hyper::Client::builder().build(hyper_rustls::HttpsConnector::with_native_roots()), auth);
// Usually you wouldn't bind this to a variable, but keep calling *CallBuilders*
// like `locations_list_pipelines(...)`, `locations_pipelines_create(...)`, `locations_pipelines_delete(...)`, `locations_pipelines_get(...)`, `locations_pipelines_jobs_list(...)`, `locations_pipelines_patch(...)`, `locations_pipelines_run(...)` and `locations_pipelines_stop(...)`
// to build up your call.
let rb = hub.projects();

Implementations

impl<'a> ProjectMethods<'a>

pub fn locations_pipelines_jobs_list(
    &self,
    parent: &str
) -> ProjectLocationPipelineJobListCall<'a>

Create a builder to help you perform the following task:

Lists jobs for a given pipeline. Throws a “FORBIDDEN” error if the caller doesn’t have permission to access it.

Arguments

• parent - Required. The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID.

pub fn locations_pipelines_create(
    &self,
    request: GoogleCloudDatapipelinesV1Pipeline,
    parent: &str
) -> ProjectLocationPipelineCreateCall<'a>

Create a builder to help you perform the following task:

Creates a pipeline. For a batch pipeline, you can pass scheduler information. Data Pipelines uses the scheduler information to create an internal scheduler that runs jobs periodically. If the internal scheduler is not configured, you can use RunPipeline to run jobs.

Arguments

• request - No description provided.
• parent - Required. The location name. For example: projects/PROJECT_ID/locations/LOCATION_ID.

pub fn locations_pipelines_delete(
    &self,
    name: &str
) -> ProjectLocationPipelineDeleteCall<'a>

Create a builder to help you perform the following task:

Deletes a pipeline. If a scheduler job is attached to the pipeline, it will be deleted.

Arguments

• name - Required. The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID.

pub fn locations_pipelines_get(
    &self,
    name: &str
) -> ProjectLocationPipelineGetCall<'a>

Create a builder to help you perform the following task:

Looks up a single pipeline. Returns a “NOT_FOUND” error if no such pipeline exists. Returns a “FORBIDDEN” error if the caller doesn’t have permission to access it.

Arguments

• name - Required. The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID.

pub fn locations_pipelines_patch(
    &self,
    request: GoogleCloudDatapipelinesV1Pipeline,
    name: &str
) -> ProjectLocationPipelinePatchCall<'a>

Create a builder to help you perform the following task:

Updates a pipeline. If successful, the updated Pipeline is returned. Returns NOT_FOUND if the pipeline doesn’t exist. If UpdatePipeline does not return successfully, you can retry the UpdatePipeline request until you receive a successful response.

Arguments

• request - No description provided.
• name - 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.

pub fn locations_pipelines_run(
    &self,
    request: GoogleCloudDatapipelinesV1RunPipelineRequest,
    name: &str
) -> ProjectLocationPipelineRunCall<'a>

Create a builder to help you perform the following task:

Creates a job for the specified pipeline directly. You can use this method when the internal scheduler is not configured and you want to trigger the job directly or through an external system. Returns a “NOT_FOUND” error if the pipeline doesn’t exist. Returns a “FORBIDDEN” error if the user doesn’t have permission to access the pipeline or run jobs for the pipeline.

Arguments

• request - No description provided.
• name - Required. The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID.

pub fn locations_pipelines_stop(
    &self,
    request: GoogleCloudDatapipelinesV1StopPipelineRequest,
    name: &str
) -> ProjectLocationPipelineStopCall<'a>

Create a builder to help you perform the following task:

Freezes pipeline execution permanently. If there’s a corresponding scheduler entry, it’s deleted, and the pipeline state is changed to “ARCHIVED”. However, pipeline metadata is retained.

Arguments

• request - No description provided.
• name - Required. The pipeline name. For example: projects/PROJECT_ID/locations/LOCATION_ID/pipelines/PIPELINE_ID.

pub fn locations_list_pipelines(
    &self,
    parent: &str
) -> ProjectLocationListPipelineCall<'a>

Create a builder to help you perform the following task:

Lists pipelines. Returns a “FORBIDDEN” error if the caller doesn’t have permission to access it.

Arguments

• parent - Required. The location name. For example: projects/PROJECT_ID/locations/LOCATION_ID.

Trait Implementations

impl<'a> MethodsBuilder for ProjectMethods<'a>