v1

package
v0.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 22, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Run in the default mode.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalFlexrsUnspecified = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal("FLEXRS_UNSPECIFIED")
	// Optimize for lower execution time.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalFlexrsSpeedOptimized = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal("FLEXRS_SPEED_OPTIMIZED")
	// Optimize for lower cost.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalFlexrsCostOptimized = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal("FLEXRS_COST_OPTIMIZED")
)
View Source 
const (
	// The configuration is unknown, or unspecified.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationWorkerIpUnspecified = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration("WORKER_IP_UNSPECIFIED")
	// Workers should have public IP addresses.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationWorkerIpPublic = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration("WORKER_IP_PUBLIC")
	// Workers should have private IP addresses.
	GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationWorkerIpPrivate = GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration("WORKER_IP_PRIVATE")
)
View Source 
const (
	// The configuration is unknown, or unspecified.
	GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationWorkerIpUnspecified = GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration("WORKER_IP_UNSPECIFIED")
	// Workers should have public IP addresses.
	GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationWorkerIpPublic = GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration("WORKER_IP_PUBLIC")
	// Workers should have private IP addresses.
	GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationWorkerIpPrivate = GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration("WORKER_IP_PRIVATE")
)
View Source 
const (
	// The pipeline state isn't specified.
	PipelineStateEnumStateUnspecified = PipelineStateEnum("STATE_UNSPECIFIED")
	// The pipeline is getting started or resumed. When finished, the pipeline state will be 'PIPELINE_STATE_ACTIVE'.
	PipelineStateEnumStateResuming = PipelineStateEnum("STATE_RESUMING")
	// The pipeline is actively running.
	PipelineStateEnumStateActive = PipelineStateEnum("STATE_ACTIVE")
	// The pipeline is in the process of stopping. When finished, the pipeline state will be 'PIPELINE_STATE_ARCHIVED'.
	PipelineStateEnumStateStopping = PipelineStateEnum("STATE_STOPPING")
	// The pipeline has been stopped. This is a terminal state and cannot be undone.
	PipelineStateEnumStateArchived = PipelineStateEnum("STATE_ARCHIVED")
	// The pipeline is paused. This is a non-terminal state. When the pipeline is paused, it will hold processing jobs, but can be resumed later. For a batch pipeline, this means pausing the scheduler job. For a streaming pipeline, creating a job snapshot to resume from will give the same effect.
	PipelineStateEnumStatePaused = PipelineStateEnum("STATE_PAUSED")
)
View Source 
const (
	// The pipeline type isn't specified.
	PipelineTypePipelineTypeUnspecified = PipelineType("PIPELINE_TYPE_UNSPECIFIED")
	// A batch pipeline. It runs jobs on a specific schedule, and each job will automatically terminate once execution is finished.
	PipelineTypePipelineTypeBatch = PipelineType("PIPELINE_TYPE_BATCH")
	// A streaming pipeline. The underlying job is continuously running until it is manually terminated by the user. This type of pipeline doesn't have a schedule to run on, and the linked job gets created when the pipeline is created.
	PipelineTypePipelineTypeStreaming = PipelineType("PIPELINE_TYPE_STREAMING")
)

Variables

This section is empty.

Functions

This section is empty.

Types

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment struct {
	// Additional experiment flags for the job.
	AdditionalExperiments []string `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.
	AdditionalUserLabels map[string]string `pulumi:"additionalUserLabels"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine *bool `pulumi:"enableStreamingEngine"`
	// Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
	FlexrsGoal *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal `pulumi:"flexrsGoal"`
	// Configuration for VM IPs.
	IpConfiguration *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName *string `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType *string `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers *int `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network *string `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers *int `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail *string `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork *string `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation *string `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.
	WorkerRegion *string `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone *string `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone *string `pulumi:"zone"`
}

The environment values to be set at runtime for a Flex Template.

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs struct {
	// Additional experiment flags for the job.
	AdditionalExperiments pulumi.StringArrayInput `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.
	AdditionalUserLabels pulumi.StringMapInput `pulumi:"additionalUserLabels"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine pulumi.BoolPtrInput `pulumi:"enableStreamingEngine"`
	// Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
	FlexrsGoal GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrInput `pulumi:"flexrsGoal"`
	// Configuration for VM IPs.
	IpConfiguration GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrInput `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName pulumi.StringPtrInput `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType pulumi.StringPtrInput `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers pulumi.IntPtrInput `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network pulumi.StringPtrInput `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers pulumi.IntPtrInput `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail pulumi.StringPtrInput `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork pulumi.StringPtrInput `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation pulumi.StringPtrInput `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.
	WorkerRegion pulumi.StringPtrInput `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone pulumi.StringPtrInput `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone pulumi.StringPtrInput `pulumi:"zone"`
}

The environment values to be set at runtime for a Flex Template.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutputWithContext 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal string

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringPtrOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoal) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalArgs and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalInput` via: 

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalArgs{...}

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput
}

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtr 

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtr(v string) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrInput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) Elem() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentInput` via: 

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs{...}

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration string

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringPtrOutput 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfiguration) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationArgs and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationInput` via: 

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationArgs{...}

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput
}

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtr 

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtr(v string) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrInput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) Elem() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput struct{ *pulumi.OutputState }

The environment values to be set at runtime for a Flex Template.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) FlexrsGoal 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) FlexrsGoal() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) IpConfiguration() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) MachineType 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Network 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Zone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs, GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtr and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput` via: 

        GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtr 

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtr(v *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentArgs) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Elem() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) FlexrsGoal 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) FlexrsGoal() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentFlexrsGoalPtrOutput

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) IpConfiguration() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentIpConfigurationPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) MachineType 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Network 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Zone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse struct {
	// Additional experiment flags for the job.
	AdditionalExperiments []string `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.
	AdditionalUserLabels map[string]string `pulumi:"additionalUserLabels"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine bool `pulumi:"enableStreamingEngine"`
	// Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
	FlexrsGoal string `pulumi:"flexrsGoal"`
	// Configuration for VM IPs.
	IpConfiguration string `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName string `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType string `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers int `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network string `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers int `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail string `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork string `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation string `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.
	WorkerRegion string `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone string `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone string `pulumi:"zone"`
}

The environment values to be set at runtime for a Flex Template.

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs struct {
	// Additional experiment flags for the job.
	AdditionalExperiments pulumi.StringArrayInput `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.
	AdditionalUserLabels pulumi.StringMapInput `pulumi:"additionalUserLabels"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine pulumi.BoolInput `pulumi:"enableStreamingEngine"`
	// Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
	FlexrsGoal pulumi.StringInput `pulumi:"flexrsGoal"`
	// Configuration for VM IPs.
	IpConfiguration pulumi.StringInput `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName pulumi.StringInput `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType pulumi.StringInput `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers pulumi.IntInput `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network pulumi.StringInput `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers pulumi.IntInput `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail pulumi.StringInput `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork pulumi.StringInput `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation pulumi.StringInput `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.
	WorkerRegion pulumi.StringInput `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone pulumi.StringInput `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone pulumi.StringInput `pulumi:"zone"`
}

The environment values to be set at runtime for a Flex Template.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseInput` via: 

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs{...}

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput struct{ *pulumi.OutputState }

The environment values to be set at runtime for a Flex Template.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) EnableStreamingEngine() pulumi.BoolOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) FlexrsGoal 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) FlexrsGoal() pulumi.StringOutput

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) IpConfiguration() pulumi.StringOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) KmsKeyName() pulumi.StringOutput

Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) MachineType 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) MachineType() pulumi.StringOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) MaxWorkers() pulumi.IntOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Network 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Network() pulumi.StringOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) NumWorkers() pulumi.IntOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ServiceAccountEmail() pulumi.StringOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Subnetwork() pulumi.StringOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) TempLocation() pulumi.StringOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) WorkerRegion() pulumi.StringOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) WorkerZone() pulumi.StringOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Zone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput) Zone() pulumi.StringOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrInput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput
	ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput
}

GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs, GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtr and GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtr 

func GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtr(v *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseArgs) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrInput

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput 

type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions). An object containing a list of key/value pairs. Example: `{ "name": "wrench", "mass": "1kg", "count": "3" }`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) FlexrsGoal 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) FlexrsGoal() pulumi.StringPtrOutput

Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) IpConfiguration() pulumi.StringPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) MachineType 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Network 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Zone 

