InstanceArgs

data class InstanceArgs(val accelerators: Output<List<InstanceAcceleratorArgs>>? = null, val cryptoKeyConfig: Output<InstanceCryptoKeyConfigArgs>? = null, val dataprocServiceAccount: Output<String>? = null, val description: Output<String>? = null, val displayName: Output<String>? = null, val enableRbac: Output<Boolean>? = null, val enableStackdriverLogging: Output<Boolean>? = null, val enableStackdriverMonitoring: Output<Boolean>? = null, val eventPublishConfig: Output<InstanceEventPublishConfigArgs>? = null, val labels: Output<Map<String, String>>? = null, val name: Output<String>? = null, val networkConfig: Output<InstanceNetworkConfigArgs>? = null, val options: Output<Map<String, String>>? = null, val privateInstance: Output<Boolean>? = null, val project: Output<String>? = null, val region: Output<String>? = null, val type: Output<String>? = null, val version: Output<String>? = null, val zone: Output<String>? = null) : ConvertibleToJava<InstanceArgs>

Represents a Data Fusion instance. To get more information about Instance, see:

Example Usage

Data Fusion Instance Basic

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var basicInstance = new Instance("basicInstance", InstanceArgs.builder()
.region("us-central1")
.type("BASIC")
.build());
}
}

Data Fusion Instance Full

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.appengine.AppengineFunctions;
import com.pulumi.gcp.appengine.inputs.GetDefaultServiceAccountArgs;
import com.pulumi.gcp.compute.Network;
import com.pulumi.gcp.compute.GlobalAddress;
import com.pulumi.gcp.compute.GlobalAddressArgs;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import com.pulumi.gcp.datafusion.inputs.InstanceNetworkConfigArgs;
import com.pulumi.gcp.datafusion.inputs.InstanceAcceleratorArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
final var default = AppengineFunctions.getDefaultServiceAccount();
var network = new Network("network");
var privateIpAlloc = new GlobalAddress("privateIpAlloc", GlobalAddressArgs.builder()
.addressType("INTERNAL")
.purpose("VPC_PEERING")
.prefixLength(22)
.network(network.id())
.build());
var extendedInstance = new Instance("extendedInstance", InstanceArgs.builder()
.description("My Data Fusion instance")
.displayName("My Data Fusion instance")
.region("us-central1")
.type("BASIC")
.enableStackdriverLogging(true)
.enableStackdriverMonitoring(true)
.privateInstance(true)
.dataprocServiceAccount(default_.email())
.labels(Map.of("example_key", "example_value"))
.networkConfig(InstanceNetworkConfigArgs.builder()
.network("default")
.ipAllocation(Output.tuple(privateIpAlloc.address(), privateIpAlloc.prefixLength()).applyValue(values -> {
var address = values.t1;
var prefixLength = values.t2;
return String.format("%s/%s", address,prefixLength);
}))
.build())
.accelerators(InstanceAcceleratorArgs.builder()
.acceleratorType("CDC")
.state("ENABLED")
.build())
.build());
}
}

Data Fusion Instance Cmek

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.kms.KeyRing;
import com.pulumi.gcp.kms.KeyRingArgs;
import com.pulumi.gcp.kms.CryptoKey;
import com.pulumi.gcp.kms.CryptoKeyArgs;
import com.pulumi.gcp.organizations.OrganizationsFunctions;
import com.pulumi.gcp.organizations.inputs.GetProjectArgs;
import com.pulumi.gcp.kms.CryptoKeyIAMBinding;
import com.pulumi.gcp.kms.CryptoKeyIAMBindingArgs;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import com.pulumi.gcp.datafusion.inputs.InstanceCryptoKeyConfigArgs;
import com.pulumi.resources.CustomResourceOptions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var keyRing = new KeyRing("keyRing", KeyRingArgs.builder()
.location("us-central1")
.build());
var cryptoKey = new CryptoKey("cryptoKey", CryptoKeyArgs.builder()
.keyRing(keyRing.id())
.build());
final var project = OrganizationsFunctions.getProject();
var cryptoKeyBinding = new CryptoKeyIAMBinding("cryptoKeyBinding", CryptoKeyIAMBindingArgs.builder()
.cryptoKeyId(cryptoKey.id())
.role("roles/cloudkms.cryptoKeyEncrypterDecrypter")
.members(String.format("serviceAccount:service-%s@gcp-sa-datafusion.iam.gserviceaccount.com", project.applyValue(getProjectResult -> getProjectResult.number())))
.build());
var cmek = new Instance("cmek", InstanceArgs.builder()
.region("us-central1")
.type("BASIC")
.cryptoKeyConfig(InstanceCryptoKeyConfigArgs.builder()
.keyReference(cryptoKey.id())
.build())
.build(), CustomResourceOptions.builder()
.dependsOn(cryptoKeyBinding)
.build());
}
}

