datafusion

package
v7.20.0 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GetInstanceIamPolicyArgs 

type GetInstanceIamPolicyArgs struct {
	// Used to find the parent resource to bind the IAM policy to
	Name string `pulumi:"name"`
	// The ID of the project in which the resource belongs.
	// If it is not provided, the project will be parsed from the identifier of the parent resource. If no project is provided in the parent identifier and no project is specified, the provider project is used.
	Project *string `pulumi:"project"`
	// The region of the Data Fusion instance.
	// Used to find the parent resource to bind the IAM policy to. If not specified,
	// the value will be parsed from the identifier of the parent resource. If no region is provided in the parent identifier and no
	// region is specified, it is taken from the provider configuration.
	Region *string `pulumi:"region"`
}

A collection of arguments for invoking getInstanceIamPolicy.

type GetInstanceIamPolicyOutputArgs 

type GetInstanceIamPolicyOutputArgs struct {
	// Used to find the parent resource to bind the IAM policy to
	Name pulumi.StringInput `pulumi:"name"`
	// The ID of the project in which the resource belongs.
	// If it is not provided, the project will be parsed from the identifier of the parent resource. If no project is provided in the parent identifier and no project is specified, the provider project is used.
	Project pulumi.StringPtrInput `pulumi:"project"`
	// The region of the Data Fusion instance.
	// Used to find the parent resource to bind the IAM policy to. If not specified,
	// the value will be parsed from the identifier of the parent resource. If no region is provided in the parent identifier and no
	// region is specified, it is taken from the provider configuration.
	Region pulumi.StringPtrInput `pulumi:"region"`
}

A collection of arguments for invoking getInstanceIamPolicy.

func (GetInstanceIamPolicyOutputArgs) ElementType 

func (GetInstanceIamPolicyOutputArgs) ElementType() reflect.Type

type GetInstanceIamPolicyResult 

type GetInstanceIamPolicyResult struct {
	// (Computed) The etag of the IAM policy.
	Etag string `pulumi:"etag"`
	// The provider-assigned unique ID for this managed resource.
	Id   string `pulumi:"id"`
	Name string `pulumi:"name"`
	// (Required only by `securitycenter.InstanceIamPolicy`) The policy data generated by
	// a `organizations.getIAMPolicy` data source.
	PolicyData string `pulumi:"policyData"`
	Project    string `pulumi:"project"`
	Region     string `pulumi:"region"`
}

A collection of values returned by getInstanceIamPolicy.

func GetInstanceIamPolicy 

func GetInstanceIamPolicy(ctx *pulumi.Context, args *GetInstanceIamPolicyArgs, opts ...pulumi.InvokeOption) (*GetInstanceIamPolicyResult, error)

Retrieves the current IAM policy data for instance

## example

```go package main

import ( 

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafusion.GetInstanceIamPolicy(ctx, &datafusion.GetInstanceIamPolicyArgs{
			Project: pulumi.StringRef(basicInstance.Project),
			Region:  pulumi.StringRef(basicInstance.Region),
			Name:    basicInstance.Name,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetInstanceIamPolicyResultOutput 

type GetInstanceIamPolicyResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getInstanceIamPolicy.

func GetInstanceIamPolicyOutput 

func GetInstanceIamPolicyOutput(ctx *pulumi.Context, args GetInstanceIamPolicyOutputArgs, opts ...pulumi.InvokeOption) GetInstanceIamPolicyResultOutput

func (GetInstanceIamPolicyResultOutput) ElementType 

func (GetInstanceIamPolicyResultOutput) ElementType() reflect.Type

func (GetInstanceIamPolicyResultOutput) Etag 

func (o GetInstanceIamPolicyResultOutput) Etag() pulumi.StringOutput

(Computed) The etag of the IAM policy.

func (GetInstanceIamPolicyResultOutput) Id 

func (o GetInstanceIamPolicyResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetInstanceIamPolicyResultOutput) Name 

func (o GetInstanceIamPolicyResultOutput) Name() pulumi.StringOutput

func (GetInstanceIamPolicyResultOutput) PolicyData 

func (o GetInstanceIamPolicyResultOutput) PolicyData() pulumi.StringOutput

(Required only by `securitycenter.InstanceIamPolicy`) The policy data generated by a `organizations.getIAMPolicy` data source.

func (GetInstanceIamPolicyResultOutput) Project 

func (o GetInstanceIamPolicyResultOutput) Project() pulumi.StringOutput

func (GetInstanceIamPolicyResultOutput) Region 

func (o GetInstanceIamPolicyResultOutput) Region() pulumi.StringOutput

func (GetInstanceIamPolicyResultOutput) ToGetInstanceIamPolicyResultOutput 

func (o GetInstanceIamPolicyResultOutput) ToGetInstanceIamPolicyResultOutput() GetInstanceIamPolicyResultOutput

func (GetInstanceIamPolicyResultOutput) ToGetInstanceIamPolicyResultOutputWithContext 

func (o GetInstanceIamPolicyResultOutput) ToGetInstanceIamPolicyResultOutputWithContext(ctx context.Context) GetInstanceIamPolicyResultOutput

type Instance 

type Instance struct {
	pulumi.CustomResourceState

	// List of accelerators enabled for this CDF instance.
	// If accelerators are enabled it is possible a permadiff will be created with the Options field.
	// Users will need to either manually update their state file to include these diffed options, or include the field in a lifecycle ignore changes block.
	// Structure is documented below.
	Accelerators InstanceAcceleratorArrayOutput `pulumi:"accelerators"`
	// Endpoint on which the REST APIs is accessible.
	ApiEndpoint pulumi.StringOutput `pulumi:"apiEndpoint"`
	// The time the instance was created in RFC3339 UTC "Zulu" format, accurate to nanoseconds.
	CreateTime pulumi.StringOutput `pulumi:"createTime"`
	// The crypto key configuration. This field is used by the Customer-Managed Encryption Keys (CMEK) feature.
	// Structure is documented below.
	CryptoKeyConfig InstanceCryptoKeyConfigPtrOutput `pulumi:"cryptoKeyConfig"`
	// User-managed service account to set on Dataproc when Cloud Data Fusion creates Dataproc to run data processing pipelines.
	DataprocServiceAccount pulumi.StringPtrOutput `pulumi:"dataprocServiceAccount"`
	// An optional description of the instance.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Display name for an instance.
	DisplayName pulumi.StringPtrOutput `pulumi:"displayName"`
	// All of labels (key/value pairs) present on the resource in GCP, including the labels configured through Pulumi, other clients and services.
	EffectiveLabels pulumi.StringMapOutput `pulumi:"effectiveLabels"`
	// Option to enable granular role-based access control.
	EnableRbac pulumi.BoolPtrOutput `pulumi:"enableRbac"`
	// Option to enable Stackdriver Logging.
	EnableStackdriverLogging pulumi.BoolPtrOutput `pulumi:"enableStackdriverLogging"`
	// Option to enable Stackdriver Monitoring.
	EnableStackdriverMonitoring pulumi.BoolPtrOutput `pulumi:"enableStackdriverMonitoring"`
	// Option to enable and pass metadata for event publishing.
	// Structure is documented below.
	EventPublishConfig InstanceEventPublishConfigPtrOutput `pulumi:"eventPublishConfig"`
	// Cloud Storage bucket generated by Data Fusion in the customer project.
	GcsBucket pulumi.StringOutput `pulumi:"gcsBucket"`
	// The resource labels for instance to use to annotate any related underlying resources,
	// such as Compute Engine VMs.
	//
	// **Note**: This field is non-authoritative, and will only manage the labels present in your configuration.
	// Please refer to the field `effectiveLabels` for all of the labels present on the resource.
	Labels pulumi.StringMapOutput `pulumi:"labels"`
	// The ID of the instance or a fully qualified identifier for the instance.
	Name pulumi.StringOutput `pulumi:"name"`
	// Network configuration options. These are required when a private Data Fusion instance is to be created.
	// Structure is documented below.
	NetworkConfig InstanceNetworkConfigPtrOutput `pulumi:"networkConfig"`
	// Map of additional options used to configure the behavior of Data Fusion instance.
	Options pulumi.StringMapOutput `pulumi:"options"`
	// P4 service account for the customer project.
	P4ServiceAccount pulumi.StringOutput `pulumi:"p4ServiceAccount"`
	// Specifies whether the Data Fusion instance should be private. If set to
	// true, all Data Fusion nodes will have private IP addresses and will not be
	// able to access the public internet.
	PrivateInstance pulumi.BoolPtrOutput `pulumi:"privateInstance"`
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringOutput `pulumi:"project"`
	// The combination of labels configured directly on the resource
	// and default labels configured on the provider.
	PulumiLabels pulumi.StringMapOutput `pulumi:"pulumiLabels"`
	// The region of the Data Fusion instance.
	Region pulumi.StringOutput `pulumi:"region"`
	// Service account which will be used to access resources in the customer project.
	//
	// Deprecated: `serviceAccount` is deprecated and will be removed in a future major release. Instead, use `tenantProjectId` to extract the tenant project ID.
	ServiceAccount pulumi.StringOutput `pulumi:"serviceAccount"`
	// Endpoint on which the Data Fusion UI and REST APIs are accessible.
	ServiceEndpoint pulumi.StringOutput `pulumi:"serviceEndpoint"`
	// The current state of this Data Fusion instance.
	// - CREATING: Instance is being created
	// - RUNNING: Instance is running and ready for requests
	// - FAILED: Instance creation failed
	// - DELETING: Instance is being deleted
	// - UPGRADING: Instance is being upgraded
	// - RESTARTING: Instance is being restarted
	State pulumi.StringOutput `pulumi:"state"`
	// Additional information about the current state of this Data Fusion instance if available.
	StateMessage pulumi.StringOutput `pulumi:"stateMessage"`
	// The name of the tenant project.
	TenantProjectId pulumi.StringOutput `pulumi:"tenantProjectId"`
	// Represents the type of Data Fusion instance. Each type is configured with
	// the default settings for processing and memory.
	// - BASIC: Basic Data Fusion instance. In Basic type, the user will be able to create data pipelines
	//   using point and click UI. However, there are certain limitations, such as fewer number
	//   of concurrent pipelines, no support for streaming pipelines, etc.
	// - ENTERPRISE: Enterprise Data Fusion instance. In Enterprise type, the user will have more features
	//   available, such as support for streaming pipelines, higher number of concurrent pipelines, etc.
	// - DEVELOPER: Developer Data Fusion instance. In Developer type, the user will have all features available but
	//   with restrictive capabilities. This is to help enterprises design and develop their data ingestion and integration
	//   pipelines at low cost.
	//   Possible values are: `BASIC`, `ENTERPRISE`, `DEVELOPER`.
	//
	// ***
	Type pulumi.StringOutput `pulumi:"type"`
	// The time the instance was last updated in RFC3339 UTC "Zulu" format, accurate to nanoseconds.
	UpdateTime pulumi.StringOutput `pulumi:"updateTime"`
	// Current version of the Data Fusion.
	Version pulumi.StringOutput `pulumi:"version"`
	// Name of the zone in which the Data Fusion instance will be created. Only DEVELOPER instances use this field.
	Zone pulumi.StringOutput `pulumi:"zone"`
}

Represents a Data Fusion instance.

To get more information about Instance, see:

* [API documentation](https://cloud.google.com/data-fusion/docs/reference/rest/v1beta1/projects.locations.instances) * How-to Guides

## Example Usage

### Data Fusion Instance Basic

```go package main