func (o GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter struct {
	// Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.
	ContainerSpecGcsPath *string `pulumi:"containerSpecGcsPath"`
	// The runtime environment for the Flex Template job.
	Environment *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment `pulumi:"environment"`
	// The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.
	JobName string `pulumi:"jobName"`
	// Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.
	LaunchOptions map[string]string `pulumi:"launchOptions"`
	// The parameters for the Flex Template. Example: `{"num_workers":"5"}`
	Parameters map[string]string `pulumi:"parameters"`
	// Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`
	TransformNameMappings map[string]string `pulumi:"transformNameMappings"`
	// Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.
	Update *bool `pulumi:"update"`
}

Launch Flex Template parameter.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs struct {
	// Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.
	ContainerSpecGcsPath pulumi.StringPtrInput `pulumi:"containerSpecGcsPath"`
	// The runtime environment for the Flex Template job.
	Environment GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrInput `pulumi:"environment"`
	// The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.
	JobName pulumi.StringInput `pulumi:"jobName"`
	// Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.
	LaunchOptions pulumi.StringMapInput `pulumi:"launchOptions"`
	// The parameters for the Flex Template. Example: `{"num_workers":"5"}`
	Parameters pulumi.StringMapInput `pulumi:"parameters"`
	// Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`
	TransformNameMappings pulumi.StringMapInput `pulumi:"transformNameMappings"`
	// Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.
	Update pulumi.BoolPtrInput `pulumi:"update"`
}

Launch Flex Template parameter.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs and GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterInput` via: 

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs{...}

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput struct{ *pulumi.OutputState }

Launch Flex Template parameter.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ContainerSpecGcsPath 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ContainerSpecGcsPath() pulumi.StringPtrOutput

Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Environment() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

The runtime environment for the Flex Template job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) JobName() pulumi.StringOutput

The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) LaunchOptions 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) LaunchOptions() pulumi.StringMapOutput

Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Parameters() pulumi.StringMapOutput

The parameters for the Flex Template. Example: `{"num_workers":"5"}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) TransformNameMappings 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) TransformNameMappings() pulumi.StringMapOutput

Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput) Update() pulumi.BoolPtrOutput

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs, GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtr and GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtr 

func GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtr(v *GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterArgs) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrInput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ContainerSpecGcsPath 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ContainerSpecGcsPath() pulumi.StringPtrOutput

Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Environment() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentPtrOutput

The runtime environment for the Flex Template job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) JobName() pulumi.StringPtrOutput

The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) LaunchOptions 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) LaunchOptions() pulumi.StringMapOutput

Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Parameters() pulumi.StringMapOutput

The parameters for the Flex Template. Example: `{"num_workers":"5"}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) TransformNameMappings 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) TransformNameMappings() pulumi.StringMapOutput

Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput) Update() pulumi.BoolPtrOutput

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponse 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponse struct {
	// Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.
	ContainerSpecGcsPath string `pulumi:"containerSpecGcsPath"`
	// The runtime environment for the Flex Template job.
	Environment GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponse `pulumi:"environment"`
	// The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.
	JobName string `pulumi:"jobName"`
	// Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.
	LaunchOptions map[string]string `pulumi:"launchOptions"`
	// The parameters for the Flex Template. Example: `{"num_workers":"5"}`
	Parameters map[string]string `pulumi:"parameters"`
	// Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`
	TransformNameMappings map[string]string `pulumi:"transformNameMappings"`
	// Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.
	Update bool `pulumi:"update"`
}

Launch Flex Template parameter.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs struct {
	// Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.
	ContainerSpecGcsPath pulumi.StringInput `pulumi:"containerSpecGcsPath"`
	// The runtime environment for the Flex Template job.
	Environment GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseInput `pulumi:"environment"`
	// The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.
	JobName pulumi.StringInput `pulumi:"jobName"`
	// Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.
	LaunchOptions pulumi.StringMapInput `pulumi:"launchOptions"`
	// The parameters for the Flex Template. Example: `{"num_workers":"5"}`
	Parameters pulumi.StringMapInput `pulumi:"parameters"`
	// Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`
	TransformNameMappings pulumi.StringMapInput `pulumi:"transformNameMappings"`
	// Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.
	Update pulumi.BoolInput `pulumi:"update"`
}

Launch Flex Template parameter.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs and GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseInput` via: 

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs{...}

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput struct{ *pulumi.OutputState }

Launch Flex Template parameter.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ContainerSpecGcsPath 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ContainerSpecGcsPath() pulumi.StringOutput

Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Environment() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponseOutput

The runtime environment for the Flex Template job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) JobName() pulumi.StringOutput

The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) LaunchOptions 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) LaunchOptions() pulumi.StringMapOutput

Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Parameters() pulumi.StringMapOutput

The parameters for the Flex Template. Example: `{"num_workers":"5"}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) TransformNameMappings 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) TransformNameMappings() pulumi.StringMapOutput

Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput) Update() pulumi.BoolOutput

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs, GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtr and GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtr 

func GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtr(v *GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseArgs) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrInput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ContainerSpecGcsPath 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ContainerSpecGcsPath() pulumi.StringPtrOutput

Cloud Storage path to a file with a JSON-serialized ContainerSpec as content.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Environment() GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironmentResponsePtrOutput

The runtime environment for the Flex Template job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) JobName() pulumi.StringPtrOutput

The job name to use for the created job. For an update job request, the job name should be the same as the existing running job.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) LaunchOptions 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) LaunchOptions() pulumi.StringMapOutput

Launch options for this Flex Template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Parameters() pulumi.StringMapOutput

The parameters for the Flex Template. Example: `{"num_workers":"5"}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) TransformNameMappings 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) TransformNameMappings() pulumi.StringMapOutput

Use this to pass transform name mappings for streaming update jobs. Example: `{"oldTransformName":"newTransformName",...}`

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput) Update() pulumi.BoolPtrOutput

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest struct {
	// Parameter to launch a job from a Flex Template.
	LaunchParameter GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter `pulumi:"launchParameter"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.
	Location string `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project string `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly *bool `pulumi:"validateOnly"`
}

A request to launch a Dataflow job from a Flex Template.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs struct {
	// Parameter to launch a job from a Flex Template.
	LaunchParameter GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterInput `pulumi:"launchParameter"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.
	Location pulumi.StringInput `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project pulumi.StringInput `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly pulumi.BoolPtrInput `pulumi:"validateOnly"`
}

A request to launch a Dataflow job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs and GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestInput` via: 

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs{...}

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput struct{ *pulumi.OutputState }

A request to launch a Dataflow job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) LaunchParameter 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) LaunchParameter() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterOutput

Parameter to launch a job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) Location() pulumi.StringOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) Project() pulumi.StringOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs, GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtr and GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtr 

func GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtr(v *GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestArgs) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) LaunchParameter 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) LaunchParameter() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterPtrOutput

Parameter to launch a job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Location() pulumi.StringPtrOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) Project() pulumi.StringPtrOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponse 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponse struct {
	// Parameter to launch a job from a Flex Template.
	LaunchParameter GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponse `pulumi:"launchParameter"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.
	Location string `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project string `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly bool `pulumi:"validateOnly"`
}

A request to launch a Dataflow job from a Flex Template.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs struct {
	// Parameter to launch a job from a Flex Template.
	LaunchParameter GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseInput `pulumi:"launchParameter"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.
	Location pulumi.StringInput `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project pulumi.StringInput `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly pulumi.BoolInput `pulumi:"validateOnly"`
}

A request to launch a Dataflow job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs and GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseInput` via: 

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs{...}

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput struct{ *pulumi.OutputState }

A request to launch a Dataflow job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) LaunchParameter 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) LaunchParameter() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponseOutput

Parameter to launch a job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) Location() pulumi.StringOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) Project() pulumi.StringOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput) ValidateOnly() pulumi.BoolOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrInput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput
	ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput
}

GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs, GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtr and GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtr 

func GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtr(v *GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseArgs) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrInput

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput 

type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) LaunchParameter 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) LaunchParameter() GoogleCloudDatapipelinesV1LaunchFlexTemplateParameterResponsePtrOutput

Parameter to launch a job from a Flex Template.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Location() pulumi.StringPtrOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request. For example, `us-central1`, `us-west1`.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) Project() pulumi.StringPtrOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchTemplateParameters 

type GoogleCloudDatapipelinesV1LaunchTemplateParameters struct {
	// The runtime environment for the job.
	Environment *GoogleCloudDatapipelinesV1RuntimeEnvironment `pulumi:"environment"`
	// The job name to use for the created job.
	JobName string `pulumi:"jobName"`
	// The runtime parameters to pass to the job.
	Parameters map[string]string `pulumi:"parameters"`
	// Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.
	TransformNameMapping map[string]string `pulumi:"transformNameMapping"`
	// If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.
	Update *bool `pulumi:"update"`
}

Parameters to provide to the template being launched.

type GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs struct {
	// The runtime environment for the job.
	Environment GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput `pulumi:"environment"`
	// The job name to use for the created job.
	JobName pulumi.StringInput `pulumi:"jobName"`
	// The runtime parameters to pass to the job.
	Parameters pulumi.StringMapInput `pulumi:"parameters"`
	// Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.
	TransformNameMapping pulumi.StringMapInput `pulumi:"transformNameMapping"`
	// If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.
	Update pulumi.BoolPtrInput `pulumi:"update"`
}

Parameters to provide to the template being launched.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

type GoogleCloudDatapipelinesV1LaunchTemplateParametersInput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateParametersInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs and GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateParametersInput` via: 

GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs{...}

type GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput struct{ *pulumi.OutputState }

Parameters to provide to the template being launched.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Environment() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

The runtime environment for the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) JobName() pulumi.StringOutput

The job name to use for the created job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Parameters() pulumi.StringMapOutput

The runtime parameters to pass to the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) TransformNameMapping 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) TransformNameMapping() pulumi.StringMapOutput

Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput) Update() pulumi.BoolPtrOutput

If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.

type GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs, GoogleCloudDatapipelinesV1LaunchTemplateParametersPtr and GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchTemplateParametersPtr 

func GoogleCloudDatapipelinesV1LaunchTemplateParametersPtr(v *GoogleCloudDatapipelinesV1LaunchTemplateParametersArgs) GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput

type GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchTemplateParametersOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Environment() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

The runtime environment for the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) JobName() pulumi.StringPtrOutput

The job name to use for the created job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Parameters() pulumi.StringMapOutput

The runtime parameters to pass to the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) TransformNameMapping 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) TransformNameMapping() pulumi.StringMapOutput

Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput) Update() pulumi.BoolPtrOutput

If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponse 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponse struct {
	// The runtime environment for the job.
	Environment GoogleCloudDatapipelinesV1RuntimeEnvironmentResponse `pulumi:"environment"`
	// The job name to use for the created job.
	JobName string `pulumi:"jobName"`
	// The runtime parameters to pass to the job.
	Parameters map[string]string `pulumi:"parameters"`
	// Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.
	TransformNameMapping map[string]string `pulumi:"transformNameMapping"`
	// If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.
	Update bool `pulumi:"update"`
}

Parameters to provide to the template being launched.

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs struct {
	// The runtime environment for the job.
	Environment GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseInput `pulumi:"environment"`
	// The job name to use for the created job.
	JobName pulumi.StringInput `pulumi:"jobName"`
	// The runtime parameters to pass to the job.
	Parameters pulumi.StringMapInput `pulumi:"parameters"`
	// Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.
	TransformNameMapping pulumi.StringMapInput `pulumi:"transformNameMapping"`
	// If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.
	Update pulumi.BoolInput `pulumi:"update"`
}

Parameters to provide to the template being launched.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseInput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs and GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseInput` via: 

GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs{...}

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput struct{ *pulumi.OutputState }

Parameters to provide to the template being launched.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Environment() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

The runtime environment for the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) JobName() pulumi.StringOutput

The job name to use for the created job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Parameters() pulumi.StringMapOutput

The runtime parameters to pass to the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) TransformNameMapping 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) TransformNameMapping() pulumi.StringMapOutput

Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput) Update() pulumi.BoolOutput

If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrInput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs, GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtr and GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtr 

func GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtr(v *GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseArgs) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrInput

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Environment 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Environment() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

The runtime environment for the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) JobName 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) JobName() pulumi.StringPtrOutput

The job name to use for the created job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Parameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Parameters() pulumi.StringMapOutput

The runtime parameters to pass to the job.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) TransformNameMapping 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) TransformNameMapping() pulumi.StringMapOutput

Map of transform name prefixes of the job to be replaced to the corresponding name prefixes of the new job. Only applicable when updating a pipeline.

func (GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Update 

func (o GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput) Update() pulumi.BoolPtrOutput

If set, replace the existing pipeline with the name specified by jobName with this pipeline, preserving state.

type GoogleCloudDatapipelinesV1LaunchTemplateRequest 

type GoogleCloudDatapipelinesV1LaunchTemplateRequest struct {
	// A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.
	GcsPath *string `pulumi:"gcsPath"`
	// The parameters of the template to launch. This should be part of the body of the POST request.
	LaunchParameters *GoogleCloudDatapipelinesV1LaunchTemplateParameters `pulumi:"launchParameters"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.
	Location *string `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project string `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly *bool `pulumi:"validateOnly"`
}

A request to launch a template.

type GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs struct {
	// A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.
	GcsPath pulumi.StringPtrInput `pulumi:"gcsPath"`
	// The parameters of the template to launch. This should be part of the body of the POST request.
	LaunchParameters GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrInput `pulumi:"launchParameters"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.
	Location pulumi.StringPtrInput `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project pulumi.StringInput `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly pulumi.BoolPtrInput `pulumi:"validateOnly"`
}

A request to launch a template.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

type GoogleCloudDatapipelinesV1LaunchTemplateRequestInput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateRequestInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs and GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateRequestInput` via: 

GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs{...}

type GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput struct{ *pulumi.OutputState }

A request to launch a template.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) GcsPath 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) GcsPath() pulumi.StringPtrOutput

A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) LaunchParameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) LaunchParameters() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

The parameters of the template to launch. This should be part of the body of the POST request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) Location() pulumi.StringPtrOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) Project() pulumi.StringOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs, GoogleCloudDatapipelinesV1LaunchTemplateRequestPtr and GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchTemplateRequestPtr 

func GoogleCloudDatapipelinesV1LaunchTemplateRequestPtr(v *GoogleCloudDatapipelinesV1LaunchTemplateRequestArgs) GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput

type GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchTemplateRequestOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) GcsPath 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) GcsPath() pulumi.StringPtrOutput

A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) LaunchParameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) LaunchParameters() GoogleCloudDatapipelinesV1LaunchTemplateParametersPtrOutput

The parameters of the template to launch. This should be part of the body of the POST request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Location() pulumi.StringPtrOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) Project() pulumi.StringPtrOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponse 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponse struct {
	// A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.
	GcsPath string `pulumi:"gcsPath"`
	// The parameters of the template to launch. This should be part of the body of the POST request.
	LaunchParameters GoogleCloudDatapipelinesV1LaunchTemplateParametersResponse `pulumi:"launchParameters"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.
	Location string `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project string `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly bool `pulumi:"validateOnly"`
}

A request to launch a template.

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs struct {
	// A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.
	GcsPath pulumi.StringInput `pulumi:"gcsPath"`
	// The parameters of the template to launch. This should be part of the body of the POST request.
	LaunchParameters GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseInput `pulumi:"launchParameters"`
	// The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.
	Location pulumi.StringInput `pulumi:"location"`
	// The ID of the Cloud Platform project that the job belongs to.
	Project pulumi.StringInput `pulumi:"project"`
	// If true, the request is validated but not actually executed. Defaults to false.
	ValidateOnly pulumi.BoolInput `pulumi:"validateOnly"`
}

A request to launch a template.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseInput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs and GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseInput` via: 

GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs{...}

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput struct{ *pulumi.OutputState }

A request to launch a template.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) GcsPath 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) GcsPath() pulumi.StringOutput

A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) LaunchParameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) LaunchParameters() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponseOutput

The parameters of the template to launch. This should be part of the body of the POST request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) Location() pulumi.StringOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) Project() pulumi.StringOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput) ValidateOnly() pulumi.BoolOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrInput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput
	ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput
}

GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs, GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtr and GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtr 

func GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtr(v *GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseArgs) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrInput

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput 

type GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) GcsPath 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) GcsPath() pulumi.StringPtrOutput

A Cloud Storage path to the template from which to create the job. Must be a valid Cloud Storage URL, beginning with 'gs://'.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) LaunchParameters 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) LaunchParameters() GoogleCloudDatapipelinesV1LaunchTemplateParametersResponsePtrOutput

The parameters of the template to launch. This should be part of the body of the POST request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Location 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Location() pulumi.StringPtrOutput

The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to which to direct the request.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Project 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) Project() pulumi.StringPtrOutput

The ID of the Cloud Platform project that the job belongs to.

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ToGoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