Data Fusion Instance Enterprise

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var enterpriseInstance = new Instance("enterpriseInstance", InstanceArgs.builder()
.enableRbac(true)
.region("us-central1")
.type("ENTERPRISE")
.build());
}
}

Data Fusion Instance Event

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.pubsub.Topic;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import com.pulumi.gcp.datafusion.inputs.InstanceEventPublishConfigArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var eventTopic = new Topic("eventTopic");
var eventInstance = new Instance("eventInstance", InstanceArgs.builder()
.region("us-central1")
.type("BASIC")
.eventPublishConfig(InstanceEventPublishConfigArgs.builder()
.enabled(true)
.topic(eventTopic.id())
.build())
.build());
}
}

Data Fusion Instance Zone

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.datafusion.Instance;
import com.pulumi.gcp.datafusion.InstanceArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var zone = new Instance("zone", InstanceArgs.builder()
.region("us-central1")
.type("DEVELOPER")
.zone("us-central1-a")
.build());
}
}

Import

Instance can be imported using any of these accepted formats

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

Constructors

Link copied to clipboard
constructor(accelerators: Output<List<InstanceAcceleratorArgs>>? = null, cryptoKeyConfig: Output<InstanceCryptoKeyConfigArgs>? = null, dataprocServiceAccount: Output<String>? = null, description: Output<String>? = null, displayName: Output<String>? = null, enableRbac: Output<Boolean>? = null, enableStackdriverLogging: Output<Boolean>? = null, enableStackdriverMonitoring: Output<Boolean>? = null, eventPublishConfig: Output<InstanceEventPublishConfigArgs>? = null, labels: Output<Map<String, String>>? = null, name: Output<String>? = null, networkConfig: Output<InstanceNetworkConfigArgs>? = null, options: Output<Map<String, String>>? = null, privateInstance: Output<Boolean>? = null, project: Output<String>? = null, region: Output<String>? = null, type: Output<String>? = null, version: Output<String>? = null, zone: Output<String>? = null)

Properties

Link copied to clipboard

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

Link copied to clipboard

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

Link copied to clipboard
val dataprocServiceAccount: Output<String>? = null

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

Link copied to clipboard
val description: Output<String>? = null

An optional description of the instance.

Link copied to clipboard
val displayName: Output<String>? = null

Display name for an instance.

Link copied to clipboard
val enableRbac: Output<Boolean>? = null

Option to enable granular role-based access control.

Link copied to clipboard
val enableStackdriverLogging: Output<Boolean>? = null

Option to enable Stackdriver Logging.

Link copied to clipboard

Option to enable Stackdriver Monitoring.

Link copied to clipboard

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

Link copied to clipboard
val labels: Output<Map<String, String>>? = null

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

Link copied to clipboard
val name: Output<String>? = null

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

Link copied to clipboard

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

Link copied to clipboard
val options: Output<Map<String, String>>? = null

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

Link copied to clipboard
val privateInstance: Output<Boolean>? = null

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.

Link copied to clipboard
val project: Output<String>? = null

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

Link copied to clipboard
val region: Output<String>? = null

The region of the Data Fusion instance.

Link copied to clipboard
val type: Output<String>? = null

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

Link copied to clipboard
val version: Output<String>? = null

Current version of the Data Fusion.

Link copied to clipboard
val zone: Output<String>? = null

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

Functions

Link copied to clipboard
open override fun toJava(): InstanceArgs