pulumi-azure-native-kotlin/com.pulumi.azurenative.streamanalytics.kotlin/Cluster

Cluster

class Cluster : KotlinCustomResource

A Stream Analytics Cluster object Azure REST API version: 2020-03-01. Prior API version in Azure Native 1.x: 2020-03-01-preview. Other available API versions: 2020-03-01-preview.

Example Usage

Create a new cluster

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var cluster = new AzureNative.StreamAnalytics.Cluster("cluster", new()
    {
        ClusterName = "An Example Cluster",
        Location = "North US",
        ResourceGroupName = "sjrg",
        Sku = new AzureNative.StreamAnalytics.Inputs.ClusterSkuArgs
        {
            Capacity = 48,
            Name = AzureNative.StreamAnalytics.ClusterSkuName.Default,
        },
        Tags =
        {
            { "key", "value" },
        },
    });
});

package main
import (
	"github.com/pulumi/pulumi-azure-native-sdk/streamanalytics/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := streamanalytics.NewCluster(ctx, "cluster", &streamanalytics.ClusterArgs{
			ClusterName:       pulumi.String("An Example Cluster"),
			Location:          pulumi.String("North US"),
			ResourceGroupName: pulumi.String("sjrg"),
			Sku: &streamanalytics.ClusterSkuArgs{
				Capacity: pulumi.Int(48),
				Name:     pulumi.String(streamanalytics.ClusterSkuNameDefault),
			},
			Tags: pulumi.StringMap{
				"key": pulumi.String("value"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.streamanalytics.Cluster;
import com.pulumi.azurenative.streamanalytics.ClusterArgs;
import com.pulumi.azurenative.streamanalytics.inputs.ClusterSkuArgs;
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 cluster = new Cluster("cluster", ClusterArgs.builder()
            .clusterName("An Example Cluster")
            .location("North US")
            .resourceGroupName("sjrg")
            .sku(ClusterSkuArgs.builder()
                .capacity(48)
                .name("Default")
                .build())
            .tags(Map.of("key", "value"))
            .build());
    }
}

Import

An existing resource can be imported using its type token, name, and identifier, e.g.

$ pulumi import azure-native:streamanalytics:Cluster An Example Cluster /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/clusters/{clusterName}

Properties

capacityAllocated

val capacityAllocated: Output<Int>

Represents the number of streaming units currently being used on the cluster.

capacityAssigned

val capacityAssigned: Output<Int>

Represents the sum of the SUs of all streaming jobs associated with the cluster. If all of the jobs were running, this would be the capacity allocated.

clusterId

val clusterId: Output<String>

Unique identifier for the cluster.

createdDate

val createdDate: Output<String>

The date this cluster was created.

etag

val etag: Output<String>

The current entity tag for the cluster. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.