func (GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ValidateOnly 

func (o GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput) ValidateOnly() pulumi.BoolPtrOutput

If true, the request is validated but not actually executed. Defaults to false.

type GoogleCloudDatapipelinesV1RuntimeEnvironment 

type GoogleCloudDatapipelinesV1RuntimeEnvironment struct {
	// Additional experiment flags for the job.
	AdditionalExperiments []string `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
	AdditionalUserLabels map[string]string `pulumi:"additionalUserLabels"`
	// Whether to bypass the safety checks for the job's temporary directory. Use with caution.
	BypassTempDirValidation *bool `pulumi:"bypassTempDirValidation"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine *bool `pulumi:"enableStreamingEngine"`
	// Configuration for VM IPs.
	IpConfiguration *GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName *string `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType *string `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers *int `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network *string `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers *int `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail *string `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork *string `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation *string `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
	WorkerRegion *string `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone *string `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone *string `pulumi:"zone"`
}

The environment values to set at runtime.

type GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs struct {
	// Additional experiment flags for the job.
	AdditionalExperiments pulumi.StringArrayInput `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
	AdditionalUserLabels pulumi.StringMapInput `pulumi:"additionalUserLabels"`
	// Whether to bypass the safety checks for the job's temporary directory. Use with caution.
	BypassTempDirValidation pulumi.BoolPtrInput `pulumi:"bypassTempDirValidation"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine pulumi.BoolPtrInput `pulumi:"enableStreamingEngine"`
	// Configuration for VM IPs.
	IpConfiguration GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrInput `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName pulumi.StringPtrInput `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType pulumi.StringPtrInput `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers pulumi.IntPtrInput `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network pulumi.StringPtrInput `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers pulumi.IntPtrInput `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail pulumi.StringPtrInput `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork pulumi.StringPtrInput `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation pulumi.StringPtrInput `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
	WorkerRegion pulumi.StringPtrInput `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone pulumi.StringPtrInput `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone pulumi.StringPtrInput `pulumi:"zone"`
}

The environment values to set at runtime.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutput 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutputWithContext 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput
}

GoogleCloudDatapipelinesV1RuntimeEnvironmentInput is an input type that accepts GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs and GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1RuntimeEnvironmentInput` via: 

GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs{...}

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration string

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutputWithContext 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringOutput 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringOutputWithContext 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringPtrOutput 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringPtrOutputWithContext 

func (e GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfiguration) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput
}

GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationInput is an input type that accepts GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationArgs and GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationInput` via: 

GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationArgs{...}

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringOutput() pulumi.StringOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput
}

func GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtr 

func GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtr(v string) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrInput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) Elem() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput struct{ *pulumi.OutputState }

The environment values to set at runtime.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) BypassTempDirValidation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) BypassTempDirValidation() pulumi.BoolPtrOutput

Whether to bypass the safety checks for the job's temporary directory. Use with caution.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) IpConfiguration() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) MachineType 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Network 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Zone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput
}

GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput is an input type that accepts GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs, GoogleCloudDatapipelinesV1RuntimeEnvironmentPtr and GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput` via: 

        GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1RuntimeEnvironmentPtr 

func GoogleCloudDatapipelinesV1RuntimeEnvironmentPtr(v *GoogleCloudDatapipelinesV1RuntimeEnvironmentArgs) GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrInput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) BypassTempDirValidation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) BypassTempDirValidation() pulumi.BoolPtrOutput

Whether to bypass the safety checks for the job's temporary directory. Use with caution.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Elem() GoogleCloudDatapipelinesV1RuntimeEnvironmentOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) IpConfiguration() GoogleCloudDatapipelinesV1RuntimeEnvironmentIpConfigurationPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) MachineType 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Network 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Zone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentPtrOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponse 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponse struct {
	// Additional experiment flags for the job.
	AdditionalExperiments []string `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
	AdditionalUserLabels map[string]string `pulumi:"additionalUserLabels"`
	// Whether to bypass the safety checks for the job's temporary directory. Use with caution.
	BypassTempDirValidation bool `pulumi:"bypassTempDirValidation"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine bool `pulumi:"enableStreamingEngine"`
	// Configuration for VM IPs.
	IpConfiguration string `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName string `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType string `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers int `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network string `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers int `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail string `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork string `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation string `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
	WorkerRegion string `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone string `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone string `pulumi:"zone"`
}

The environment values to set at runtime.

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs struct {
	// Additional experiment flags for the job.
	AdditionalExperiments pulumi.StringArrayInput `pulumi:"additionalExperiments"`
	// Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
	AdditionalUserLabels pulumi.StringMapInput `pulumi:"additionalUserLabels"`
	// Whether to bypass the safety checks for the job's temporary directory. Use with caution.
	BypassTempDirValidation pulumi.BoolInput `pulumi:"bypassTempDirValidation"`
	// Whether to enable Streaming Engine for the job.
	EnableStreamingEngine pulumi.BoolInput `pulumi:"enableStreamingEngine"`
	// Configuration for VM IPs.
	IpConfiguration pulumi.StringInput `pulumi:"ipConfiguration"`
	// Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/
	KmsKeyName pulumi.StringInput `pulumi:"kmsKeyName"`
	// The machine type to use for the job. Defaults to the value from the template if not specified.
	MachineType pulumi.StringInput `pulumi:"machineType"`
	// The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
	MaxWorkers pulumi.IntInput `pulumi:"maxWorkers"`
	// Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
	Network pulumi.StringInput `pulumi:"network"`
	// The initial number of Compute Engine instances for the job.
	NumWorkers pulumi.IntInput `pulumi:"numWorkers"`
	// The email address of the service account to run the job as.
	ServiceAccountEmail pulumi.StringInput `pulumi:"serviceAccountEmail"`
	// Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
	Subnetwork pulumi.StringInput `pulumi:"subnetwork"`
	// The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
	TempLocation pulumi.StringInput `pulumi:"tempLocation"`
	// The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
	WorkerRegion pulumi.StringInput `pulumi:"workerRegion"`
	// The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
	WorkerZone pulumi.StringInput `pulumi:"workerZone"`
	// The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
	Zone pulumi.StringInput `pulumi:"zone"`
}

The environment values to set at runtime.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput
}

GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseInput is an input type that accepts GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs and GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseInput` via: 

GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs{...}

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput struct{ *pulumi.OutputState }

The environment values to set at runtime.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) BypassTempDirValidation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) BypassTempDirValidation() pulumi.BoolOutput

Whether to bypass the safety checks for the job's temporary directory. Use with caution.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) EnableStreamingEngine() pulumi.BoolOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) IpConfiguration() pulumi.StringOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) KmsKeyName() pulumi.StringOutput

Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) MachineType 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) MachineType() pulumi.StringOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) MaxWorkers() pulumi.IntOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Network 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Network() pulumi.StringOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) NumWorkers() pulumi.IntOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ServiceAccountEmail() pulumi.StringOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Subnetwork() pulumi.StringOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) TempLocation() pulumi.StringOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) WorkerRegion() pulumi.StringOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) WorkerZone() pulumi.StringOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Zone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput) Zone() pulumi.StringOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrInput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput
	ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput
}

GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs, GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtr and GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtr 

func GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtr(v *GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseArgs) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrInput

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput 

type GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) AdditionalExperiments 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) AdditionalExperiments() pulumi.StringArrayOutput

Additional experiment flags for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) AdditionalUserLabels 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) AdditionalUserLabels() pulumi.StringMapOutput

Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions) page. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) BypassTempDirValidation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) BypassTempDirValidation() pulumi.BoolPtrOutput

Whether to bypass the safety checks for the job's temporary directory. Use with caution.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponseOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) EnableStreamingEngine 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) EnableStreamingEngine() pulumi.BoolPtrOutput

Whether to enable Streaming Engine for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) IpConfiguration 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) IpConfiguration() pulumi.StringPtrOutput

Configuration for VM IPs.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) KmsKeyName 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) KmsKeyName() pulumi.StringPtrOutput

Name for the Cloud KMS key for the job. The key format is: projects//locations//keyRings//cryptoKeys/

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) MachineType 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) MachineType() pulumi.StringPtrOutput

The machine type to use for the job. Defaults to the value from the template if not specified.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) MaxWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) MaxWorkers() pulumi.IntPtrOutput

The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Network 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Network() pulumi.StringPtrOutput

Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) NumWorkers 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) NumWorkers() pulumi.IntPtrOutput

The initial number of Compute Engine instances for the job.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ServiceAccountEmail 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ServiceAccountEmail() pulumi.StringPtrOutput

The email address of the service account to run the job as.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Subnetwork 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Subnetwork() pulumi.StringPtrOutput

Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) TempLocation 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) TempLocation() pulumi.StringPtrOutput

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput() GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) ToGoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) WorkerRegion 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) WorkerRegion() pulumi.StringPtrOutput

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) WorkerZone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) WorkerZone() pulumi.StringPtrOutput

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.