import ( 

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafusion.NewInstance(ctx, "basic_instance", &datafusion.InstanceArgs{
			Name:   pulumi.String("my-instance"),
			Region: pulumi.String("us-central1"),
			Type:   pulumi.String("BASIC"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Data Fusion Instance Full

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/appengine"
"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/compute"
"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_default, err := appengine.GetDefaultServiceAccount(ctx, nil, nil)
		if err != nil {
			return err
		}
		network, err := compute.NewNetwork(ctx, "network", &compute.NetworkArgs{
			Name: pulumi.String("datafusion-full-network"),
		})
		if err != nil {
			return err
		}
		privateIpAlloc, err := compute.NewGlobalAddress(ctx, "private_ip_alloc", &compute.GlobalAddressArgs{
			Name:         pulumi.String("datafusion-ip-alloc"),
			AddressType:  pulumi.String("INTERNAL"),
			Purpose:      pulumi.String("VPC_PEERING"),
			PrefixLength: pulumi.Int(22),
			Network:      network.ID(),
		})
		if err != nil {
			return err
		}
		_, err = datafusion.NewInstance(ctx, "extended_instance", &datafusion.InstanceArgs{
			Name:                        pulumi.String("my-instance"),
			Description:                 pulumi.String("My Data Fusion instance"),
			DisplayName:                 pulumi.String("My Data Fusion instance"),
			Region:                      pulumi.String("us-central1"),
			Type:                        pulumi.String("BASIC"),
			EnableStackdriverLogging:    pulumi.Bool(true),
			EnableStackdriverMonitoring: pulumi.Bool(true),
			PrivateInstance:             pulumi.Bool(true),
			DataprocServiceAccount:      pulumi.String(_default.Email),
			Labels: pulumi.StringMap{
				"example_key": pulumi.String("example_value"),
			},
			NetworkConfig: &datafusion.InstanceNetworkConfigArgs{
				Network: pulumi.String("default"),
				IpAllocation: pulumi.All(privateIpAlloc.Address, privateIpAlloc.PrefixLength).ApplyT(func(_args []interface{}) (string, error) {
					address := _args[0].(string)
					prefixLength := _args[1].(int)
					return fmt.Sprintf("%v/%v", address, prefixLength), nil
				}).(pulumi.StringOutput),
			},
			Accelerators: datafusion.InstanceAcceleratorArray{
				&datafusion.InstanceAcceleratorArgs{
					AcceleratorType: pulumi.String("CDC"),
					State:           pulumi.String("ENABLED"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Data Fusion Instance Cmek

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/kms"
"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/organizations"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		keyRing, err := kms.NewKeyRing(ctx, "key_ring", &kms.KeyRingArgs{
			Name:     pulumi.String("my-instance"),
			Location: pulumi.String("us-central1"),
		})
		if err != nil {
			return err
		}
		cryptoKey, err := kms.NewCryptoKey(ctx, "crypto_key", &kms.CryptoKeyArgs{
			Name:    pulumi.String("my-instance"),
			KeyRing: keyRing.ID(),
		})
		if err != nil {
			return err
		}
		_, err = datafusion.NewInstance(ctx, "cmek", &datafusion.InstanceArgs{
			Name:   pulumi.String("my-instance"),
			Region: pulumi.String("us-central1"),
			Type:   pulumi.String("BASIC"),
			CryptoKeyConfig: &datafusion.InstanceCryptoKeyConfigArgs{
				KeyReference: cryptoKey.ID(),
			},
		})
		if err != nil {
			return err
		}
		project, err := organizations.LookupProject(ctx, nil, nil)
		if err != nil {
			return err
		}
		_, err = kms.NewCryptoKeyIAMMember(ctx, "crypto_key_member", &kms.CryptoKeyIAMMemberArgs{
			CryptoKeyId: cryptoKey.ID(),
			Role:        pulumi.String("roles/cloudkms.cryptoKeyEncrypterDecrypter"),
			Member:      pulumi.String(fmt.Sprintf("serviceAccount:service-%v@gcp-sa-datafusion.iam.gserviceaccount.com", project.Number)),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Data Fusion Instance Enterprise

```go package main

import ( 

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafusion.NewInstance(ctx, "enterprise_instance", &datafusion.InstanceArgs{
			Name:       pulumi.String("my-instance"),
			Region:     pulumi.String("us-central1"),
			Type:       pulumi.String("ENTERPRISE"),
			EnableRbac: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Data Fusion Instance Event

```go package main

import ( 

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/pubsub"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		eventTopic, err := pubsub.NewTopic(ctx, "event", &pubsub.TopicArgs{
			Name: pulumi.String("my-instance"),
		})
		if err != nil {
			return err
		}
		_, err = datafusion.NewInstance(ctx, "event", &datafusion.InstanceArgs{
			Name:   pulumi.String("my-instance"),
			Region: pulumi.String("us-central1"),
			Type:   pulumi.String("BASIC"),
			EventPublishConfig: &datafusion.InstanceEventPublishConfigArgs{
				Enabled: pulumi.Bool(true),
				Topic:   eventTopic.ID(),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Data Fusion Instance Zone

```go package main

import ( 

"github.com/pulumi/pulumi-gcp/sdk/v7/go/gcp/datafusion"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := datafusion.NewInstance(ctx, "zone", &datafusion.InstanceArgs{
			Name:   pulumi.String("my-instance"),
			Region: pulumi.String("us-central1"),
			Zone:   pulumi.String("us-central1-a"),
			Type:   pulumi.String("DEVELOPER"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Instance can be imported using any of these accepted formats:

* `projects/{{project}}/locations/{{region}}/instances/{{name}}`

* `{{project}}/{{region}}/{{name}}`

* `{{region}}/{{name}}`

* `{{name}}`

When using the `pulumi import` command, Instance can be imported using one of the formats above. For example:

```sh $ pulumi import gcp:datafusion/instance:Instance default projects/{{project}}/locations/{{region}}/instances/{{name}} ```

```sh $ pulumi import gcp:datafusion/instance:Instance default {{project}}/{{region}}/{{name}} ```

```sh $ pulumi import gcp:datafusion/instance:Instance default {{region}}/{{name}} ```

```sh $ pulumi import gcp:datafusion/instance:Instance default {{name}} ```

func GetInstance 

func GetInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *InstanceState, opts ...pulumi.ResourceOption) (*Instance, error)

GetInstance gets an existing Instance 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 NewInstance 

func NewInstance(ctx *pulumi.Context,
	name string, args *InstanceArgs, opts ...pulumi.ResourceOption) (*Instance, error)

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

func (*Instance) ElementType 

func (*Instance) ElementType() reflect.Type

func (*Instance) ToInstanceOutput 

func (i *Instance) ToInstanceOutput() InstanceOutput

func (*Instance) ToInstanceOutputWithContext 

func (i *Instance) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

type InstanceAccelerator 

type InstanceAccelerator struct {
	// The type of an accelator for a CDF instance.
	// Possible values are: `CDC`, `HEALTHCARE`, `CCAI_INSIGHTS`.
	AcceleratorType string `pulumi:"acceleratorType"`
	// The type of an accelator for a CDF instance.
	// Possible values are: `ENABLED`, `DISABLED`.
	State string `pulumi:"state"`
}

type InstanceAcceleratorArgs 

type InstanceAcceleratorArgs struct {
	// The type of an accelator for a CDF instance.
	// Possible values are: `CDC`, `HEALTHCARE`, `CCAI_INSIGHTS`.
	AcceleratorType pulumi.StringInput `pulumi:"acceleratorType"`
	// The type of an accelator for a CDF instance.
	// Possible values are: `ENABLED`, `DISABLED`.
	State pulumi.StringInput `pulumi:"state"`
}

func (InstanceAcceleratorArgs) ElementType 

func (InstanceAcceleratorArgs) ElementType() reflect.Type

func (InstanceAcceleratorArgs) ToInstanceAcceleratorOutput 

func (i InstanceAcceleratorArgs) ToInstanceAcceleratorOutput() InstanceAcceleratorOutput

func (InstanceAcceleratorArgs) ToInstanceAcceleratorOutputWithContext 

func (i InstanceAcceleratorArgs) ToInstanceAcceleratorOutputWithContext(ctx context.Context) InstanceAcceleratorOutput

type InstanceAcceleratorArray 

type InstanceAcceleratorArray []InstanceAcceleratorInput

func (InstanceAcceleratorArray) ElementType 

func (InstanceAcceleratorArray) ElementType() reflect.Type

func (InstanceAcceleratorArray) ToInstanceAcceleratorArrayOutput 

func (i InstanceAcceleratorArray) ToInstanceAcceleratorArrayOutput() InstanceAcceleratorArrayOutput

func (InstanceAcceleratorArray) ToInstanceAcceleratorArrayOutputWithContext 

func (i InstanceAcceleratorArray) ToInstanceAcceleratorArrayOutputWithContext(ctx context.Context) InstanceAcceleratorArrayOutput

type InstanceAcceleratorArrayInput 

type InstanceAcceleratorArrayInput interface {
	pulumi.Input

	ToInstanceAcceleratorArrayOutput() InstanceAcceleratorArrayOutput
	ToInstanceAcceleratorArrayOutputWithContext(context.Context) InstanceAcceleratorArrayOutput
}

InstanceAcceleratorArrayInput is an input type that accepts InstanceAcceleratorArray and InstanceAcceleratorArrayOutput values. You can construct a concrete instance of `InstanceAcceleratorArrayInput` via: 

InstanceAcceleratorArray{ InstanceAcceleratorArgs{...} }

type InstanceAcceleratorArrayOutput 

type InstanceAcceleratorArrayOutput struct{ *pulumi.OutputState }

func (InstanceAcceleratorArrayOutput) ElementType 

func (InstanceAcceleratorArrayOutput) ElementType() reflect.Type

func (InstanceAcceleratorArrayOutput) Index 

func (o InstanceAcceleratorArrayOutput) Index(i pulumi.IntInput) InstanceAcceleratorOutput

func (InstanceAcceleratorArrayOutput) ToInstanceAcceleratorArrayOutput 

func (o InstanceAcceleratorArrayOutput) ToInstanceAcceleratorArrayOutput() InstanceAcceleratorArrayOutput

func (InstanceAcceleratorArrayOutput) ToInstanceAcceleratorArrayOutputWithContext 

func (o InstanceAcceleratorArrayOutput) ToInstanceAcceleratorArrayOutputWithContext(ctx context.Context) InstanceAcceleratorArrayOutput

type InstanceAcceleratorInput 

type InstanceAcceleratorInput interface {
	pulumi.Input

	ToInstanceAcceleratorOutput() InstanceAcceleratorOutput
	ToInstanceAcceleratorOutputWithContext(context.Context) InstanceAcceleratorOutput
}

InstanceAcceleratorInput is an input type that accepts InstanceAcceleratorArgs and InstanceAcceleratorOutput values. You can construct a concrete instance of `InstanceAcceleratorInput` via: 

InstanceAcceleratorArgs{...}

type InstanceAcceleratorOutput 

type InstanceAcceleratorOutput struct{ *pulumi.OutputState }

func (InstanceAcceleratorOutput) AcceleratorType 

func (o InstanceAcceleratorOutput) AcceleratorType() pulumi.StringOutput

The type of an accelator for a CDF instance. Possible values are: `CDC`, `HEALTHCARE`, `CCAI_INSIGHTS`.

func (InstanceAcceleratorOutput) ElementType 

func (InstanceAcceleratorOutput) ElementType() reflect.Type

func (InstanceAcceleratorOutput) State 

func (o InstanceAcceleratorOutput) State() pulumi.StringOutput

The type of an accelator for a CDF instance. Possible values are: `ENABLED`, `DISABLED`.

func (InstanceAcceleratorOutput) ToInstanceAcceleratorOutput 

func (o InstanceAcceleratorOutput) ToInstanceAcceleratorOutput() InstanceAcceleratorOutput

func (InstanceAcceleratorOutput) ToInstanceAcceleratorOutputWithContext 

func (o InstanceAcceleratorOutput) ToInstanceAcceleratorOutputWithContext(ctx context.Context) InstanceAcceleratorOutput

type InstanceArgs 

type InstanceArgs struct {
	// List of accelerators enabled for this CDF instance.
	// If accelerators are enabled it is possible a permadiff will be created with the Options field.
	// Users will need to either manually update their state file to include these diffed options, or include the field in a lifecycle ignore changes block.
	// Structure is documented below.
	Accelerators InstanceAcceleratorArrayInput
	// The crypto key configuration. This field is used by the Customer-Managed Encryption Keys (CMEK) feature.
	// Structure is documented below.
	CryptoKeyConfig InstanceCryptoKeyConfigPtrInput
	// User-managed service account to set on Dataproc when Cloud Data Fusion creates Dataproc to run data processing pipelines.
	DataprocServiceAccount pulumi.StringPtrInput
	// An optional description of the instance.
	Description pulumi.StringPtrInput
	// Display name for an instance.
	DisplayName pulumi.StringPtrInput
	// Option to enable granular role-based access control.
	EnableRbac pulumi.BoolPtrInput
	// Option to enable Stackdriver Logging.
	EnableStackdriverLogging pulumi.BoolPtrInput
	// Option to enable Stackdriver Monitoring.
	EnableStackdriverMonitoring pulumi.BoolPtrInput
	// Option to enable and pass metadata for event publishing.
	// Structure is documented below.
	EventPublishConfig InstanceEventPublishConfigPtrInput
	// The resource labels for instance to use to annotate any related underlying resources,
	// such as Compute Engine VMs.
	//
	// **Note**: This field is non-authoritative, and will only manage the labels present in your configuration.
	// Please refer to the field `effectiveLabels` for all of the labels present on the resource.
	Labels pulumi.StringMapInput
	// The ID of the instance or a fully qualified identifier for the instance.
	Name pulumi.StringPtrInput
	// Network configuration options. These are required when a private Data Fusion instance is to be created.
	// Structure is documented below.
	NetworkConfig InstanceNetworkConfigPtrInput
	// Map of additional options used to configure the behavior of Data Fusion instance.
	Options pulumi.StringMapInput
	// Specifies whether the Data Fusion instance should be private. If set to
	// true, all Data Fusion nodes will have private IP addresses and will not be
	// able to access the public internet.
	PrivateInstance pulumi.BoolPtrInput
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringPtrInput
	// The region of the Data Fusion instance.
	Region pulumi.StringPtrInput
	// Represents the type of Data Fusion instance. Each type is configured with
	// the default settings for processing and memory.
	// - BASIC: Basic Data Fusion instance. In Basic type, the user will be able to create data pipelines
	//   using point and click UI. However, there are certain limitations, such as fewer number
	//   of concurrent pipelines, no support for streaming pipelines, etc.
	// - ENTERPRISE: Enterprise Data Fusion instance. In Enterprise type, the user will have more features
	//   available, such as support for streaming pipelines, higher number of concurrent pipelines, etc.
	// - DEVELOPER: Developer Data Fusion instance. In Developer type, the user will have all features available but
	//   with restrictive capabilities. This is to help enterprises design and develop their data ingestion and integration
	//   pipelines at low cost.
	//   Possible values are: `BASIC`, `ENTERPRISE`, `DEVELOPER`.
	//
	// ***
	Type pulumi.StringInput
	// Current version of the Data Fusion.
	Version pulumi.StringPtrInput
	// Name of the zone in which the Data Fusion instance will be created. Only DEVELOPER instances use this field.
	Zone pulumi.StringPtrInput
}

The set of arguments for constructing a Instance resource.

func (InstanceArgs) ElementType 

func (InstanceArgs) ElementType() reflect.Type

type InstanceArray 

type InstanceArray []InstanceInput

func (InstanceArray) ElementType 

func (InstanceArray) ElementType() reflect.Type

func (InstanceArray) ToInstanceArrayOutput 

func (i InstanceArray) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArray) ToInstanceArrayOutputWithContext 

func (i InstanceArray) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceArrayInput 

type InstanceArrayInput interface {
	pulumi.Input

	ToInstanceArrayOutput() InstanceArrayOutput
	ToInstanceArrayOutputWithContext(context.Context) InstanceArrayOutput
}

InstanceArrayInput is an input type that accepts InstanceArray and InstanceArrayOutput values. You can construct a concrete instance of `InstanceArrayInput` via: 

InstanceArray{ InstanceArgs{...} }

type InstanceArrayOutput 

type InstanceArrayOutput struct{ *pulumi.OutputState }

func (InstanceArrayOutput) ElementType 

func (InstanceArrayOutput) ElementType() reflect.Type

func (InstanceArrayOutput) Index 

func (o InstanceArrayOutput) Index(i pulumi.IntInput) InstanceOutput

func (InstanceArrayOutput) ToInstanceArrayOutput 

func (o InstanceArrayOutput) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArrayOutput) ToInstanceArrayOutputWithContext 

func (o InstanceArrayOutput) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceCryptoKeyConfig 

type InstanceCryptoKeyConfig struct {
	// The name of the key which is used to encrypt/decrypt customer data. For key in Cloud KMS, the key should be in the format of projects/*/locations/*/keyRings/*/cryptoKeys/*.
	KeyReference string `pulumi:"keyReference"`
}

type InstanceCryptoKeyConfigArgs 

type InstanceCryptoKeyConfigArgs struct {
	// The name of the key which is used to encrypt/decrypt customer data. For key in Cloud KMS, the key should be in the format of projects/*/locations/*/keyRings/*/cryptoKeys/*.
	KeyReference pulumi.StringInput `pulumi:"keyReference"`
}

func (InstanceCryptoKeyConfigArgs) ElementType 

func (InstanceCryptoKeyConfigArgs) ElementType() reflect.Type

func (InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigOutput 

func (i InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigOutput() InstanceCryptoKeyConfigOutput

func (InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigOutputWithContext 

func (i InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigOutputWithContext(ctx context.Context) InstanceCryptoKeyConfigOutput

func (InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigPtrOutput 

func (i InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigPtrOutput() InstanceCryptoKeyConfigPtrOutput

func (InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigPtrOutputWithContext 

func (i InstanceCryptoKeyConfigArgs) ToInstanceCryptoKeyConfigPtrOutputWithContext(ctx context.Context) InstanceCryptoKeyConfigPtrOutput

type InstanceCryptoKeyConfigInput 

type InstanceCryptoKeyConfigInput interface {
	pulumi.Input

	ToInstanceCryptoKeyConfigOutput() InstanceCryptoKeyConfigOutput
	ToInstanceCryptoKeyConfigOutputWithContext(context.Context) InstanceCryptoKeyConfigOutput
}

InstanceCryptoKeyConfigInput is an input type that accepts InstanceCryptoKeyConfigArgs and InstanceCryptoKeyConfigOutput values. You can construct a concrete instance of `InstanceCryptoKeyConfigInput` via: 

InstanceCryptoKeyConfigArgs{...}

type InstanceCryptoKeyConfigOutput 

type InstanceCryptoKeyConfigOutput struct{ *pulumi.OutputState }

func (InstanceCryptoKeyConfigOutput) ElementType 

func (InstanceCryptoKeyConfigOutput) ElementType() reflect.Type

func (InstanceCryptoKeyConfigOutput) KeyReference 

func (o InstanceCryptoKeyConfigOutput) KeyReference() pulumi.StringOutput

The name of the key which is used to encrypt/decrypt customer data. For key in Cloud KMS, the key should be in the format of projects/*/locations/*/keyRings/*/cryptoKeys/*.

func (InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigOutput 

func (o InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigOutput() InstanceCryptoKeyConfigOutput

func (InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigOutputWithContext 

func (o InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigOutputWithContext(ctx context.Context) InstanceCryptoKeyConfigOutput

func (InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigPtrOutput 

func (o InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigPtrOutput() InstanceCryptoKeyConfigPtrOutput

func (InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigPtrOutputWithContext 

func (o InstanceCryptoKeyConfigOutput) ToInstanceCryptoKeyConfigPtrOutputWithContext(ctx context.Context) InstanceCryptoKeyConfigPtrOutput

type InstanceCryptoKeyConfigPtrInput 

type InstanceCryptoKeyConfigPtrInput interface {
	pulumi.Input

	ToInstanceCryptoKeyConfigPtrOutput() InstanceCryptoKeyConfigPtrOutput
	ToInstanceCryptoKeyConfigPtrOutputWithContext(context.Context) InstanceCryptoKeyConfigPtrOutput
}

InstanceCryptoKeyConfigPtrInput is an input type that accepts InstanceCryptoKeyConfigArgs, InstanceCryptoKeyConfigPtr and InstanceCryptoKeyConfigPtrOutput values. You can construct a concrete instance of `InstanceCryptoKeyConfigPtrInput` via: 

        InstanceCryptoKeyConfigArgs{...}

or:

        nil

func InstanceCryptoKeyConfigPtr 

func InstanceCryptoKeyConfigPtr(v *InstanceCryptoKeyConfigArgs) InstanceCryptoKeyConfigPtrInput

type InstanceCryptoKeyConfigPtrOutput 

type InstanceCryptoKeyConfigPtrOutput struct{ *pulumi.OutputState }

func (InstanceCryptoKeyConfigPtrOutput) Elem 

func (o InstanceCryptoKeyConfigPtrOutput) Elem() InstanceCryptoKeyConfigOutput

func (InstanceCryptoKeyConfigPtrOutput) ElementType 

func (InstanceCryptoKeyConfigPtrOutput) ElementType() reflect.Type

func (InstanceCryptoKeyConfigPtrOutput) KeyReference 

func (o InstanceCryptoKeyConfigPtrOutput) KeyReference() pulumi.StringPtrOutput

The name of the key which is used to encrypt/decrypt customer data. For key in Cloud KMS, the key should be in the format of projects/*/locations/*/keyRings/*/cryptoKeys/*.

func (InstanceCryptoKeyConfigPtrOutput) ToInstanceCryptoKeyConfigPtrOutput 

func (o InstanceCryptoKeyConfigPtrOutput) ToInstanceCryptoKeyConfigPtrOutput() InstanceCryptoKeyConfigPtrOutput

func (InstanceCryptoKeyConfigPtrOutput) ToInstanceCryptoKeyConfigPtrOutputWithContext 

func (o InstanceCryptoKeyConfigPtrOutput) ToInstanceCryptoKeyConfigPtrOutputWithContext(ctx context.Context) InstanceCryptoKeyConfigPtrOutput

type InstanceEventPublishConfig 

type InstanceEventPublishConfig struct {
	// Option to enable Event Publishing.
	Enabled bool `pulumi:"enabled"`
	// The resource name of the Pub/Sub topic. Format: projects/{projectId}/topics/{topic_id}
	Topic string `pulumi:"topic"`
}

type InstanceEventPublishConfigArgs 

type InstanceEventPublishConfigArgs struct {
	// Option to enable Event Publishing.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The resource name of the Pub/Sub topic. Format: projects/{projectId}/topics/{topic_id}
	Topic pulumi.StringInput `pulumi:"topic"`
}

func (InstanceEventPublishConfigArgs) ElementType 

func (InstanceEventPublishConfigArgs) ElementType() reflect.Type

func (InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigOutput 

func (i InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigOutput() InstanceEventPublishConfigOutput

func (InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigOutputWithContext 

func (i InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigOutputWithContext(ctx context.Context) InstanceEventPublishConfigOutput

func (InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigPtrOutput 

func (i InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigPtrOutput() InstanceEventPublishConfigPtrOutput

func (InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigPtrOutputWithContext 

func (i InstanceEventPublishConfigArgs) ToInstanceEventPublishConfigPtrOutputWithContext(ctx context.Context) InstanceEventPublishConfigPtrOutput

type InstanceEventPublishConfigInput 

type InstanceEventPublishConfigInput interface {
	pulumi.Input

	ToInstanceEventPublishConfigOutput() InstanceEventPublishConfigOutput
	ToInstanceEventPublishConfigOutputWithContext(context.Context) InstanceEventPublishConfigOutput
}

InstanceEventPublishConfigInput is an input type that accepts InstanceEventPublishConfigArgs and InstanceEventPublishConfigOutput values. You can construct a concrete instance of `InstanceEventPublishConfigInput` via: 

InstanceEventPublishConfigArgs{...}

type InstanceEventPublishConfigOutput 

type InstanceEventPublishConfigOutput struct{ *pulumi.OutputState }

func (InstanceEventPublishConfigOutput) ElementType 

func (InstanceEventPublishConfigOutput) ElementType() reflect.Type

func (InstanceEventPublishConfigOutput) Enabled 

func (o InstanceEventPublishConfigOutput) Enabled() pulumi.BoolOutput

Option to enable Event Publishing.

func (InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigOutput 

func (o InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigOutput() InstanceEventPublishConfigOutput

func (InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigOutputWithContext 

func (o InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigOutputWithContext(ctx context.Context) InstanceEventPublishConfigOutput

func (InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigPtrOutput 

func (o InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigPtrOutput() InstanceEventPublishConfigPtrOutput

func (InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigPtrOutputWithContext 

func (o InstanceEventPublishConfigOutput) ToInstanceEventPublishConfigPtrOutputWithContext(ctx context.Context) InstanceEventPublishConfigPtrOutput

func (InstanceEventPublishConfigOutput) Topic 

func (o InstanceEventPublishConfigOutput) Topic() pulumi.StringOutput

The resource name of the Pub/Sub topic. Format: projects/{projectId}/topics/{topic_id}

type InstanceEventPublishConfigPtrInput 

type InstanceEventPublishConfigPtrInput interface {
	pulumi.Input

	ToInstanceEventPublishConfigPtrOutput() InstanceEventPublishConfigPtrOutput
	ToInstanceEventPublishConfigPtrOutputWithContext(context.Context) InstanceEventPublishConfigPtrOutput
}

InstanceEventPublishConfigPtrInput is an input type that accepts InstanceEventPublishConfigArgs, InstanceEventPublishConfigPtr and InstanceEventPublishConfigPtrOutput values. You can construct a concrete instance of `InstanceEventPublishConfigPtrInput` via: 

        InstanceEventPublishConfigArgs{...}

or:

        nil

func InstanceEventPublishConfigPtr 

func InstanceEventPublishConfigPtr(v *InstanceEventPublishConfigArgs) InstanceEventPublishConfigPtrInput

type InstanceEventPublishConfigPtrOutput 

type InstanceEventPublishConfigPtrOutput struct{ *pulumi.OutputState }

func (InstanceEventPublishConfigPtrOutput) Elem 

func (o InstanceEventPublishConfigPtrOutput) Elem() InstanceEventPublishConfigOutput

func (InstanceEventPublishConfigPtrOutput) ElementType 

func (InstanceEventPublishConfigPtrOutput) ElementType() reflect.Type

func (InstanceEventPublishConfigPtrOutput) Enabled 

func (o InstanceEventPublishConfigPtrOutput) Enabled() pulumi.BoolPtrOutput

Option to enable Event Publishing.

func (InstanceEventPublishConfigPtrOutput) ToInstanceEventPublishConfigPtrOutput 

func (o InstanceEventPublishConfigPtrOutput) ToInstanceEventPublishConfigPtrOutput() InstanceEventPublishConfigPtrOutput

func (InstanceEventPublishConfigPtrOutput) ToInstanceEventPublishConfigPtrOutputWithContext 

func (o InstanceEventPublishConfigPtrOutput) ToInstanceEventPublishConfigPtrOutputWithContext(ctx context.Context) InstanceEventPublishConfigPtrOutput

func (InstanceEventPublishConfigPtrOutput) Topic 

func (o InstanceEventPublishConfigPtrOutput) Topic() pulumi.StringPtrOutput

The resource name of the Pub/Sub topic. Format: projects/{projectId}/topics/{topic_id}

type InstanceInput 

type InstanceInput interface {
	pulumi.Input

	ToInstanceOutput() InstanceOutput
	ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
}

type InstanceMap 

type InstanceMap map[string]InstanceInput

func (InstanceMap) ElementType 

func (InstanceMap) ElementType() reflect.Type

func (InstanceMap) ToInstanceMapOutput 

func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMap) ToInstanceMapOutputWithContext 

func (i InstanceMap) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceMapInput 

type InstanceMapInput interface {
	pulumi.Input

	ToInstanceMapOutput() InstanceMapOutput
	ToInstanceMapOutputWithContext(context.Context) InstanceMapOutput
}

InstanceMapInput is an input type that accepts InstanceMap and InstanceMapOutput values. You can construct a concrete instance of `InstanceMapInput` via: 

InstanceMap{ "key": InstanceArgs{...} }

type InstanceMapOutput 

type InstanceMapOutput struct{ *pulumi.OutputState }

func (InstanceMapOutput) ElementType 

func (InstanceMapOutput) ElementType() reflect.Type

func (InstanceMapOutput) MapIndex 

func (o InstanceMapOutput) MapIndex(k pulumi.StringInput) InstanceOutput

func (InstanceMapOutput) ToInstanceMapOutput 

func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMapOutput) ToInstanceMapOutputWithContext 

func (o InstanceMapOutput) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceNetworkConfig 

type InstanceNetworkConfig struct {
	// The IP range in CIDR notation to use for the managed Data Fusion instance
	// nodes. This range must not overlap with any other ranges used in the Data Fusion instance network.
	IpAllocation string `pulumi:"ipAllocation"`
	// Name of the network in the project with which the tenant project
	// will be peered for executing pipelines. In case of shared VPC where the network resides in another host
	// project the network should specified in the form of projects/{host-project-id}/global/networks/{network}
	Network string `pulumi:"network"`
}

type InstanceNetworkConfigArgs 

type InstanceNetworkConfigArgs struct {
	// The IP range in CIDR notation to use for the managed Data Fusion instance
	// nodes. This range must not overlap with any other ranges used in the Data Fusion instance network.
	IpAllocation pulumi.StringInput `pulumi:"ipAllocation"`
	// Name of the network in the project with which the tenant project
	// will be peered for executing pipelines. In case of shared VPC where the network resides in another host
	// project the network should specified in the form of projects/{host-project-id}/global/networks/{network}
	Network pulumi.StringInput `pulumi:"network"`
}

func (InstanceNetworkConfigArgs) ElementType 

func (InstanceNetworkConfigArgs) ElementType() reflect.Type

func (InstanceNetworkConfigArgs) ToInstanceNetworkConfigOutput 

func (i InstanceNetworkConfigArgs) ToInstanceNetworkConfigOutput() InstanceNetworkConfigOutput

func (InstanceNetworkConfigArgs) ToInstanceNetworkConfigOutputWithContext 

func (i InstanceNetworkConfigArgs) ToInstanceNetworkConfigOutputWithContext(ctx context.Context) InstanceNetworkConfigOutput

func (InstanceNetworkConfigArgs) ToInstanceNetworkConfigPtrOutput 

func (i InstanceNetworkConfigArgs) ToInstanceNetworkConfigPtrOutput() InstanceNetworkConfigPtrOutput

func (InstanceNetworkConfigArgs) ToInstanceNetworkConfigPtrOutputWithContext 

func (i InstanceNetworkConfigArgs) ToInstanceNetworkConfigPtrOutputWithContext(ctx context.Context) InstanceNetworkConfigPtrOutput

type InstanceNetworkConfigInput 

type InstanceNetworkConfigInput interface {
	pulumi.Input

	ToInstanceNetworkConfigOutput() InstanceNetworkConfigOutput
	ToInstanceNetworkConfigOutputWithContext(context.Context) InstanceNetworkConfigOutput
}

InstanceNetworkConfigInput is an input type that accepts InstanceNetworkConfigArgs and InstanceNetworkConfigOutput values. You can construct a concrete instance of `InstanceNetworkConfigInput` via: 

InstanceNetworkConfigArgs{...}

type InstanceNetworkConfigOutput 

type InstanceNetworkConfigOutput struct{ *pulumi.OutputState }

func (InstanceNetworkConfigOutput) ElementType 

func (InstanceNetworkConfigOutput) ElementType() reflect.Type

func (InstanceNetworkConfigOutput) IpAllocation 

func (o InstanceNetworkConfigOutput) IpAllocation() pulumi.StringOutput

The IP range in CIDR notation to use for the managed Data Fusion instance nodes. This range must not overlap with any other ranges used in the Data Fusion instance network.

func (InstanceNetworkConfigOutput) Network 

func (o InstanceNetworkConfigOutput) Network() pulumi.StringOutput

Name of the network in the project with which the tenant project will be peered for executing pipelines. In case of shared VPC where the network resides in another host project the network should specified in the form of projects/{host-project-id}/global/networks/{network}

func (InstanceNetworkConfigOutput) ToInstanceNetworkConfigOutput 

func (o InstanceNetworkConfigOutput) ToInstanceNetworkConfigOutput() InstanceNetworkConfigOutput

func (InstanceNetworkConfigOutput) ToInstanceNetworkConfigOutputWithContext 

func (o InstanceNetworkConfigOutput) ToInstanceNetworkConfigOutputWithContext(ctx context.Context) InstanceNetworkConfigOutput

func (InstanceNetworkConfigOutput) ToInstanceNetworkConfigPtrOutput 

func (o InstanceNetworkConfigOutput) ToInstanceNetworkConfigPtrOutput() InstanceNetworkConfigPtrOutput

func (InstanceNetworkConfigOutput) ToInstanceNetworkConfigPtrOutputWithContext 

func (o InstanceNetworkConfigOutput) ToInstanceNetworkConfigPtrOutputWithContext(ctx context.Context) InstanceNetworkConfigPtrOutput

type InstanceNetworkConfigPtrInput 

type InstanceNetworkConfigPtrInput interface {
	pulumi.Input

	ToInstanceNetworkConfigPtrOutput() InstanceNetworkConfigPtrOutput
	ToInstanceNetworkConfigPtrOutputWithContext(context.Context) InstanceNetworkConfigPtrOutput
}

InstanceNetworkConfigPtrInput is an input type that accepts InstanceNetworkConfigArgs, InstanceNetworkConfigPtr and InstanceNetworkConfigPtrOutput values. You can construct a concrete instance of `InstanceNetworkConfigPtrInput` via: 

        InstanceNetworkConfigArgs{...}

or:

        nil

func InstanceNetworkConfigPtr 

func InstanceNetworkConfigPtr(v *InstanceNetworkConfigArgs) InstanceNetworkConfigPtrInput

type InstanceNetworkConfigPtrOutput 

type InstanceNetworkConfigPtrOutput struct{ *pulumi.OutputState }

func (InstanceNetworkConfigPtrOutput) Elem 

func (o InstanceNetworkConfigPtrOutput) Elem() InstanceNetworkConfigOutput

func (InstanceNetworkConfigPtrOutput) ElementType 

func (InstanceNetworkConfigPtrOutput) ElementType() reflect.Type

func (InstanceNetworkConfigPtrOutput) IpAllocation 

func (o InstanceNetworkConfigPtrOutput) IpAllocation() pulumi.StringPtrOutput

The IP range in CIDR notation to use for the managed Data Fusion instance nodes. This range must not overlap with any other ranges used in the Data Fusion instance network.

func (InstanceNetworkConfigPtrOutput) Network 

func (o InstanceNetworkConfigPtrOutput) Network() pulumi.StringPtrOutput

Name of the network in the project with which the tenant project will be peered for executing pipelines. In case of shared VPC where the network resides in another host project the network should specified in the form of projects/{host-project-id}/global/networks/{network}

func (InstanceNetworkConfigPtrOutput) ToInstanceNetworkConfigPtrOutput 

func (o InstanceNetworkConfigPtrOutput) ToInstanceNetworkConfigPtrOutput() InstanceNetworkConfigPtrOutput

func (InstanceNetworkConfigPtrOutput) ToInstanceNetworkConfigPtrOutputWithContext 

func (o InstanceNetworkConfigPtrOutput) ToInstanceNetworkConfigPtrOutputWithContext(ctx context.Context) InstanceNetworkConfigPtrOutput

type InstanceOutput 

type InstanceOutput struct{ *pulumi.OutputState }

func (InstanceOutput) Accelerators 

func (o InstanceOutput) Accelerators() InstanceAcceleratorArrayOutput

List of accelerators enabled for this CDF instance. If accelerators are enabled it is possible a permadiff will be created with the Options field. Users will need to either manually update their state file to include these diffed options, or include the field in a lifecycle ignore changes block. Structure is documented below.

func (InstanceOutput) ApiEndpoint 

func (o InstanceOutput) ApiEndpoint() pulumi.StringOutput

Endpoint on which the REST APIs is accessible.

func (InstanceOutput) CreateTime 

func (o InstanceOutput) CreateTime() pulumi.StringOutput

The time the instance was created in RFC3339 UTC "Zulu" format, accurate to nanoseconds.

func (InstanceOutput) CryptoKeyConfig 

func (o InstanceOutput) CryptoKeyConfig() InstanceCryptoKeyConfigPtrOutput

The crypto key configuration. This field is used by the Customer-Managed Encryption Keys (CMEK) feature. Structure is documented below.

func (InstanceOutput) DataprocServiceAccount 

func (o InstanceOutput) DataprocServiceAccount() pulumi.StringPtrOutput

User-managed service account to set on Dataproc when Cloud Data Fusion creates Dataproc to run data processing pipelines.

func (InstanceOutput) Description 

func (o InstanceOutput) Description() pulumi.StringPtrOutput

An optional description of the instance.

func (InstanceOutput) DisplayName 

func (o InstanceOutput) DisplayName() pulumi.StringPtrOutput

Display name for an instance.

func (InstanceOutput) EffectiveLabels 

func (o InstanceOutput) EffectiveLabels() pulumi.StringMapOutput

All of labels (key/value pairs) present on the resource in GCP, including the labels configured through Pulumi, other clients and services.

func (InstanceOutput) ElementType 

func (InstanceOutput) ElementType() reflect.Type

func (InstanceOutput) EnableRbac 

func (o InstanceOutput) EnableRbac() pulumi.BoolPtrOutput

Option to enable granular role-based access control.

func (InstanceOutput) EnableStackdriverLogging 

func (o InstanceOutput) EnableStackdriverLogging() pulumi.BoolPtrOutput

Option to enable Stackdriver Logging.

func (InstanceOutput) EnableStackdriverMonitoring 

func (o InstanceOutput) EnableStackdriverMonitoring() pulumi.BoolPtrOutput

Option to enable Stackdriver Monitoring.

func (InstanceOutput) EventPublishConfig 

func (o InstanceOutput) EventPublishConfig() InstanceEventPublishConfigPtrOutput

Option to enable and pass metadata for event publishing. Structure is documented below.

func (InstanceOutput) GcsBucket 

func (o InstanceOutput) GcsBucket() pulumi.StringOutput

Cloud Storage bucket generated by Data Fusion in the customer project.

func (InstanceOutput) Labels 

func (o InstanceOutput) Labels() pulumi.StringMapOutput

The resource labels for instance to use to annotate any related underlying resources, such as Compute Engine VMs.

**Note**: This field is non-authoritative, and will only manage the labels present in your configuration. Please refer to the field `effectiveLabels` for all of the labels present on the resource.

func (InstanceOutput) Name 

func (o InstanceOutput) Name() pulumi.StringOutput

The ID of the instance or a fully qualified identifier for the instance.

func (InstanceOutput) NetworkConfig 

func (o InstanceOutput) NetworkConfig() InstanceNetworkConfigPtrOutput

Network configuration options. These are required when a private Data Fusion instance is to be created. Structure is documented below.

func (InstanceOutput) Options 

func (o InstanceOutput) Options() pulumi.StringMapOutput

Map of additional options used to configure the behavior of Data Fusion instance.

func (InstanceOutput) P4ServiceAccount 

func (o InstanceOutput) P4ServiceAccount() pulumi.StringOutput

P4 service account for the customer project.

func (InstanceOutput) PrivateInstance 

func (o InstanceOutput) PrivateInstance() pulumi.BoolPtrOutput

Specifies whether the Data Fusion instance should be private. If set to true, all Data Fusion nodes will have private IP addresses and will not be able to access the public internet.

func (InstanceOutput) Project 

func (o InstanceOutput) Project() pulumi.StringOutput

The ID of the project in which the resource belongs. If it is not provided, the provider project is used.

func (InstanceOutput) PulumiLabels 

func (o InstanceOutput) PulumiLabels() pulumi.StringMapOutput

The combination of labels configured directly on the resource and default labels configured on the provider.

func (InstanceOutput) Region 

func (o InstanceOutput) Region() pulumi.StringOutput

The region of the Data Fusion instance.

func (InstanceOutput) ServiceAccount deprecated 

func (o InstanceOutput) ServiceAccount() pulumi.StringOutput

Service account which will be used to access resources in the customer project.

Deprecated: `serviceAccount` is deprecated and will be removed in a future major release. Instead, use `tenantProjectId` to extract the tenant project ID.

func (InstanceOutput) ServiceEndpoint 

func (o InstanceOutput) ServiceEndpoint() pulumi.StringOutput

Endpoint on which the Data Fusion UI and REST APIs are accessible.

func (InstanceOutput) State 

func (o InstanceOutput) State() pulumi.StringOutput

The current state of this Data Fusion instance. - CREATING: Instance is being created - RUNNING: Instance is running and ready for requests - FAILED: Instance creation failed - DELETING: Instance is being deleted - UPGRADING: Instance is being upgraded - RESTARTING: Instance is being restarted

func (InstanceOutput) StateMessage 

func (o InstanceOutput) StateMessage() pulumi.StringOutput

Additional information about the current state of this Data Fusion instance if available.

func (InstanceOutput) TenantProjectId 

func (o InstanceOutput) TenantProjectId() pulumi.StringOutput

The name of the tenant project.

func (InstanceOutput) ToInstanceOutput 

func (o InstanceOutput) ToInstanceOutput() InstanceOutput

func (InstanceOutput) ToInstanceOutputWithContext 

func (o InstanceOutput) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

func (InstanceOutput) Type 

func (o InstanceOutput) Type() pulumi.StringOutput

Represents the type of Data Fusion instance. Each type is configured with the default settings for processing and memory.

  • BASIC: Basic Data Fusion instance. In Basic type, the user will be able to create data pipelines using point and click UI. However, there are certain limitations, such as fewer number of concurrent pipelines, no support for streaming pipelines, etc.
  • ENTERPRISE: Enterprise Data Fusion instance. In Enterprise type, the user will have more features available, such as support for streaming pipelines, higher number of concurrent pipelines, etc.
  • DEVELOPER: Developer Data Fusion instance. In Developer type, the user will have all features available but with restrictive capabilities. This is to help enterprises design and develop their data ingestion and integration pipelines at low cost. Possible values are: `BASIC`, `ENTERPRISE`, `DEVELOPER`.

***

func (InstanceOutput) UpdateTime 

func (o InstanceOutput) UpdateTime() pulumi.StringOutput

The time the instance was last updated in RFC3339 UTC "Zulu" format, accurate to nanoseconds.

func (InstanceOutput) Version 

func (o InstanceOutput) Version() pulumi.StringOutput

Current version of the Data Fusion.

func (InstanceOutput) Zone 

func (o InstanceOutput) Zone() pulumi.StringOutput

Name of the zone in which the Data Fusion instance will be created. Only DEVELOPER instances use this field.

type InstanceState 

type InstanceState struct {
	// List of accelerators enabled for this CDF instance.
	// If accelerators are enabled it is possible a permadiff will be created with the Options field.
	// Users will need to either manually update their state file to include these diffed options, or include the field in a lifecycle ignore changes block.
	// Structure is documented below.
	Accelerators InstanceAcceleratorArrayInput
	// Endpoint on which the REST APIs is accessible.
	ApiEndpoint pulumi.StringPtrInput
	// The time the instance was created in RFC3339 UTC "Zulu" format, accurate to nanoseconds.
	CreateTime pulumi.StringPtrInput
	// The crypto key configuration. This field is used by the Customer-Managed Encryption Keys (CMEK) feature.
	// Structure is documented below.
	CryptoKeyConfig InstanceCryptoKeyConfigPtrInput
	// User-managed service account to set on Dataproc when Cloud Data Fusion creates Dataproc to run data processing pipelines.
	DataprocServiceAccount pulumi.StringPtrInput
	// An optional description of the instance.
	Description pulumi.StringPtrInput
	// Display name for an instance.
	DisplayName pulumi.StringPtrInput
	// All of labels (key/value pairs) present on the resource in GCP, including the labels configured through Pulumi, other clients and services.
	EffectiveLabels pulumi.StringMapInput
	// Option to enable granular role-based access control.
	EnableRbac pulumi.BoolPtrInput
	// Option to enable Stackdriver Logging.
	EnableStackdriverLogging pulumi.BoolPtrInput
	// Option to enable Stackdriver Monitoring.
	EnableStackdriverMonitoring pulumi.BoolPtrInput
	// Option to enable and pass metadata for event publishing.
	// Structure is documented below.
	EventPublishConfig InstanceEventPublishConfigPtrInput
	// Cloud Storage bucket generated by Data Fusion in the customer project.
	GcsBucket pulumi.StringPtrInput
	// The resource labels for instance to use to annotate any related underlying resources,
	// such as Compute Engine VMs.
	//
	// **Note**: This field is non-authoritative, and will only manage the labels present in your configuration.
	// Please refer to the field `effectiveLabels` for all of the labels present on the resource.
	Labels pulumi.StringMapInput
	// The ID of the instance or a fully qualified identifier for the instance.
	Name pulumi.StringPtrInput
	// Network configuration options. These are required when a private Data Fusion instance is to be created.
	// Structure is documented below.
	NetworkConfig InstanceNetworkConfigPtrInput
	// Map of additional options used to configure the behavior of Data Fusion instance.
	Options pulumi.StringMapInput
	// P4 service account for the customer project.
	P4ServiceAccount pulumi.StringPtrInput
	// Specifies whether the Data Fusion instance should be private. If set to
	// true, all Data Fusion nodes will have private IP addresses and will not be
	// able to access the public internet.
	PrivateInstance pulumi.BoolPtrInput
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringPtrInput
	// The combination of labels configured directly on the resource
	// and default labels configured on the provider.
	PulumiLabels pulumi.StringMapInput
	// The region of the Data Fusion instance.
	Region pulumi.StringPtrInput
	// Service account which will be used to access resources in the customer project.
	//
	// Deprecated: `serviceAccount` is deprecated and will be removed in a future major release. Instead, use `tenantProjectId` to extract the tenant project ID.
	ServiceAccount pulumi.StringPtrInput
	// Endpoint on which the Data Fusion UI and REST APIs are accessible.
	ServiceEndpoint pulumi.StringPtrInput
	// The current state of this Data Fusion instance.
	// - CREATING: Instance is being created
	// - RUNNING: Instance is running and ready for requests
	// - FAILED: Instance creation failed
	// - DELETING: Instance is being deleted
	// - UPGRADING: Instance is being upgraded
	// - RESTARTING: Instance is being restarted
	State pulumi.StringPtrInput
	// Additional information about the current state of this Data Fusion instance if available.
	StateMessage pulumi.StringPtrInput
	// The name of the tenant project.
	TenantProjectId pulumi.StringPtrInput
	// Represents the type of Data Fusion instance. Each type is configured with
	// the default settings for processing and memory.
	// - BASIC: Basic Data Fusion instance. In Basic type, the user will be able to create data pipelines
	//   using point and click UI. However, there are certain limitations, such as fewer number
	//   of concurrent pipelines, no support for streaming pipelines, etc.
	// - ENTERPRISE: Enterprise Data Fusion instance. In Enterprise type, the user will have more features
	//   available, such as support for streaming pipelines, higher number of concurrent pipelines, etc.
	// - DEVELOPER: Developer Data Fusion instance. In Developer type, the user will have all features available but
	//   with restrictive capabilities. This is to help enterprises design and develop their data ingestion and integration
	//   pipelines at low cost.
	//   Possible values are: `BASIC`, `ENTERPRISE`, `DEVELOPER`.
	//
	// ***
	Type pulumi.StringPtrInput
	// The time the instance was last updated in RFC3339 UTC "Zulu" format, accurate to nanoseconds.
	UpdateTime pulumi.StringPtrInput
	// Current version of the Data Fusion.
	Version pulumi.StringPtrInput
	// Name of the zone in which the Data Fusion instance will be created. Only DEVELOPER instances use this field.
	Zone pulumi.StringPtrInput
}

func (InstanceState) ElementType 

func (InstanceState) ElementType() reflect.Type

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.