func (GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Zone 

func (o GoogleCloudDatapipelinesV1RuntimeEnvironmentResponsePtrOutput) Zone() pulumi.StringPtrOutput

The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

type GoogleCloudDatapipelinesV1ScheduleSpec 

type GoogleCloudDatapipelinesV1ScheduleSpec struct {
	// Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.
	Schedule *string `pulumi:"schedule"`
	// Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.
	TimeZone *string `pulumi:"timeZone"`
}

Details of the schedule the pipeline runs on.

type GoogleCloudDatapipelinesV1ScheduleSpecArgs 

type GoogleCloudDatapipelinesV1ScheduleSpecArgs struct {
	// Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.
	Schedule pulumi.StringPtrInput `pulumi:"schedule"`
	// Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.
	TimeZone pulumi.StringPtrInput `pulumi:"timeZone"`
}

Details of the schedule the pipeline runs on.

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecOutput 

func (i GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecOutput() GoogleCloudDatapipelinesV1ScheduleSpecOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecOutputWithContext 

func (i GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput 

func (i GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1ScheduleSpecArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

type GoogleCloudDatapipelinesV1ScheduleSpecInput 

type GoogleCloudDatapipelinesV1ScheduleSpecInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1ScheduleSpecOutput() GoogleCloudDatapipelinesV1ScheduleSpecOutput
	ToGoogleCloudDatapipelinesV1ScheduleSpecOutputWithContext(context.Context) GoogleCloudDatapipelinesV1ScheduleSpecOutput
}

GoogleCloudDatapipelinesV1ScheduleSpecInput is an input type that accepts GoogleCloudDatapipelinesV1ScheduleSpecArgs and GoogleCloudDatapipelinesV1ScheduleSpecOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1ScheduleSpecInput` via: 

GoogleCloudDatapipelinesV1ScheduleSpecArgs{...}

type GoogleCloudDatapipelinesV1ScheduleSpecOutput 

type GoogleCloudDatapipelinesV1ScheduleSpecOutput struct{ *pulumi.OutputState }

Details of the schedule the pipeline runs on.

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) Schedule 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) Schedule() pulumi.StringPtrOutput

Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) TimeZone 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) TimeZone() pulumi.StringPtrOutput

Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecOutput() GoogleCloudDatapipelinesV1ScheduleSpecOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

type GoogleCloudDatapipelinesV1ScheduleSpecPtrInput 

type GoogleCloudDatapipelinesV1ScheduleSpecPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput
	ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput
}

GoogleCloudDatapipelinesV1ScheduleSpecPtrInput is an input type that accepts GoogleCloudDatapipelinesV1ScheduleSpecArgs, GoogleCloudDatapipelinesV1ScheduleSpecPtr and GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1ScheduleSpecPtrInput` via: 

        GoogleCloudDatapipelinesV1ScheduleSpecArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1ScheduleSpecPtr 

func GoogleCloudDatapipelinesV1ScheduleSpecPtr(v *GoogleCloudDatapipelinesV1ScheduleSpecArgs) GoogleCloudDatapipelinesV1ScheduleSpecPtrInput

type GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput 

type GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) Elem() GoogleCloudDatapipelinesV1ScheduleSpecOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) Schedule 

func (o GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) Schedule() pulumi.StringPtrOutput

Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) TimeZone 

func (o GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) TimeZone() pulumi.StringPtrOutput

Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecPtrOutput

type GoogleCloudDatapipelinesV1ScheduleSpecResponse 

type GoogleCloudDatapipelinesV1ScheduleSpecResponse struct {
	// When the next Scheduler job is going to run.
	NextJobTime string `pulumi:"nextJobTime"`
	// Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.
	Schedule string `pulumi:"schedule"`
	// Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.
	TimeZone string `pulumi:"timeZone"`
}

Details of the schedule the pipeline runs on.

type GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs 

type GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs struct {
	// When the next Scheduler job is going to run.
	NextJobTime pulumi.StringInput `pulumi:"nextJobTime"`
	// Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.
	Schedule pulumi.StringInput `pulumi:"schedule"`
	// Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.
	TimeZone pulumi.StringInput `pulumi:"timeZone"`
}

Details of the schedule the pipeline runs on.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutput 

func (i GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

type GoogleCloudDatapipelinesV1ScheduleSpecResponseInput 

type GoogleCloudDatapipelinesV1ScheduleSpecResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput
	ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput
}

GoogleCloudDatapipelinesV1ScheduleSpecResponseInput is an input type that accepts GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs and GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1ScheduleSpecResponseInput` via: 

GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs{...}

type GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput 

type GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput struct{ *pulumi.OutputState }

Details of the schedule the pipeline runs on.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) NextJobTime 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) NextJobTime() pulumi.StringOutput

When the next Scheduler job is going to run.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) Schedule 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) Schedule() pulumi.StringOutput

Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) TimeZone 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) TimeZone() pulumi.StringOutput

Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

type GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrInput 

type GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput
	ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput
}

GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs, GoogleCloudDatapipelinesV1ScheduleSpecResponsePtr and GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1ScheduleSpecResponsePtr 

func GoogleCloudDatapipelinesV1ScheduleSpecResponsePtr(v *GoogleCloudDatapipelinesV1ScheduleSpecResponseArgs) GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrInput

type GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput 

type GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) NextJobTime 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) NextJobTime() pulumi.StringPtrOutput

When the next Scheduler job is going to run.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) Schedule 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) Schedule() pulumi.StringPtrOutput

Unix-cron format of the schedule. This information is retrieved from the linked Cloud Scheduler.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) TimeZone 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) TimeZone() pulumi.StringPtrOutput

Timezone ID. This matches the timezone IDs used by the Cloud Scheduler API. If empty, UTC time is assumed.

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput() GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

func (GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput) ToGoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1ScheduleSpecResponsePtrOutput

type GoogleCloudDatapipelinesV1Workload 

type GoogleCloudDatapipelinesV1Workload struct {
	// Template information and additional parameters needed to launch a Dataflow job using the flex launch API.
	DataflowFlexTemplateRequest *GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest `pulumi:"dataflowFlexTemplateRequest"`
	// Template information and additional parameters needed to launch a Dataflow job using the standard launch API.
	DataflowLaunchTemplateRequest *GoogleCloudDatapipelinesV1LaunchTemplateRequest `pulumi:"dataflowLaunchTemplateRequest"`
}

Workload details for creating the pipeline jobs.

type GoogleCloudDatapipelinesV1WorkloadArgs 

type GoogleCloudDatapipelinesV1WorkloadArgs struct {
	// Template information and additional parameters needed to launch a Dataflow job using the flex launch API.
	DataflowFlexTemplateRequest GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrInput `pulumi:"dataflowFlexTemplateRequest"`
	// Template information and additional parameters needed to launch a Dataflow job using the standard launch API.
	DataflowLaunchTemplateRequest GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrInput `pulumi:"dataflowLaunchTemplateRequest"`
}

Workload details for creating the pipeline jobs.

func (GoogleCloudDatapipelinesV1WorkloadArgs) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadOutput 

func (i GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadOutput() GoogleCloudDatapipelinesV1WorkloadOutput

func (GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadOutputWithContext 

func (i GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadOutput

func (GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput 

func (i GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput() GoogleCloudDatapipelinesV1WorkloadPtrOutput

func (GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1WorkloadArgs) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadPtrOutput

type GoogleCloudDatapipelinesV1WorkloadInput 

type GoogleCloudDatapipelinesV1WorkloadInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1WorkloadOutput() GoogleCloudDatapipelinesV1WorkloadOutput
	ToGoogleCloudDatapipelinesV1WorkloadOutputWithContext(context.Context) GoogleCloudDatapipelinesV1WorkloadOutput
}

GoogleCloudDatapipelinesV1WorkloadInput is an input type that accepts GoogleCloudDatapipelinesV1WorkloadArgs and GoogleCloudDatapipelinesV1WorkloadOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1WorkloadInput` via: 

GoogleCloudDatapipelinesV1WorkloadArgs{...}

type GoogleCloudDatapipelinesV1WorkloadOutput 

type GoogleCloudDatapipelinesV1WorkloadOutput struct{ *pulumi.OutputState }

Workload details for creating the pipeline jobs.

func (GoogleCloudDatapipelinesV1WorkloadOutput) DataflowFlexTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) DataflowFlexTemplateRequest() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

Template information and additional parameters needed to launch a Dataflow job using the flex launch API.

func (GoogleCloudDatapipelinesV1WorkloadOutput) DataflowLaunchTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) DataflowLaunchTemplateRequest() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

Template information and additional parameters needed to launch a Dataflow job using the standard launch API.

func (GoogleCloudDatapipelinesV1WorkloadOutput) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadOutput 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadOutput() GoogleCloudDatapipelinesV1WorkloadOutput

func (GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadOutput

func (GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput() GoogleCloudDatapipelinesV1WorkloadPtrOutput

func (GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadPtrOutput

type GoogleCloudDatapipelinesV1WorkloadPtrInput 

type GoogleCloudDatapipelinesV1WorkloadPtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1WorkloadPtrOutput() GoogleCloudDatapipelinesV1WorkloadPtrOutput
	ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1WorkloadPtrOutput
}

GoogleCloudDatapipelinesV1WorkloadPtrInput is an input type that accepts GoogleCloudDatapipelinesV1WorkloadArgs, GoogleCloudDatapipelinesV1WorkloadPtr and GoogleCloudDatapipelinesV1WorkloadPtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1WorkloadPtrInput` via: 

        GoogleCloudDatapipelinesV1WorkloadArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1WorkloadPtr 

func GoogleCloudDatapipelinesV1WorkloadPtr(v *GoogleCloudDatapipelinesV1WorkloadArgs) GoogleCloudDatapipelinesV1WorkloadPtrInput

type GoogleCloudDatapipelinesV1WorkloadPtrOutput 

type GoogleCloudDatapipelinesV1WorkloadPtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) DataflowFlexTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadPtrOutput) DataflowFlexTemplateRequest() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestPtrOutput

Template information and additional parameters needed to launch a Dataflow job using the flex launch API.

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) DataflowLaunchTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadPtrOutput) DataflowLaunchTemplateRequest() GoogleCloudDatapipelinesV1LaunchTemplateRequestPtrOutput

Template information and additional parameters needed to launch a Dataflow job using the standard launch API.

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1WorkloadPtrOutput) Elem() GoogleCloudDatapipelinesV1WorkloadOutput

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput 

func (o GoogleCloudDatapipelinesV1WorkloadPtrOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutput() GoogleCloudDatapipelinesV1WorkloadPtrOutput

func (GoogleCloudDatapipelinesV1WorkloadPtrOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadPtrOutput) ToGoogleCloudDatapipelinesV1WorkloadPtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadPtrOutput

type GoogleCloudDatapipelinesV1WorkloadResponse 

type GoogleCloudDatapipelinesV1WorkloadResponse struct {
	// Template information and additional parameters needed to launch a Dataflow job using the flex launch API.
	DataflowFlexTemplateRequest GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponse `pulumi:"dataflowFlexTemplateRequest"`
	// Template information and additional parameters needed to launch a Dataflow job using the standard launch API.
	DataflowLaunchTemplateRequest GoogleCloudDatapipelinesV1LaunchTemplateRequestResponse `pulumi:"dataflowLaunchTemplateRequest"`
}

Workload details for creating the pipeline jobs.

type GoogleCloudDatapipelinesV1WorkloadResponseArgs 

type GoogleCloudDatapipelinesV1WorkloadResponseArgs struct {
	// Template information and additional parameters needed to launch a Dataflow job using the flex launch API.
	DataflowFlexTemplateRequest GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseInput `pulumi:"dataflowFlexTemplateRequest"`
	// Template information and additional parameters needed to launch a Dataflow job using the standard launch API.
	DataflowLaunchTemplateRequest GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseInput `pulumi:"dataflowLaunchTemplateRequest"`
}

Workload details for creating the pipeline jobs.

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponseOutput 

func (i GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponseOutput() GoogleCloudDatapipelinesV1WorkloadResponseOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponseOutputWithContext 

func (i GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadResponseOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput 

func (i GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput() GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext 

func (i GoogleCloudDatapipelinesV1WorkloadResponseArgs) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

type GoogleCloudDatapipelinesV1WorkloadResponseInput 

type GoogleCloudDatapipelinesV1WorkloadResponseInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1WorkloadResponseOutput() GoogleCloudDatapipelinesV1WorkloadResponseOutput
	ToGoogleCloudDatapipelinesV1WorkloadResponseOutputWithContext(context.Context) GoogleCloudDatapipelinesV1WorkloadResponseOutput
}

GoogleCloudDatapipelinesV1WorkloadResponseInput is an input type that accepts GoogleCloudDatapipelinesV1WorkloadResponseArgs and GoogleCloudDatapipelinesV1WorkloadResponseOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1WorkloadResponseInput` via: 

GoogleCloudDatapipelinesV1WorkloadResponseArgs{...}

type GoogleCloudDatapipelinesV1WorkloadResponseOutput 

type GoogleCloudDatapipelinesV1WorkloadResponseOutput struct{ *pulumi.OutputState }

Workload details for creating the pipeline jobs.

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) DataflowFlexTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) DataflowFlexTemplateRequest() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponseOutput

Template information and additional parameters needed to launch a Dataflow job using the flex launch API.

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) DataflowLaunchTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) DataflowLaunchTemplateRequest() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponseOutput

Template information and additional parameters needed to launch a Dataflow job using the standard launch API.

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponseOutput 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponseOutput() GoogleCloudDatapipelinesV1WorkloadResponseOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponseOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponseOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadResponseOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput() GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

func (GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadResponseOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

type GoogleCloudDatapipelinesV1WorkloadResponsePtrInput 

type GoogleCloudDatapipelinesV1WorkloadResponsePtrInput interface {
	pulumi.Input

	ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput() GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput
	ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext(context.Context) GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput
}

GoogleCloudDatapipelinesV1WorkloadResponsePtrInput is an input type that accepts GoogleCloudDatapipelinesV1WorkloadResponseArgs, GoogleCloudDatapipelinesV1WorkloadResponsePtr and GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput values. You can construct a concrete instance of `GoogleCloudDatapipelinesV1WorkloadResponsePtrInput` via: 

        GoogleCloudDatapipelinesV1WorkloadResponseArgs{...}

or:

        nil

func GoogleCloudDatapipelinesV1WorkloadResponsePtr 

func GoogleCloudDatapipelinesV1WorkloadResponsePtr(v *GoogleCloudDatapipelinesV1WorkloadResponseArgs) GoogleCloudDatapipelinesV1WorkloadResponsePtrInput

type GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput 

type GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput struct{ *pulumi.OutputState }

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) DataflowFlexTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) DataflowFlexTemplateRequest() GoogleCloudDatapipelinesV1LaunchFlexTemplateRequestResponsePtrOutput

Template information and additional parameters needed to launch a Dataflow job using the flex launch API.

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) DataflowLaunchTemplateRequest 

func (o GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) DataflowLaunchTemplateRequest() GoogleCloudDatapipelinesV1LaunchTemplateRequestResponsePtrOutput

Template information and additional parameters needed to launch a Dataflow job using the standard launch API.

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) Elem 

func (o GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) Elem() GoogleCloudDatapipelinesV1WorkloadResponseOutput

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ElementType 

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ElementType() reflect.Type

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput 

func (o GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutput() GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

func (GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext 

func (o GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput) ToGoogleCloudDatapipelinesV1WorkloadResponsePtrOutputWithContext(ctx context.Context) GoogleCloudDatapipelinesV1WorkloadResponsePtrOutput

type LookupPipelineArgs 

type LookupPipelineArgs struct {
	Location   string  `pulumi:"location"`
	PipelineId string  `pulumi:"pipelineId"`
	Project    *string `pulumi:"project"`
}

type LookupPipelineOutputArgs 

type LookupPipelineOutputArgs struct {
	Location   pulumi.StringInput    `pulumi:"location"`
	PipelineId pulumi.StringInput    `pulumi:"pipelineId"`
	Project    pulumi.StringPtrInput `pulumi:"project"`
}

func (LookupPipelineOutputArgs) ElementType 

func (LookupPipelineOutputArgs) ElementType() reflect.Type

type LookupPipelineResult 

type LookupPipelineResult struct {
	// Immutable. The timestamp when the pipeline was initially created. Set by the Data Pipelines service.
	CreateTime string `pulumi:"createTime"`
	// The display name of the pipeline. It can contain only letters ([A-Za-z]), numbers ([0-9]), hyphens (-), and underscores (_).
	DisplayName string `pulumi:"displayName"`
	// Number of jobs.
	JobCount int `pulumi:"jobCount"`
	// Immutable. The timestamp when the pipeline was last modified. Set by the Data Pipelines service.
	LastUpdateTime string `pulumi:"lastUpdateTime"`
	// 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](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) * `LOCATION_ID` is the canonical ID for the pipeline's location. The list of available locations can be obtained by calling 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](https://cloud.google.com/about/locations#region). * `PIPELINE_ID` is the ID of the pipeline. Must be unique for the selected project and location.
	Name string `pulumi:"name"`
	// Immutable. The sources of the pipeline (for example, Dataplex). The keys and values are set by the corresponding sources during pipeline creation.
	PipelineSources map[string]string `pulumi:"pipelineSources"`
	// 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.
	ScheduleInfo GoogleCloudDatapipelinesV1ScheduleSpecResponse `pulumi:"scheduleInfo"`
	// 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.
	SchedulerServiceAccountEmail string `pulumi:"schedulerServiceAccountEmail"`
	// 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.
	State string `pulumi:"state"`
	// The type of the pipeline. This field affects the scheduling of the pipeline and the type of metrics to show for the pipeline.
	Type string `pulumi:"type"`
	// Workload information for creating new jobs.
	Workload GoogleCloudDatapipelinesV1WorkloadResponse `pulumi:"workload"`
}

func LookupPipeline 

func LookupPipeline(ctx *pulumi.Context, args *LookupPipelineArgs, opts ...pulumi.InvokeOption) (*LookupPipelineResult, error)

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.

type LookupPipelineResultOutput 

type LookupPipelineResultOutput struct{ *pulumi.OutputState }

func LookupPipelineOutput 

func LookupPipelineOutput(ctx *pulumi.Context, args LookupPipelineOutputArgs, opts ...pulumi.InvokeOption) LookupPipelineResultOutput

func (LookupPipelineResultOutput) CreateTime 

func (o LookupPipelineResultOutput) CreateTime() pulumi.StringOutput

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

func (LookupPipelineResultOutput) DisplayName 

func (o LookupPipelineResultOutput) DisplayName() pulumi.StringOutput

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

func (LookupPipelineResultOutput) ElementType 

func (LookupPipelineResultOutput) ElementType() reflect.Type

func (LookupPipelineResultOutput) JobCount 

func (o LookupPipelineResultOutput) JobCount() pulumi.IntOutput

Number of jobs.

func (LookupPipelineResultOutput) LastUpdateTime 

func (o LookupPipelineResultOutput) LastUpdateTime() pulumi.StringOutput

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

func (LookupPipelineResultOutput) Name 

func (o LookupPipelineResultOutput) Name() pulumi.StringOutput

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](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) * `LOCATION_ID` is the canonical ID for the pipeline's location. The list of available locations can be obtained by calling 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](https://cloud.google.com/about/locations#region). * `PIPELINE_ID` is the ID of the pipeline. Must be unique for the selected project and location.

func (LookupPipelineResultOutput) PipelineSources 

func (o LookupPipelineResultOutput) PipelineSources() pulumi.StringMapOutput

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

func (LookupPipelineResultOutput) ScheduleInfo 

func (o LookupPipelineResultOutput) ScheduleInfo() GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput

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.

func (LookupPipelineResultOutput) SchedulerServiceAccountEmail 

func (o LookupPipelineResultOutput) SchedulerServiceAccountEmail() pulumi.StringOutput

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.

func (LookupPipelineResultOutput) State 

func (o LookupPipelineResultOutput) State() pulumi.StringOutput

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.

func (LookupPipelineResultOutput) ToLookupPipelineResultOutput 

func (o LookupPipelineResultOutput) ToLookupPipelineResultOutput() LookupPipelineResultOutput

func (LookupPipelineResultOutput) ToLookupPipelineResultOutputWithContext 

func (o LookupPipelineResultOutput) ToLookupPipelineResultOutputWithContext(ctx context.Context) LookupPipelineResultOutput

func (LookupPipelineResultOutput) Type 

func (o LookupPipelineResultOutput) Type() pulumi.StringOutput

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

func (LookupPipelineResultOutput) Workload 

func (o LookupPipelineResultOutput) Workload() GoogleCloudDatapipelinesV1WorkloadResponseOutput

Workload information for creating new jobs.

type Pipeline 

type Pipeline struct {
	pulumi.CustomResourceState

	// Immutable. The timestamp when the pipeline was initially created. Set by the Data Pipelines service.
	CreateTime pulumi.StringOutput `pulumi:"createTime"`
	// The display name of the pipeline. It can contain only letters ([A-Za-z]), numbers ([0-9]), hyphens (-), and underscores (_).
	DisplayName pulumi.StringOutput `pulumi:"displayName"`
	// Number of jobs.
	JobCount pulumi.IntOutput `pulumi:"jobCount"`
	// Immutable. The timestamp when the pipeline was last modified. Set by the Data Pipelines service.
	LastUpdateTime pulumi.StringOutput `pulumi:"lastUpdateTime"`
	// 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](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) * `LOCATION_ID` is the canonical ID for the pipeline's location. The list of available locations can be obtained by calling 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](https://cloud.google.com/about/locations#region). * `PIPELINE_ID` is the ID of the pipeline. Must be unique for the selected project and location.
	Name pulumi.StringOutput `pulumi:"name"`
	// Immutable. The sources of the pipeline (for example, Dataplex). The keys and values are set by the corresponding sources during pipeline creation.
	PipelineSources pulumi.StringMapOutput `pulumi:"pipelineSources"`
	// 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.
	ScheduleInfo GoogleCloudDatapipelinesV1ScheduleSpecResponseOutput `pulumi:"scheduleInfo"`
	// 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.
	SchedulerServiceAccountEmail pulumi.StringOutput `pulumi:"schedulerServiceAccountEmail"`
	// 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.
	State pulumi.StringOutput `pulumi:"state"`
	// The type of the pipeline. This field affects the scheduling of the pipeline and the type of metrics to show for the pipeline.
	Type pulumi.StringOutput `pulumi:"type"`
	// Workload information for creating new jobs.
	Workload GoogleCloudDatapipelinesV1WorkloadResponseOutput `pulumi:"workload"`
}

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.

func GetPipeline 

func GetPipeline(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *PipelineState, opts ...pulumi.ResourceOption) (*Pipeline, error)

GetPipeline gets an existing Pipeline resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewPipeline 

func NewPipeline(ctx *pulumi.Context,
	name string, args *PipelineArgs, opts ...pulumi.ResourceOption) (*Pipeline, error)

NewPipeline registers a new resource with the given unique name, arguments, and options.

func (*Pipeline) ElementType 

func (*Pipeline) ElementType() reflect.Type

func (*Pipeline) ToPipelineOutput 

func (i *Pipeline) ToPipelineOutput() PipelineOutput

func (*Pipeline) ToPipelineOutputWithContext 

func (i *Pipeline) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput

type PipelineArgs 

type PipelineArgs struct {
	// The display name of the pipeline. It can contain only letters ([A-Za-z]), numbers ([0-9]), hyphens (-), and underscores (_).
	DisplayName pulumi.StringInput
	Location    pulumi.StringPtrInput
	// 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](https://cloud.google.com/resource-manager/docs/creating-managing-projects#identifying_projects) * `LOCATION_ID` is the canonical ID for the pipeline's location. The list of available locations can be obtained by calling 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](https://cloud.google.com/about/locations#region). * `PIPELINE_ID` is the ID of the pipeline. Must be unique for the selected project and location.
	Name pulumi.StringPtrInput
	// Immutable. The sources of the pipeline (for example, Dataplex). The keys and values are set by the corresponding sources during pipeline creation.
	PipelineSources pulumi.StringMapInput
	Project         pulumi.StringPtrInput
	// 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.
	ScheduleInfo GoogleCloudDatapipelinesV1ScheduleSpecPtrInput
	// 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.
	SchedulerServiceAccountEmail pulumi.StringPtrInput
	// 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.
	State PipelineStateEnumInput
	// The type of the pipeline. This field affects the scheduling of the pipeline and the type of metrics to show for the pipeline.
	Type PipelineTypeInput
	// Workload information for creating new jobs.
	Workload GoogleCloudDatapipelinesV1WorkloadPtrInput
}

The set of arguments for constructing a Pipeline resource.

func (PipelineArgs) ElementType 

func (PipelineArgs) ElementType() reflect.Type

type PipelineInput 

type PipelineInput interface {
	pulumi.Input

	ToPipelineOutput() PipelineOutput
	ToPipelineOutputWithContext(ctx context.Context) PipelineOutput
}

type PipelineOutput 

type PipelineOutput struct{ *pulumi.OutputState }

func (PipelineOutput) ElementType 

func (PipelineOutput) ElementType() reflect.Type

func (PipelineOutput) ToPipelineOutput 

func (o PipelineOutput) ToPipelineOutput() PipelineOutput

func (PipelineOutput) ToPipelineOutputWithContext 

func (o PipelineOutput) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput

type PipelineState 

type PipelineState struct {
}

func (PipelineState) ElementType 

func (PipelineState) ElementType() reflect.Type

type PipelineStateEnum 

type PipelineStateEnum 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.

func (PipelineStateEnum) ElementType 

func (PipelineStateEnum) ElementType() reflect.Type

func (PipelineStateEnum) ToPipelineStateEnumOutput 

func (e PipelineStateEnum) ToPipelineStateEnumOutput() PipelineStateEnumOutput

func (PipelineStateEnum) ToPipelineStateEnumOutputWithContext 

func (e PipelineStateEnum) ToPipelineStateEnumOutputWithContext(ctx context.Context) PipelineStateEnumOutput

func (PipelineStateEnum) ToPipelineStateEnumPtrOutput 

func (e PipelineStateEnum) ToPipelineStateEnumPtrOutput() PipelineStateEnumPtrOutput

func (PipelineStateEnum) ToPipelineStateEnumPtrOutputWithContext 

func (e PipelineStateEnum) ToPipelineStateEnumPtrOutputWithContext(ctx context.Context) PipelineStateEnumPtrOutput

func (PipelineStateEnum) ToStringOutput 

func (e PipelineStateEnum) ToStringOutput() pulumi.StringOutput

func (PipelineStateEnum) ToStringOutputWithContext 

func (e PipelineStateEnum) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (PipelineStateEnum) ToStringPtrOutput 

func (e PipelineStateEnum) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineStateEnum) ToStringPtrOutputWithContext 

func (e PipelineStateEnum) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type PipelineStateEnumInput 

type PipelineStateEnumInput interface {
	pulumi.Input

	ToPipelineStateEnumOutput() PipelineStateEnumOutput
	ToPipelineStateEnumOutputWithContext(context.Context) PipelineStateEnumOutput
}

PipelineStateEnumInput is an input type that accepts PipelineStateEnumArgs and PipelineStateEnumOutput values. You can construct a concrete instance of `PipelineStateEnumInput` via: 

PipelineStateEnumArgs{...}

type PipelineStateEnumOutput 

type PipelineStateEnumOutput struct{ *pulumi.OutputState }

func (PipelineStateEnumOutput) ElementType 

func (PipelineStateEnumOutput) ElementType() reflect.Type

func (PipelineStateEnumOutput) ToPipelineStateEnumOutput 

func (o PipelineStateEnumOutput) ToPipelineStateEnumOutput() PipelineStateEnumOutput

func (PipelineStateEnumOutput) ToPipelineStateEnumOutputWithContext 

func (o PipelineStateEnumOutput) ToPipelineStateEnumOutputWithContext(ctx context.Context) PipelineStateEnumOutput

func (PipelineStateEnumOutput) ToPipelineStateEnumPtrOutput 

func (o PipelineStateEnumOutput) ToPipelineStateEnumPtrOutput() PipelineStateEnumPtrOutput

func (PipelineStateEnumOutput) ToPipelineStateEnumPtrOutputWithContext 

func (o PipelineStateEnumOutput) ToPipelineStateEnumPtrOutputWithContext(ctx context.Context) PipelineStateEnumPtrOutput

func (PipelineStateEnumOutput) ToStringOutput 

func (o PipelineStateEnumOutput) ToStringOutput() pulumi.StringOutput

func (PipelineStateEnumOutput) ToStringOutputWithContext 

func (o PipelineStateEnumOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (PipelineStateEnumOutput) ToStringPtrOutput 

func (o PipelineStateEnumOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineStateEnumOutput) ToStringPtrOutputWithContext 

func (o PipelineStateEnumOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type PipelineStateEnumPtrInput 

type PipelineStateEnumPtrInput interface {
	pulumi.Input

	ToPipelineStateEnumPtrOutput() PipelineStateEnumPtrOutput
	ToPipelineStateEnumPtrOutputWithContext(context.Context) PipelineStateEnumPtrOutput
}

func PipelineStateEnumPtr 

func PipelineStateEnumPtr(v string) PipelineStateEnumPtrInput

type PipelineStateEnumPtrOutput 

type PipelineStateEnumPtrOutput struct{ *pulumi.OutputState }

func (PipelineStateEnumPtrOutput) Elem 

func (o PipelineStateEnumPtrOutput) Elem() PipelineStateEnumOutput

func (PipelineStateEnumPtrOutput) ElementType 

func (PipelineStateEnumPtrOutput) ElementType() reflect.Type

func (PipelineStateEnumPtrOutput) ToPipelineStateEnumPtrOutput 

func (o PipelineStateEnumPtrOutput) ToPipelineStateEnumPtrOutput() PipelineStateEnumPtrOutput

func (PipelineStateEnumPtrOutput) ToPipelineStateEnumPtrOutputWithContext 

func (o PipelineStateEnumPtrOutput) ToPipelineStateEnumPtrOutputWithContext(ctx context.Context) PipelineStateEnumPtrOutput

func (PipelineStateEnumPtrOutput) ToStringPtrOutput 

func (o PipelineStateEnumPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineStateEnumPtrOutput) ToStringPtrOutputWithContext 

func (o PipelineStateEnumPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type PipelineType 

type PipelineType 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.

func (PipelineType) ElementType 

func (PipelineType) ElementType() reflect.Type

func (PipelineType) ToPipelineTypeOutput 

func (e PipelineType) ToPipelineTypeOutput() PipelineTypeOutput

func (PipelineType) ToPipelineTypeOutputWithContext 

func (e PipelineType) ToPipelineTypeOutputWithContext(ctx context.Context) PipelineTypeOutput

func (PipelineType) ToPipelineTypePtrOutput 

func (e PipelineType) ToPipelineTypePtrOutput() PipelineTypePtrOutput

func (PipelineType) ToPipelineTypePtrOutputWithContext 

func (e PipelineType) ToPipelineTypePtrOutputWithContext(ctx context.Context) PipelineTypePtrOutput

func (PipelineType) ToStringOutput 

func (e PipelineType) ToStringOutput() pulumi.StringOutput

func (PipelineType) ToStringOutputWithContext 

func (e PipelineType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (PipelineType) ToStringPtrOutput 

func (e PipelineType) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineType) ToStringPtrOutputWithContext 

func (e PipelineType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type PipelineTypeInput 

type PipelineTypeInput interface {
	pulumi.Input

	ToPipelineTypeOutput() PipelineTypeOutput
	ToPipelineTypeOutputWithContext(context.Context) PipelineTypeOutput
}

PipelineTypeInput is an input type that accepts PipelineTypeArgs and PipelineTypeOutput values. You can construct a concrete instance of `PipelineTypeInput` via: 

PipelineTypeArgs{...}

type PipelineTypeOutput 

type PipelineTypeOutput struct{ *pulumi.OutputState }

func (PipelineTypeOutput) ElementType 

func (PipelineTypeOutput) ElementType() reflect.Type

func (PipelineTypeOutput) ToPipelineTypeOutput 

func (o PipelineTypeOutput) ToPipelineTypeOutput() PipelineTypeOutput

func (PipelineTypeOutput) ToPipelineTypeOutputWithContext 

func (o PipelineTypeOutput) ToPipelineTypeOutputWithContext(ctx context.Context) PipelineTypeOutput

func (PipelineTypeOutput) ToPipelineTypePtrOutput 

func (o PipelineTypeOutput) ToPipelineTypePtrOutput() PipelineTypePtrOutput

func (PipelineTypeOutput) ToPipelineTypePtrOutputWithContext 

func (o PipelineTypeOutput) ToPipelineTypePtrOutputWithContext(ctx context.Context) PipelineTypePtrOutput

func (PipelineTypeOutput) ToStringOutput 

func (o PipelineTypeOutput) ToStringOutput() pulumi.StringOutput

func (PipelineTypeOutput) ToStringOutputWithContext 

func (o PipelineTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (PipelineTypeOutput) ToStringPtrOutput 

func (o PipelineTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineTypeOutput) ToStringPtrOutputWithContext 

func (o PipelineTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type PipelineTypePtrInput 

type PipelineTypePtrInput interface {
	pulumi.Input

	ToPipelineTypePtrOutput() PipelineTypePtrOutput
	ToPipelineTypePtrOutputWithContext(context.Context) PipelineTypePtrOutput
}

func PipelineTypePtr 

func PipelineTypePtr(v string) PipelineTypePtrInput

type PipelineTypePtrOutput 

type PipelineTypePtrOutput struct{ *pulumi.OutputState }

func (PipelineTypePtrOutput) Elem 

func (o PipelineTypePtrOutput) Elem() PipelineTypeOutput

func (PipelineTypePtrOutput) ElementType 

func (PipelineTypePtrOutput) ElementType() reflect.Type

func (PipelineTypePtrOutput) ToPipelineTypePtrOutput 

func (o PipelineTypePtrOutput) ToPipelineTypePtrOutput() PipelineTypePtrOutput

func (PipelineTypePtrOutput) ToPipelineTypePtrOutputWithContext 

func (o PipelineTypePtrOutput) ToPipelineTypePtrOutputWithContext(ctx context.Context) PipelineTypePtrOutput

func (PipelineTypePtrOutput) ToStringPtrOutput 

func (o PipelineTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (PipelineTypePtrOutput) ToStringPtrOutputWithContext 

func (o PipelineTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.