streamanalytics

package
v4.42.0 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2022 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 Cluster added in v4.29.0 

type Cluster struct {
	pulumi.CustomResourceState

	// The Azure Region where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	Location pulumi.StringOutput `pulumi:"location"`
	// The name which should be used for this Stream Analytics Cluster. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the Resource Group where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The number of streaming units supported by the Cluster. Accepted values are multiples of `36` in the range of `36` to `216`.
	StreamingCapacity pulumi.IntOutput `pulumi:"streamingCapacity"`
	// A mapping of tags which should be assigned to the Stream Analytics.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
}

Manages a Stream Analytics Cluster.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", &core.ResourceGroupArgs{
			Location: pulumi.String("West Europe"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewCluster(ctx, "exampleCluster", &streamanalytics.ClusterArgs{
			ResourceGroupName: exampleResourceGroup.Name,
			Location:          exampleResourceGroup.Location,
			StreamingCapacity: pulumi.Int(36),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Clusters can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/cluster:Cluster example /subscriptions/12345678-1234-9876-4563-123456789012/resourceGroups/resGroup1/providers/Microsoft.StreamAnalytics/clusters/cluster1

```

func GetCluster added in v4.29.0 

func GetCluster(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ClusterState, opts ...pulumi.ResourceOption) (*Cluster, error)

GetCluster gets an existing Cluster 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 NewCluster added in v4.29.0 

func NewCluster(ctx *pulumi.Context,
	name string, args *ClusterArgs, opts ...pulumi.ResourceOption) (*Cluster, error)

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

func (*Cluster) ElementType added in v4.29.0 

func (*Cluster) ElementType() reflect.Type

func (*Cluster) ToClusterOutput added in v4.29.0 

func (i *Cluster) ToClusterOutput() ClusterOutput

func (*Cluster) ToClusterOutputWithContext added in v4.29.0 

func (i *Cluster) ToClusterOutputWithContext(ctx context.Context) ClusterOutput

type ClusterArgs added in v4.29.0 

type ClusterArgs struct {
	// The Azure Region where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	Location pulumi.StringPtrInput
	// The name which should be used for this Stream Analytics Cluster. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The number of streaming units supported by the Cluster. Accepted values are multiples of `36` in the range of `36` to `216`.
	StreamingCapacity pulumi.IntInput
	// A mapping of tags which should be assigned to the Stream Analytics.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a Cluster resource.

func (ClusterArgs) ElementType added in v4.29.0 

func (ClusterArgs) ElementType() reflect.Type

type ClusterArray added in v4.29.0 

type ClusterArray []ClusterInput

func (ClusterArray) ElementType added in v4.29.0 

func (ClusterArray) ElementType() reflect.Type

func (ClusterArray) ToClusterArrayOutput added in v4.29.0 

func (i ClusterArray) ToClusterArrayOutput() ClusterArrayOutput

func (ClusterArray) ToClusterArrayOutputWithContext added in v4.29.0 

func (i ClusterArray) ToClusterArrayOutputWithContext(ctx context.Context) ClusterArrayOutput

type ClusterArrayInput added in v4.29.0 

type ClusterArrayInput interface {
	pulumi.Input

	ToClusterArrayOutput() ClusterArrayOutput
	ToClusterArrayOutputWithContext(context.Context) ClusterArrayOutput
}

ClusterArrayInput is an input type that accepts ClusterArray and ClusterArrayOutput values. You can construct a concrete instance of `ClusterArrayInput` via: 

ClusterArray{ ClusterArgs{...} }

type ClusterArrayOutput added in v4.29.0 

type ClusterArrayOutput struct{ *pulumi.OutputState }

func (ClusterArrayOutput) ElementType added in v4.29.0 

func (ClusterArrayOutput) ElementType() reflect.Type

func (ClusterArrayOutput) Index added in v4.29.0 

func (o ClusterArrayOutput) Index(i pulumi.IntInput) ClusterOutput

func (ClusterArrayOutput) ToClusterArrayOutput added in v4.29.0 

func (o ClusterArrayOutput) ToClusterArrayOutput() ClusterArrayOutput

func (ClusterArrayOutput) ToClusterArrayOutputWithContext added in v4.29.0 

func (o ClusterArrayOutput) ToClusterArrayOutputWithContext(ctx context.Context) ClusterArrayOutput

type ClusterInput added in v4.29.0 

type ClusterInput interface {
	pulumi.Input

	ToClusterOutput() ClusterOutput
	ToClusterOutputWithContext(ctx context.Context) ClusterOutput
}

type ClusterMap added in v4.29.0 

type ClusterMap map[string]ClusterInput

func (ClusterMap) ElementType added in v4.29.0 

func (ClusterMap) ElementType() reflect.Type

func (ClusterMap) ToClusterMapOutput added in v4.29.0 

func (i ClusterMap) ToClusterMapOutput() ClusterMapOutput

func (ClusterMap) ToClusterMapOutputWithContext added in v4.29.0 

func (i ClusterMap) ToClusterMapOutputWithContext(ctx context.Context) ClusterMapOutput

type ClusterMapInput added in v4.29.0 

type ClusterMapInput interface {
	pulumi.Input

	ToClusterMapOutput() ClusterMapOutput
	ToClusterMapOutputWithContext(context.Context) ClusterMapOutput
}

ClusterMapInput is an input type that accepts ClusterMap and ClusterMapOutput values. You can construct a concrete instance of `ClusterMapInput` via: 

ClusterMap{ "key": ClusterArgs{...} }

type ClusterMapOutput added in v4.29.0 

type ClusterMapOutput struct{ *pulumi.OutputState }

func (ClusterMapOutput) ElementType added in v4.29.0 

func (ClusterMapOutput) ElementType() reflect.Type

func (ClusterMapOutput) MapIndex added in v4.29.0 

func (o ClusterMapOutput) MapIndex(k pulumi.StringInput) ClusterOutput

func (ClusterMapOutput) ToClusterMapOutput added in v4.29.0 

func (o ClusterMapOutput) ToClusterMapOutput() ClusterMapOutput

func (ClusterMapOutput) ToClusterMapOutputWithContext added in v4.29.0 

func (o ClusterMapOutput) ToClusterMapOutputWithContext(ctx context.Context) ClusterMapOutput

type ClusterOutput added in v4.29.0 

type ClusterOutput struct{ *pulumi.OutputState }

func (ClusterOutput) ElementType added in v4.29.0 

func (ClusterOutput) ElementType() reflect.Type

func (ClusterOutput) ToClusterOutput added in v4.29.0 

func (o ClusterOutput) ToClusterOutput() ClusterOutput

func (ClusterOutput) ToClusterOutputWithContext added in v4.29.0 

func (o ClusterOutput) ToClusterOutputWithContext(ctx context.Context) ClusterOutput

type ClusterState added in v4.29.0 

type ClusterState struct {
	// The Azure Region where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	Location pulumi.StringPtrInput
	// The name which should be used for this Stream Analytics Cluster. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Cluster should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The number of streaming units supported by the Cluster. Accepted values are multiples of `36` in the range of `36` to `216`.
	StreamingCapacity pulumi.IntPtrInput
	// A mapping of tags which should be assigned to the Stream Analytics.
	Tags pulumi.StringMapInput
}

func (ClusterState) ElementType added in v4.29.0 

func (ClusterState) ElementType() reflect.Type

type FunctionJavaScriptUDF 

type FunctionJavaScriptUDF struct {
	pulumi.CustomResourceState

	// One or more `input` blocks as defined below.
	Inputs FunctionJavaScriptUDFInputTypeArrayOutput `pulumi:"inputs"`
	// The name of the JavaScript UDF Function. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// An `output` blocks as defined below.
	Output FunctionJavaScriptUDFOutputTypeOutput `pulumi:"output"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The JavaScript of this UDF Function.
	Script pulumi.StringOutput `pulumi:"script"`
	// The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a JavaScript UDF Function within Stream Analytics Streaming Job.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewFunctionJavaScriptUDF(ctx, "exampleFunctionJavaScriptUDF", &streamanalytics.FunctionJavaScriptUDFArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			Script:                 pulumi.String(fmt.Sprintf("%v%v%v", "function getRandomNumber(in) {\n", "  return in;\n", "}\n")),
			Inputs: streamanalytics.FunctionJavaScriptUDFInputArray{
				&streamanalytics.FunctionJavaScriptUDFInputArgs{
					Type: pulumi.String("bigint"),
				},
			},
			Output: streamanalytics.FunctionJavaScriptUDFOutputArgs{
				Type: pulumi.String("bigint"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics JavaScript UDF Functions can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/functionJavaScriptUDF:FunctionJavaScriptUDF example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetFunctionJavaScriptUDF 

func GetFunctionJavaScriptUDF(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *FunctionJavaScriptUDFState, opts ...pulumi.ResourceOption) (*FunctionJavaScriptUDF, error)

GetFunctionJavaScriptUDF gets an existing FunctionJavaScriptUDF 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 NewFunctionJavaScriptUDF 

func NewFunctionJavaScriptUDF(ctx *pulumi.Context,
	name string, args *FunctionJavaScriptUDFArgs, opts ...pulumi.ResourceOption) (*FunctionJavaScriptUDF, error)

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

func (*FunctionJavaScriptUDF) ElementType 

func (*FunctionJavaScriptUDF) ElementType() reflect.Type

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutput 

func (i *FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutput() FunctionJavaScriptUDFOutput

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutputWithContext 

func (i *FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutput

type FunctionJavaScriptUDFArgs 

type FunctionJavaScriptUDFArgs struct {
	// One or more `input` blocks as defined below.
	Inputs FunctionJavaScriptUDFInputTypeArrayInput
	// The name of the JavaScript UDF Function. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// An `output` blocks as defined below.
	Output FunctionJavaScriptUDFOutputTypeInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The JavaScript of this UDF Function.
	Script pulumi.StringInput
	// The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a FunctionJavaScriptUDF resource.

func (FunctionJavaScriptUDFArgs) ElementType 

func (FunctionJavaScriptUDFArgs) ElementType() reflect.Type

type FunctionJavaScriptUDFArray 

type FunctionJavaScriptUDFArray []FunctionJavaScriptUDFInput

func (FunctionJavaScriptUDFArray) ElementType 

func (FunctionJavaScriptUDFArray) ElementType() reflect.Type

func (FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutput 

func (i FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutput() FunctionJavaScriptUDFArrayOutput

func (FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutputWithContext 

func (i FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutputWithContext(ctx context.Context) FunctionJavaScriptUDFArrayOutput

type FunctionJavaScriptUDFArrayInput 

type FunctionJavaScriptUDFArrayInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFArrayOutput() FunctionJavaScriptUDFArrayOutput
	ToFunctionJavaScriptUDFArrayOutputWithContext(context.Context) FunctionJavaScriptUDFArrayOutput
}

FunctionJavaScriptUDFArrayInput is an input type that accepts FunctionJavaScriptUDFArray and FunctionJavaScriptUDFArrayOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFArrayInput` via: 

FunctionJavaScriptUDFArray{ FunctionJavaScriptUDFArgs{...} }

type FunctionJavaScriptUDFArrayOutput 

type FunctionJavaScriptUDFArrayOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFArrayOutput) ElementType 

func (FunctionJavaScriptUDFArrayOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFArrayOutput) Index 

func (o FunctionJavaScriptUDFArrayOutput) Index(i pulumi.IntInput) FunctionJavaScriptUDFOutput

func (FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutput 

func (o FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutput() FunctionJavaScriptUDFArrayOutput

func (FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutputWithContext 

func (o FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutputWithContext(ctx context.Context) FunctionJavaScriptUDFArrayOutput

type FunctionJavaScriptUDFInput 

type FunctionJavaScriptUDFInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFOutput() FunctionJavaScriptUDFOutput
	ToFunctionJavaScriptUDFOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutput
}

type FunctionJavaScriptUDFInputType 

type FunctionJavaScriptUDFInputType struct {
	// The Data Type for the Input Argument of this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.
	Type string `pulumi:"type"`
}

type FunctionJavaScriptUDFInputTypeArgs 

type FunctionJavaScriptUDFInputTypeArgs struct {
	// The Data Type for the Input Argument of this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (FunctionJavaScriptUDFInputTypeArgs) ElementType 

func (FunctionJavaScriptUDFInputTypeArgs) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutput 

func (i FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutput() FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutputWithContext 

func (i FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutputWithContext(ctx context.Context) FunctionJavaScriptUDFInputTypeOutput

type FunctionJavaScriptUDFInputTypeArray 

type FunctionJavaScriptUDFInputTypeArray []FunctionJavaScriptUDFInputTypeInput

func (FunctionJavaScriptUDFInputTypeArray) ElementType 

func (FunctionJavaScriptUDFInputTypeArray) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutput 

func (i FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutput() FunctionJavaScriptUDFInputTypeArrayOutput

func (FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext 

func (i FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext(ctx context.Context) FunctionJavaScriptUDFInputTypeArrayOutput

type FunctionJavaScriptUDFInputTypeArrayInput 

type FunctionJavaScriptUDFInputTypeArrayInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFInputTypeArrayOutput() FunctionJavaScriptUDFInputTypeArrayOutput
	ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext(context.Context) FunctionJavaScriptUDFInputTypeArrayOutput
}

FunctionJavaScriptUDFInputTypeArrayInput is an input type that accepts FunctionJavaScriptUDFInputTypeArray and FunctionJavaScriptUDFInputTypeArrayOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFInputTypeArrayInput` via: 

FunctionJavaScriptUDFInputTypeArray{ FunctionJavaScriptUDFInputTypeArgs{...} }

type FunctionJavaScriptUDFInputTypeArrayOutput 

type FunctionJavaScriptUDFInputTypeArrayOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFInputTypeArrayOutput) ElementType 

func (FunctionJavaScriptUDFInputTypeArrayOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArrayOutput) Index 

func (o FunctionJavaScriptUDFInputTypeArrayOutput) Index(i pulumi.IntInput) FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutput 

func (o FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutput() FunctionJavaScriptUDFInputTypeArrayOutput

func (FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext 

func (o FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext(ctx context.Context) FunctionJavaScriptUDFInputTypeArrayOutput

type FunctionJavaScriptUDFInputTypeInput 

type FunctionJavaScriptUDFInputTypeInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFInputTypeOutput() FunctionJavaScriptUDFInputTypeOutput
	ToFunctionJavaScriptUDFInputTypeOutputWithContext(context.Context) FunctionJavaScriptUDFInputTypeOutput
}

FunctionJavaScriptUDFInputTypeInput is an input type that accepts FunctionJavaScriptUDFInputTypeArgs and FunctionJavaScriptUDFInputTypeOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFInputTypeInput` via: 

FunctionJavaScriptUDFInputTypeArgs{...}

type FunctionJavaScriptUDFInputTypeOutput 

type FunctionJavaScriptUDFInputTypeOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFInputTypeOutput) ElementType 

func (FunctionJavaScriptUDFInputTypeOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutput 

func (o FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutput() FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutputWithContext 

func (o FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutputWithContext(ctx context.Context) FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeOutput) Type 

func (o FunctionJavaScriptUDFInputTypeOutput) Type() pulumi.StringOutput

The Data Type for the Input Argument of this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.

type FunctionJavaScriptUDFMap 

type FunctionJavaScriptUDFMap map[string]FunctionJavaScriptUDFInput

func (FunctionJavaScriptUDFMap) ElementType 

func (FunctionJavaScriptUDFMap) ElementType() reflect.Type

func (FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutput 

func (i FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutput() FunctionJavaScriptUDFMapOutput

func (FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutputWithContext 

func (i FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutputWithContext(ctx context.Context) FunctionJavaScriptUDFMapOutput

type FunctionJavaScriptUDFMapInput 

type FunctionJavaScriptUDFMapInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFMapOutput() FunctionJavaScriptUDFMapOutput
	ToFunctionJavaScriptUDFMapOutputWithContext(context.Context) FunctionJavaScriptUDFMapOutput
}

FunctionJavaScriptUDFMapInput is an input type that accepts FunctionJavaScriptUDFMap and FunctionJavaScriptUDFMapOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFMapInput` via: 

FunctionJavaScriptUDFMap{ "key": FunctionJavaScriptUDFArgs{...} }

type FunctionJavaScriptUDFMapOutput 

type FunctionJavaScriptUDFMapOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFMapOutput) ElementType 

func (FunctionJavaScriptUDFMapOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFMapOutput) MapIndex 

func (o FunctionJavaScriptUDFMapOutput) MapIndex(k pulumi.StringInput) FunctionJavaScriptUDFOutput

func (FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutput 

func (o FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutput() FunctionJavaScriptUDFMapOutput

func (FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutputWithContext 

func (o FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutputWithContext(ctx context.Context) FunctionJavaScriptUDFMapOutput

type FunctionJavaScriptUDFOutput 

type FunctionJavaScriptUDFOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFOutput) ElementType 

func (FunctionJavaScriptUDFOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutput 

func (o FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutput() FunctionJavaScriptUDFOutput

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutputWithContext 

func (o FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutput

type FunctionJavaScriptUDFOutputType 

type FunctionJavaScriptUDFOutputType struct {
	// The Data Type output from this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.
	Type string `pulumi:"type"`
}

type FunctionJavaScriptUDFOutputTypeArgs 

type FunctionJavaScriptUDFOutputTypeArgs struct {
	// The Data Type output from this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (FunctionJavaScriptUDFOutputTypeArgs) ElementType 

func (FunctionJavaScriptUDFOutputTypeArgs) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutput 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutput() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutputWithContext 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutput 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutputTypePtrOutput

type FunctionJavaScriptUDFOutputTypeInput 

type FunctionJavaScriptUDFOutputTypeInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFOutputTypeOutput() FunctionJavaScriptUDFOutputTypeOutput
	ToFunctionJavaScriptUDFOutputTypeOutputWithContext(context.Context) FunctionJavaScriptUDFOutputTypeOutput
}

FunctionJavaScriptUDFOutputTypeInput is an input type that accepts FunctionJavaScriptUDFOutputTypeArgs and FunctionJavaScriptUDFOutputTypeOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFOutputTypeInput` via: 

FunctionJavaScriptUDFOutputTypeArgs{...}

type FunctionJavaScriptUDFOutputTypeOutput 

type FunctionJavaScriptUDFOutputTypeOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFOutputTypeOutput) ElementType 

func (FunctionJavaScriptUDFOutputTypeOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutput 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutput() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutputWithContext 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypeOutput) Type 

func (o FunctionJavaScriptUDFOutputTypeOutput) Type() pulumi.StringOutput

The Data Type output from this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.

type FunctionJavaScriptUDFOutputTypePtrInput 

type FunctionJavaScriptUDFOutputTypePtrInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput
	ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext(context.Context) FunctionJavaScriptUDFOutputTypePtrOutput
}

FunctionJavaScriptUDFOutputTypePtrInput is an input type that accepts FunctionJavaScriptUDFOutputTypeArgs, FunctionJavaScriptUDFOutputTypePtr and FunctionJavaScriptUDFOutputTypePtrOutput values. You can construct a concrete instance of `FunctionJavaScriptUDFOutputTypePtrInput` via: 

        FunctionJavaScriptUDFOutputTypeArgs{...}

or:

        nil

func FunctionJavaScriptUDFOutputTypePtr 

func FunctionJavaScriptUDFOutputTypePtr(v *FunctionJavaScriptUDFOutputTypeArgs) FunctionJavaScriptUDFOutputTypePtrInput

type FunctionJavaScriptUDFOutputTypePtrOutput 

type FunctionJavaScriptUDFOutputTypePtrOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFOutputTypePtrOutput) Elem 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) Elem() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypePtrOutput) ElementType 

func (FunctionJavaScriptUDFOutputTypePtrOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypePtrOutput) Type 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) Type() pulumi.StringPtrOutput

The Data Type output from this JavaScript Function. Possible values include `array`, `any`, `bigint`, `datetime`, `float`, `nvarchar(max)` and `record`.

type FunctionJavaScriptUDFState 

type FunctionJavaScriptUDFState struct {
	// One or more `input` blocks as defined below.
	Inputs FunctionJavaScriptUDFInputTypeArrayInput
	// The name of the JavaScript UDF Function. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// An `output` blocks as defined below.
	Output FunctionJavaScriptUDFOutputTypePtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The JavaScript of this UDF Function.
	Script pulumi.StringPtrInput
	// The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (FunctionJavaScriptUDFState) ElementType 

func (FunctionJavaScriptUDFState) ElementType() reflect.Type

type GetJobIdentity added in v4.8.0 

type GetJobIdentity struct {
	// The ID of the Principal (Client) in Azure Active Directory.
	PrincipalId string `pulumi:"principalId"`
	// The ID of the Azure Active Directory Tenant.
	TenantId string `pulumi:"tenantId"`
	// The type of identity used for the Stream Analytics Job.
	Type string `pulumi:"type"`
}

type GetJobIdentityArgs added in v4.8.0 

type GetJobIdentityArgs struct {
	// The ID of the Principal (Client) in Azure Active Directory.
	PrincipalId pulumi.StringInput `pulumi:"principalId"`
	// The ID of the Azure Active Directory Tenant.
	TenantId pulumi.StringInput `pulumi:"tenantId"`
	// The type of identity used for the Stream Analytics Job.
	Type pulumi.StringInput `pulumi:"type"`
}

func (GetJobIdentityArgs) ElementType added in v4.8.0 

func (GetJobIdentityArgs) ElementType() reflect.Type

func (GetJobIdentityArgs) ToGetJobIdentityOutput added in v4.8.0 

func (i GetJobIdentityArgs) ToGetJobIdentityOutput() GetJobIdentityOutput

func (GetJobIdentityArgs) ToGetJobIdentityOutputWithContext added in v4.8.0 

func (i GetJobIdentityArgs) ToGetJobIdentityOutputWithContext(ctx context.Context) GetJobIdentityOutput

type GetJobIdentityArray added in v4.8.0 

type GetJobIdentityArray []GetJobIdentityInput

func (GetJobIdentityArray) ElementType added in v4.8.0 

func (GetJobIdentityArray) ElementType() reflect.Type

func (GetJobIdentityArray) ToGetJobIdentityArrayOutput added in v4.8.0 

func (i GetJobIdentityArray) ToGetJobIdentityArrayOutput() GetJobIdentityArrayOutput

func (GetJobIdentityArray) ToGetJobIdentityArrayOutputWithContext added in v4.8.0 

func (i GetJobIdentityArray) ToGetJobIdentityArrayOutputWithContext(ctx context.Context) GetJobIdentityArrayOutput

type GetJobIdentityArrayInput added in v4.8.0 

type GetJobIdentityArrayInput interface {
	pulumi.Input

	ToGetJobIdentityArrayOutput() GetJobIdentityArrayOutput
	ToGetJobIdentityArrayOutputWithContext(context.Context) GetJobIdentityArrayOutput
}

GetJobIdentityArrayInput is an input type that accepts GetJobIdentityArray and GetJobIdentityArrayOutput values. You can construct a concrete instance of `GetJobIdentityArrayInput` via: 

GetJobIdentityArray{ GetJobIdentityArgs{...} }

type GetJobIdentityArrayOutput added in v4.8.0 

type GetJobIdentityArrayOutput struct{ *pulumi.OutputState }

func (GetJobIdentityArrayOutput) ElementType added in v4.8.0 

func (GetJobIdentityArrayOutput) ElementType() reflect.Type

func (GetJobIdentityArrayOutput) Index added in v4.8.0 

func (o GetJobIdentityArrayOutput) Index(i pulumi.IntInput) GetJobIdentityOutput

func (GetJobIdentityArrayOutput) ToGetJobIdentityArrayOutput added in v4.8.0 

func (o GetJobIdentityArrayOutput) ToGetJobIdentityArrayOutput() GetJobIdentityArrayOutput

func (GetJobIdentityArrayOutput) ToGetJobIdentityArrayOutputWithContext added in v4.8.0 

func (o GetJobIdentityArrayOutput) ToGetJobIdentityArrayOutputWithContext(ctx context.Context) GetJobIdentityArrayOutput

type GetJobIdentityInput added in v4.8.0 

type GetJobIdentityInput interface {
	pulumi.Input

	ToGetJobIdentityOutput() GetJobIdentityOutput
	ToGetJobIdentityOutputWithContext(context.Context) GetJobIdentityOutput
}

GetJobIdentityInput is an input type that accepts GetJobIdentityArgs and GetJobIdentityOutput values. You can construct a concrete instance of `GetJobIdentityInput` via: 

GetJobIdentityArgs{...}

type GetJobIdentityOutput added in v4.8.0 

type GetJobIdentityOutput struct{ *pulumi.OutputState }

func (GetJobIdentityOutput) ElementType added in v4.8.0 

func (GetJobIdentityOutput) ElementType() reflect.Type

func (GetJobIdentityOutput) PrincipalId added in v4.8.0 

func (o GetJobIdentityOutput) PrincipalId() pulumi.StringOutput

The ID of the Principal (Client) in Azure Active Directory.

func (GetJobIdentityOutput) TenantId added in v4.8.0 

func (o GetJobIdentityOutput) TenantId() pulumi.StringOutput

The ID of the Azure Active Directory Tenant.

func (GetJobIdentityOutput) ToGetJobIdentityOutput added in v4.8.0 

func (o GetJobIdentityOutput) ToGetJobIdentityOutput() GetJobIdentityOutput

func (GetJobIdentityOutput) ToGetJobIdentityOutputWithContext added in v4.8.0 

func (o GetJobIdentityOutput) ToGetJobIdentityOutputWithContext(ctx context.Context) GetJobIdentityOutput

func (GetJobIdentityOutput) Type added in v4.8.0 

func (o GetJobIdentityOutput) Type() pulumi.StringOutput

The type of identity used for the Stream Analytics Job.

type Job 

type Job struct {
	pulumi.CustomResourceState

	// Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are `1.0`, `1.1` and `1.2`.
	CompatibilityLevel pulumi.StringOutput `pulumi:"compatibilityLevel"`
	// Specifies the Data Locale of the Job, which [should be a supported .NET Culture](<https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx>).
	DataLocale pulumi.StringOutput `pulumi:"dataLocale"`
	// Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is `-1` (indefinite) to `1814399` (20d 23h 59m 59s).  Default is `0`.
	EventsLateArrivalMaxDelayInSeconds pulumi.IntPtrOutput `pulumi:"eventsLateArrivalMaxDelayInSeconds"`
	// Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is `0` to `599` (9m 59s). Default is `5`.
	EventsOutOfOrderMaxDelayInSeconds pulumi.IntPtrOutput `pulumi:"eventsOutOfOrderMaxDelayInSeconds"`
	// Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are `Adjust` and `Drop`.  Default is `Adjust`.
	EventsOutOfOrderPolicy pulumi.StringPtrOutput `pulumi:"eventsOutOfOrderPolicy"`
	// An `identity` block as defined below.
	Identity JobIdentityPtrOutput `pulumi:"identity"`
	// The Job ID assigned by the Stream Analytics Job.
	JobId pulumi.StringOutput `pulumi:"jobId"`
	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location pulumi.StringOutput `pulumi:"location"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are `Drop` and `Stop`.  Default is `Drop`.
	OutputErrorPolicy pulumi.StringPtrOutput `pulumi:"outputErrorPolicy"`
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
	StreamAnalyticsClusterId pulumi.StringPtrOutput `pulumi:"streamAnalyticsClusterId"`
	// Specifies the number of streaming units that the streaming job uses. Supported values are `1`, `3`, `6` and multiples of `6` up to `120`.
	StreamingUnits pulumi.IntOutput `pulumi:"streamingUnits"`
	// A mapping of tags assigned to the resource.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// Specifies the query that will be run in the streaming job, [written in Stream Analytics Query Language (SAQL)](https://msdn.microsoft.com/library/azure/dn834998).
	TransformationQuery pulumi.StringOutput `pulumi:"transformationQuery"`
}

Manages a Stream Analytics Job.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", &core.ResourceGroupArgs{
			Location: pulumi.String("West Europe"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewJob(ctx, "exampleJob", &streamanalytics.JobArgs{
			ResourceGroupName:                  exampleResourceGroup.Name,
			Location:                           exampleResourceGroup.Location,
			CompatibilityLevel:                 pulumi.String("1.2"),
			DataLocale:                         pulumi.String("en-GB"),
			EventsLateArrivalMaxDelayInSeconds: pulumi.Int(60),
			EventsOutOfOrderMaxDelayInSeconds:  pulumi.Int(50),
			EventsOutOfOrderPolicy:             pulumi.String("Adjust"),
			OutputErrorPolicy:                  pulumi.String("Drop"),
			StreamingUnits:                     pulumi.Int(3),
			Tags: pulumi.StringMap{
				"environment": pulumi.String("Example"),
			},
			TransformationQuery: pulumi.String(fmt.Sprintf("%v%v%v", "    SELECT *\n", "    INTO [YourOutputAlias]\n", "    FROM [YourInputAlias]\n")),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Job's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/job:Job example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1

```

func GetJob 

func GetJob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *JobState, opts ...pulumi.ResourceOption) (*Job, error)

GetJob gets an existing Job 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 NewJob 

func NewJob(ctx *pulumi.Context,
	name string, args *JobArgs, opts ...pulumi.ResourceOption) (*Job, error)

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

func (*Job) ElementType 

func (*Job) ElementType() reflect.Type

func (*Job) ToJobOutput 

func (i *Job) ToJobOutput() JobOutput

func (*Job) ToJobOutputWithContext 

func (i *Job) ToJobOutputWithContext(ctx context.Context) JobOutput

type JobArgs 

type JobArgs struct {
	// Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are `1.0`, `1.1` and `1.2`.
	CompatibilityLevel pulumi.StringPtrInput
	// Specifies the Data Locale of the Job, which [should be a supported .NET Culture](<https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx>).
	DataLocale pulumi.StringPtrInput
	// Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is `-1` (indefinite) to `1814399` (20d 23h 59m 59s).  Default is `0`.
	EventsLateArrivalMaxDelayInSeconds pulumi.IntPtrInput
	// Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is `0` to `599` (9m 59s). Default is `5`.
	EventsOutOfOrderMaxDelayInSeconds pulumi.IntPtrInput
	// Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are `Adjust` and `Drop`.  Default is `Adjust`.
	EventsOutOfOrderPolicy pulumi.StringPtrInput
	// An `identity` block as defined below.
	Identity JobIdentityPtrInput
	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are `Drop` and `Stop`.  Default is `Drop`.
	OutputErrorPolicy pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
	StreamAnalyticsClusterId pulumi.StringPtrInput
	// Specifies the number of streaming units that the streaming job uses. Supported values are `1`, `3`, `6` and multiples of `6` up to `120`.
	StreamingUnits pulumi.IntInput
	// A mapping of tags assigned to the resource.
	Tags pulumi.StringMapInput
	// Specifies the query that will be run in the streaming job, [written in Stream Analytics Query Language (SAQL)](https://msdn.microsoft.com/library/azure/dn834998).
	TransformationQuery pulumi.StringInput
}

The set of arguments for constructing a Job resource.

func (JobArgs) ElementType 

func (JobArgs) ElementType() reflect.Type

type JobArray 

type JobArray []JobInput

func (JobArray) ElementType 

func (JobArray) ElementType() reflect.Type

func (JobArray) ToJobArrayOutput 

func (i JobArray) ToJobArrayOutput() JobArrayOutput

func (JobArray) ToJobArrayOutputWithContext 

func (i JobArray) ToJobArrayOutputWithContext(ctx context.Context) JobArrayOutput

type JobArrayInput 

type JobArrayInput interface {
	pulumi.Input

	ToJobArrayOutput() JobArrayOutput
	ToJobArrayOutputWithContext(context.Context) JobArrayOutput
}

JobArrayInput is an input type that accepts JobArray and JobArrayOutput values. You can construct a concrete instance of `JobArrayInput` via: 

JobArray{ JobArgs{...} }

type JobArrayOutput 

type JobArrayOutput struct{ *pulumi.OutputState }

func (JobArrayOutput) ElementType 

func (JobArrayOutput) ElementType() reflect.Type

func (JobArrayOutput) Index 

func (o JobArrayOutput) Index(i pulumi.IntInput) JobOutput

func (JobArrayOutput) ToJobArrayOutput 

func (o JobArrayOutput) ToJobArrayOutput() JobArrayOutput

func (JobArrayOutput) ToJobArrayOutputWithContext 

func (o JobArrayOutput) ToJobArrayOutputWithContext(ctx context.Context) JobArrayOutput

type JobIdentity added in v4.8.0 

type JobIdentity struct {
	// The ID of the Principal (Client) in Azure Active Directory.
	PrincipalId *string `pulumi:"principalId"`
	// The ID of the Azure Active Directory Tenant.
	TenantId *string `pulumi:"tenantId"`
	// The type of identity used for the Stream Analytics Job. The only possible value is `SystemAssigned`.
	Type string `pulumi:"type"`
}

type JobIdentityArgs added in v4.8.0 

type JobIdentityArgs struct {
	// The ID of the Principal (Client) in Azure Active Directory.
	PrincipalId pulumi.StringPtrInput `pulumi:"principalId"`
	// The ID of the Azure Active Directory Tenant.
	TenantId pulumi.StringPtrInput `pulumi:"tenantId"`
	// The type of identity used for the Stream Analytics Job. The only possible value is `SystemAssigned`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (JobIdentityArgs) ElementType added in v4.8.0 

func (JobIdentityArgs) ElementType() reflect.Type

func (JobIdentityArgs) ToJobIdentityOutput added in v4.8.0 

func (i JobIdentityArgs) ToJobIdentityOutput() JobIdentityOutput

func (JobIdentityArgs) ToJobIdentityOutputWithContext added in v4.8.0 

func (i JobIdentityArgs) ToJobIdentityOutputWithContext(ctx context.Context) JobIdentityOutput

func (JobIdentityArgs) ToJobIdentityPtrOutput added in v4.8.0 

func (i JobIdentityArgs) ToJobIdentityPtrOutput() JobIdentityPtrOutput

func (JobIdentityArgs) ToJobIdentityPtrOutputWithContext added in v4.8.0 

func (i JobIdentityArgs) ToJobIdentityPtrOutputWithContext(ctx context.Context) JobIdentityPtrOutput

type JobIdentityInput added in v4.8.0 

type JobIdentityInput interface {
	pulumi.Input

	ToJobIdentityOutput() JobIdentityOutput
	ToJobIdentityOutputWithContext(context.Context) JobIdentityOutput
}

JobIdentityInput is an input type that accepts JobIdentityArgs and JobIdentityOutput values. You can construct a concrete instance of `JobIdentityInput` via: 

JobIdentityArgs{...}

type JobIdentityOutput added in v4.8.0 

type JobIdentityOutput struct{ *pulumi.OutputState }

func (JobIdentityOutput) ElementType added in v4.8.0 

func (JobIdentityOutput) ElementType() reflect.Type

func (JobIdentityOutput) PrincipalId added in v4.8.0 

func (o JobIdentityOutput) PrincipalId() pulumi.StringPtrOutput

The ID of the Principal (Client) in Azure Active Directory.

func (JobIdentityOutput) TenantId added in v4.8.0 

func (o JobIdentityOutput) TenantId() pulumi.StringPtrOutput

The ID of the Azure Active Directory Tenant.

func (JobIdentityOutput) ToJobIdentityOutput added in v4.8.0 

func (o JobIdentityOutput) ToJobIdentityOutput() JobIdentityOutput

func (JobIdentityOutput) ToJobIdentityOutputWithContext added in v4.8.0 

func (o JobIdentityOutput) ToJobIdentityOutputWithContext(ctx context.Context) JobIdentityOutput

func (JobIdentityOutput) ToJobIdentityPtrOutput added in v4.8.0 

func (o JobIdentityOutput) ToJobIdentityPtrOutput() JobIdentityPtrOutput

func (JobIdentityOutput) ToJobIdentityPtrOutputWithContext added in v4.8.0 

func (o JobIdentityOutput) ToJobIdentityPtrOutputWithContext(ctx context.Context) JobIdentityPtrOutput

func (JobIdentityOutput) Type added in v4.8.0 

func (o JobIdentityOutput) Type() pulumi.StringOutput

The type of identity used for the Stream Analytics Job. The only possible value is `SystemAssigned`.

type JobIdentityPtrInput added in v4.8.0 

type JobIdentityPtrInput interface {
	pulumi.Input

	ToJobIdentityPtrOutput() JobIdentityPtrOutput
	ToJobIdentityPtrOutputWithContext(context.Context) JobIdentityPtrOutput
}

JobIdentityPtrInput is an input type that accepts JobIdentityArgs, JobIdentityPtr and JobIdentityPtrOutput values. You can construct a concrete instance of `JobIdentityPtrInput` via: 

        JobIdentityArgs{...}

or:

        nil

func JobIdentityPtr added in v4.8.0 

func JobIdentityPtr(v *JobIdentityArgs) JobIdentityPtrInput

type JobIdentityPtrOutput added in v4.8.0 

type JobIdentityPtrOutput struct{ *pulumi.OutputState }

func (JobIdentityPtrOutput) Elem added in v4.8.0 

func (o JobIdentityPtrOutput) Elem() JobIdentityOutput

func (JobIdentityPtrOutput) ElementType added in v4.8.0 

func (JobIdentityPtrOutput) ElementType() reflect.Type

func (JobIdentityPtrOutput) PrincipalId added in v4.8.0 

func (o JobIdentityPtrOutput) PrincipalId() pulumi.StringPtrOutput

The ID of the Principal (Client) in Azure Active Directory.

func (JobIdentityPtrOutput) TenantId added in v4.8.0 

func (o JobIdentityPtrOutput) TenantId() pulumi.StringPtrOutput

The ID of the Azure Active Directory Tenant.

func (JobIdentityPtrOutput) ToJobIdentityPtrOutput added in v4.8.0 

func (o JobIdentityPtrOutput) ToJobIdentityPtrOutput() JobIdentityPtrOutput

func (JobIdentityPtrOutput) ToJobIdentityPtrOutputWithContext added in v4.8.0 

func (o JobIdentityPtrOutput) ToJobIdentityPtrOutputWithContext(ctx context.Context) JobIdentityPtrOutput

func (JobIdentityPtrOutput) Type added in v4.8.0 

func (o JobIdentityPtrOutput) Type() pulumi.StringPtrOutput

The type of identity used for the Stream Analytics Job. The only possible value is `SystemAssigned`.

type JobInput 

type JobInput interface {
	pulumi.Input

	ToJobOutput() JobOutput
	ToJobOutputWithContext(ctx context.Context) JobOutput
}

type JobMap 

type JobMap map[string]JobInput

func (JobMap) ElementType 

func (JobMap) ElementType() reflect.Type

func (JobMap) ToJobMapOutput 

func (i JobMap) ToJobMapOutput() JobMapOutput

func (JobMap) ToJobMapOutputWithContext 

func (i JobMap) ToJobMapOutputWithContext(ctx context.Context) JobMapOutput

type JobMapInput 

type JobMapInput interface {
	pulumi.Input

	ToJobMapOutput() JobMapOutput
	ToJobMapOutputWithContext(context.Context) JobMapOutput
}

JobMapInput is an input type that accepts JobMap and JobMapOutput values. You can construct a concrete instance of `JobMapInput` via: 

JobMap{ "key": JobArgs{...} }

type JobMapOutput 

type JobMapOutput struct{ *pulumi.OutputState }

func (JobMapOutput) ElementType 

func (JobMapOutput) ElementType() reflect.Type

func (JobMapOutput) MapIndex 

func (o JobMapOutput) MapIndex(k pulumi.StringInput) JobOutput

func (JobMapOutput) ToJobMapOutput 

func (o JobMapOutput) ToJobMapOutput() JobMapOutput

func (JobMapOutput) ToJobMapOutputWithContext 

func (o JobMapOutput) ToJobMapOutputWithContext(ctx context.Context) JobMapOutput

type JobOutput 

type JobOutput struct{ *pulumi.OutputState }

func (JobOutput) ElementType 

func (JobOutput) ElementType() reflect.Type

func (JobOutput) ToJobOutput 

func (o JobOutput) ToJobOutput() JobOutput

func (JobOutput) ToJobOutputWithContext 

func (o JobOutput) ToJobOutputWithContext(ctx context.Context) JobOutput

type JobState 

type JobState struct {
	// Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are `1.0`, `1.1` and `1.2`.
	CompatibilityLevel pulumi.StringPtrInput
	// Specifies the Data Locale of the Job, which [should be a supported .NET Culture](<https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx>).
	DataLocale pulumi.StringPtrInput
	// Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is `-1` (indefinite) to `1814399` (20d 23h 59m 59s).  Default is `0`.
	EventsLateArrivalMaxDelayInSeconds pulumi.IntPtrInput
	// Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is `0` to `599` (9m 59s). Default is `5`.
	EventsOutOfOrderMaxDelayInSeconds pulumi.IntPtrInput
	// Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are `Adjust` and `Drop`.  Default is `Adjust`.
	EventsOutOfOrderPolicy pulumi.StringPtrInput
	// An `identity` block as defined below.
	Identity JobIdentityPtrInput
	// The Job ID assigned by the Stream Analytics Job.
	JobId pulumi.StringPtrInput
	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are `Drop` and `Stop`.  Default is `Drop`.
	OutputErrorPolicy pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
	StreamAnalyticsClusterId pulumi.StringPtrInput
	// Specifies the number of streaming units that the streaming job uses. Supported values are `1`, `3`, `6` and multiples of `6` up to `120`.
	StreamingUnits pulumi.IntPtrInput
	// A mapping of tags assigned to the resource.
	Tags pulumi.StringMapInput
	// Specifies the query that will be run in the streaming job, [written in Stream Analytics Query Language (SAQL)](https://msdn.microsoft.com/library/azure/dn834998).
	TransformationQuery pulumi.StringPtrInput
}

func (JobState) ElementType 

func (JobState) ElementType() reflect.Type

type LookupJobArgs 

type LookupJobArgs struct {
	// Specifies the name of the Stream Analytics Job.
	Name string `pulumi:"name"`
	// Specifies the name of the resource group the Stream Analytics Job is located in.
	ResourceGroupName string `pulumi:"resourceGroupName"`
}

A collection of arguments for invoking getJob.

type LookupJobOutputArgs added in v4.20.0 

type LookupJobOutputArgs struct {
	// Specifies the name of the Stream Analytics Job.
	Name pulumi.StringInput `pulumi:"name"`
	// Specifies the name of the resource group the Stream Analytics Job is located in.
	ResourceGroupName pulumi.StringInput `pulumi:"resourceGroupName"`
}

A collection of arguments for invoking getJob.

func (LookupJobOutputArgs) ElementType added in v4.20.0 

func (LookupJobOutputArgs) ElementType() reflect.Type

type LookupJobResult 

type LookupJobResult struct {
	// The compatibility level for this job.
	CompatibilityLevel string `pulumi:"compatibilityLevel"`
	// The Data Locale of the Job.
	DataLocale string `pulumi:"dataLocale"`
	// The maximum tolerable delay in seconds where events arriving late could be included.
	EventsLateArrivalMaxDelayInSeconds int `pulumi:"eventsLateArrivalMaxDelayInSeconds"`
	// The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
	EventsOutOfOrderMaxDelayInSeconds int `pulumi:"eventsOutOfOrderMaxDelayInSeconds"`
	// The policy which should be applied to events which arrive out of order in the input event stream.
	EventsOutOfOrderPolicy string `pulumi:"eventsOutOfOrderPolicy"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// (Optional) An `identity` block as defined below.
	Identities []GetJobIdentity `pulumi:"identities"`
	// The Job ID assigned by the Stream Analytics Job.
	JobId string `pulumi:"jobId"`
	// The Azure location where the Stream Analytics Job exists.
	Location string `pulumi:"location"`
	Name     string `pulumi:"name"`
	// The policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size).
	OutputErrorPolicy string `pulumi:"outputErrorPolicy"`
	ResourceGroupName string `pulumi:"resourceGroupName"`
	// The number of streaming units that the streaming job uses.
	StreamingUnits int `pulumi:"streamingUnits"`
	// The query that will be run in the streaming job, [written in Stream Analytics Query Language (SAQL)](https://msdn.microsoft.com/library/azure/dn834998).
	TransformationQuery string `pulumi:"transformationQuery"`
}

A collection of values returned by getJob.

func LookupJob 

func LookupJob(ctx *pulumi.Context, args *LookupJobArgs, opts ...pulumi.InvokeOption) (*LookupJobResult, error)

Use this data source to access information about an existing Stream Analytics Job.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("jobId", example.JobId)
		return nil
	})
}

```

type LookupJobResultOutput added in v4.20.0 

type LookupJobResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getJob.

func LookupJobOutput added in v4.20.0 

func LookupJobOutput(ctx *pulumi.Context, args LookupJobOutputArgs, opts ...pulumi.InvokeOption) LookupJobResultOutput

func (LookupJobResultOutput) CompatibilityLevel added in v4.20.0 

func (o LookupJobResultOutput) CompatibilityLevel() pulumi.StringOutput

The compatibility level for this job.

func (LookupJobResultOutput) DataLocale added in v4.20.0 

func (o LookupJobResultOutput) DataLocale() pulumi.StringOutput

The Data Locale of the Job.

func (LookupJobResultOutput) ElementType added in v4.20.0 

func (LookupJobResultOutput) ElementType() reflect.Type

func (LookupJobResultOutput) EventsLateArrivalMaxDelayInSeconds added in v4.20.0 

func (o LookupJobResultOutput) EventsLateArrivalMaxDelayInSeconds() pulumi.IntOutput

The maximum tolerable delay in seconds where events arriving late could be included.

func (LookupJobResultOutput) EventsOutOfOrderMaxDelayInSeconds added in v4.20.0 

func (o LookupJobResultOutput) EventsOutOfOrderMaxDelayInSeconds() pulumi.IntOutput

The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.

func (LookupJobResultOutput) EventsOutOfOrderPolicy added in v4.20.0 

func (o LookupJobResultOutput) EventsOutOfOrderPolicy() pulumi.StringOutput

The policy which should be applied to events which arrive out of order in the input event stream.

func (LookupJobResultOutput) Id added in v4.20.0 

func (o LookupJobResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupJobResultOutput) Identities added in v4.20.0 

func (o LookupJobResultOutput) Identities() GetJobIdentityArrayOutput

(Optional) An `identity` block as defined below.

func (LookupJobResultOutput) JobId added in v4.20.0 

func (o LookupJobResultOutput) JobId() pulumi.StringOutput

The Job ID assigned by the Stream Analytics Job.

func (LookupJobResultOutput) Location added in v4.20.0 

func (o LookupJobResultOutput) Location() pulumi.StringOutput

The Azure location where the Stream Analytics Job exists.

func (LookupJobResultOutput) Name added in v4.20.0 

func (o LookupJobResultOutput) Name() pulumi.StringOutput

func (LookupJobResultOutput) OutputErrorPolicy added in v4.20.0 

func (o LookupJobResultOutput) OutputErrorPolicy() pulumi.StringOutput

The policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size).

func (LookupJobResultOutput) ResourceGroupName added in v4.20.0 

func (o LookupJobResultOutput) ResourceGroupName() pulumi.StringOutput

func (LookupJobResultOutput) StreamingUnits added in v4.20.0 

func (o LookupJobResultOutput) StreamingUnits() pulumi.IntOutput

The number of streaming units that the streaming job uses.

func (LookupJobResultOutput) ToLookupJobResultOutput added in v4.20.0 

func (o LookupJobResultOutput) ToLookupJobResultOutput() LookupJobResultOutput

func (LookupJobResultOutput) ToLookupJobResultOutputWithContext added in v4.20.0 

func (o LookupJobResultOutput) ToLookupJobResultOutputWithContext(ctx context.Context) LookupJobResultOutput

func (LookupJobResultOutput) TransformationQuery added in v4.20.0 

func (o LookupJobResultOutput) TransformationQuery() pulumi.StringOutput

The query that will be run in the streaming job, [written in Stream Analytics Query Language (SAQL)](https://msdn.microsoft.com/library/azure/dn834998).

type ManagedPrivateEndpoint added in v4.29.0 

type ManagedPrivateEndpoint struct {
	pulumi.CustomResourceState

	// The name which should be used for this Stream Analytics Managed Private Endpoint. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the Resource Group where the Stream Analytics Managed Private Endpoint should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The name of the Stream Analytics Cluster where the Managed Private Endpoint should be created. Changing this forces a new resource to be created.
	StreamAnalyticsClusterName pulumi.StringOutput `pulumi:"streamAnalyticsClusterName"`
	// Specifies the sub resource name which the Stream Analytics Private Endpoint is able to connect to. Changing this forces a new resource to be created.
	SubresourceName pulumi.StringOutput `pulumi:"subresourceName"`
	// The ID of the Private Link Enabled Remote Resource which this Stream Analytics Private endpoint should be connected to. Changing this forces a new resource to be created.
	TargetResourceId pulumi.StringOutput `pulumi:"targetResourceId"`
}

Manages a Stream Analytics Managed Private Endpoint.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", &core.ResourceGroupArgs{
			Location: pulumi.String("West Europe"),
		})
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      exampleResourceGroup.Name,
			Location:               exampleResourceGroup.Location,
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
			AccountKind:            pulumi.String("StorageV2"),
			IsHnsEnabled:           pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		exampleCluster, err := streamanalytics.NewCluster(ctx, "exampleCluster", &streamanalytics.ClusterArgs{
			ResourceGroupName: exampleResourceGroup.Name,
			Location:          exampleResourceGroup.Location,
			StreamingCapacity: pulumi.Int(36),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewManagedPrivateEndpoint(ctx, "exampleManagedPrivateEndpoint", &streamanalytics.ManagedPrivateEndpointArgs{
			ResourceGroupName:          exampleResourceGroup.Name,
			StreamAnalyticsClusterName: exampleCluster.Name,
			TargetResourceId:           exampleAccount.ID(),
			SubresourceName:            pulumi.String("blob"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Private Endpoints can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/managedPrivateEndpoint:ManagedPrivateEndpoint example /subscriptions/12345678-1234-9876-4563-123456789012/resourceGroups/resGroup1/providers/Microsoft.StreamAnalytics/clusters/cluster1/privateEndpoints/endpoint1

```

func GetManagedPrivateEndpoint added in v4.29.0 

func GetManagedPrivateEndpoint(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ManagedPrivateEndpointState, opts ...pulumi.ResourceOption) (*ManagedPrivateEndpoint, error)

GetManagedPrivateEndpoint gets an existing ManagedPrivateEndpoint 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 NewManagedPrivateEndpoint added in v4.29.0 

func NewManagedPrivateEndpoint(ctx *pulumi.Context,
	name string, args *ManagedPrivateEndpointArgs, opts ...pulumi.ResourceOption) (*ManagedPrivateEndpoint, error)

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

func (*ManagedPrivateEndpoint) ElementType added in v4.29.0 

func (*ManagedPrivateEndpoint) ElementType() reflect.Type

func (*ManagedPrivateEndpoint) ToManagedPrivateEndpointOutput added in v4.29.0 

func (i *ManagedPrivateEndpoint) ToManagedPrivateEndpointOutput() ManagedPrivateEndpointOutput

func (*ManagedPrivateEndpoint) ToManagedPrivateEndpointOutputWithContext added in v4.29.0 

func (i *ManagedPrivateEndpoint) ToManagedPrivateEndpointOutputWithContext(ctx context.Context) ManagedPrivateEndpointOutput

type ManagedPrivateEndpointArgs added in v4.29.0 

type ManagedPrivateEndpointArgs struct {
	// The name which should be used for this Stream Analytics Managed Private Endpoint. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Managed Private Endpoint should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The name of the Stream Analytics Cluster where the Managed Private Endpoint should be created. Changing this forces a new resource to be created.
	StreamAnalyticsClusterName pulumi.StringInput
	// Specifies the sub resource name which the Stream Analytics Private Endpoint is able to connect to. Changing this forces a new resource to be created.
	SubresourceName pulumi.StringInput
	// The ID of the Private Link Enabled Remote Resource which this Stream Analytics Private endpoint should be connected to. Changing this forces a new resource to be created.
	TargetResourceId pulumi.StringInput
}

The set of arguments for constructing a ManagedPrivateEndpoint resource.

func (ManagedPrivateEndpointArgs) ElementType added in v4.29.0 

func (ManagedPrivateEndpointArgs) ElementType() reflect.Type

type ManagedPrivateEndpointArray added in v4.29.0 

type ManagedPrivateEndpointArray []ManagedPrivateEndpointInput

func (ManagedPrivateEndpointArray) ElementType added in v4.29.0 

func (ManagedPrivateEndpointArray) ElementType() reflect.Type

func (ManagedPrivateEndpointArray) ToManagedPrivateEndpointArrayOutput added in v4.29.0 

func (i ManagedPrivateEndpointArray) ToManagedPrivateEndpointArrayOutput() ManagedPrivateEndpointArrayOutput

func (ManagedPrivateEndpointArray) ToManagedPrivateEndpointArrayOutputWithContext added in v4.29.0 

func (i ManagedPrivateEndpointArray) ToManagedPrivateEndpointArrayOutputWithContext(ctx context.Context) ManagedPrivateEndpointArrayOutput

type ManagedPrivateEndpointArrayInput added in v4.29.0 

type ManagedPrivateEndpointArrayInput interface {
	pulumi.Input

	ToManagedPrivateEndpointArrayOutput() ManagedPrivateEndpointArrayOutput
	ToManagedPrivateEndpointArrayOutputWithContext(context.Context) ManagedPrivateEndpointArrayOutput
}

ManagedPrivateEndpointArrayInput is an input type that accepts ManagedPrivateEndpointArray and ManagedPrivateEndpointArrayOutput values. You can construct a concrete instance of `ManagedPrivateEndpointArrayInput` via: 

ManagedPrivateEndpointArray{ ManagedPrivateEndpointArgs{...} }

type ManagedPrivateEndpointArrayOutput added in v4.29.0 

type ManagedPrivateEndpointArrayOutput struct{ *pulumi.OutputState }

func (ManagedPrivateEndpointArrayOutput) ElementType added in v4.29.0 

func (ManagedPrivateEndpointArrayOutput) ElementType() reflect.Type

func (ManagedPrivateEndpointArrayOutput) Index added in v4.29.0 

func (o ManagedPrivateEndpointArrayOutput) Index(i pulumi.IntInput) ManagedPrivateEndpointOutput

func (ManagedPrivateEndpointArrayOutput) ToManagedPrivateEndpointArrayOutput added in v4.29.0 

func (o ManagedPrivateEndpointArrayOutput) ToManagedPrivateEndpointArrayOutput() ManagedPrivateEndpointArrayOutput

func (ManagedPrivateEndpointArrayOutput) ToManagedPrivateEndpointArrayOutputWithContext added in v4.29.0 

func (o ManagedPrivateEndpointArrayOutput) ToManagedPrivateEndpointArrayOutputWithContext(ctx context.Context) ManagedPrivateEndpointArrayOutput

type ManagedPrivateEndpointInput added in v4.29.0 

type ManagedPrivateEndpointInput interface {
	pulumi.Input

	ToManagedPrivateEndpointOutput() ManagedPrivateEndpointOutput
	ToManagedPrivateEndpointOutputWithContext(ctx context.Context) ManagedPrivateEndpointOutput
}

type ManagedPrivateEndpointMap added in v4.29.0 

type ManagedPrivateEndpointMap map[string]ManagedPrivateEndpointInput

func (ManagedPrivateEndpointMap) ElementType added in v4.29.0 

func (ManagedPrivateEndpointMap) ElementType() reflect.Type

func (ManagedPrivateEndpointMap) ToManagedPrivateEndpointMapOutput added in v4.29.0 

func (i ManagedPrivateEndpointMap) ToManagedPrivateEndpointMapOutput() ManagedPrivateEndpointMapOutput

func (ManagedPrivateEndpointMap) ToManagedPrivateEndpointMapOutputWithContext added in v4.29.0 

func (i ManagedPrivateEndpointMap) ToManagedPrivateEndpointMapOutputWithContext(ctx context.Context) ManagedPrivateEndpointMapOutput

type ManagedPrivateEndpointMapInput added in v4.29.0 

type ManagedPrivateEndpointMapInput interface {
	pulumi.Input

	ToManagedPrivateEndpointMapOutput() ManagedPrivateEndpointMapOutput
	ToManagedPrivateEndpointMapOutputWithContext(context.Context) ManagedPrivateEndpointMapOutput
}

ManagedPrivateEndpointMapInput is an input type that accepts ManagedPrivateEndpointMap and ManagedPrivateEndpointMapOutput values. You can construct a concrete instance of `ManagedPrivateEndpointMapInput` via: 

ManagedPrivateEndpointMap{ "key": ManagedPrivateEndpointArgs{...} }

type ManagedPrivateEndpointMapOutput added in v4.29.0 

type ManagedPrivateEndpointMapOutput struct{ *pulumi.OutputState }

func (ManagedPrivateEndpointMapOutput) ElementType added in v4.29.0 

func (ManagedPrivateEndpointMapOutput) ElementType() reflect.Type

func (ManagedPrivateEndpointMapOutput) MapIndex added in v4.29.0 

func (o ManagedPrivateEndpointMapOutput) MapIndex(k pulumi.StringInput) ManagedPrivateEndpointOutput

func (ManagedPrivateEndpointMapOutput) ToManagedPrivateEndpointMapOutput added in v4.29.0 

func (o ManagedPrivateEndpointMapOutput) ToManagedPrivateEndpointMapOutput() ManagedPrivateEndpointMapOutput

func (ManagedPrivateEndpointMapOutput) ToManagedPrivateEndpointMapOutputWithContext added in v4.29.0 

func (o ManagedPrivateEndpointMapOutput) ToManagedPrivateEndpointMapOutputWithContext(ctx context.Context) ManagedPrivateEndpointMapOutput

type ManagedPrivateEndpointOutput added in v4.29.0 

type ManagedPrivateEndpointOutput struct{ *pulumi.OutputState }

func (ManagedPrivateEndpointOutput) ElementType added in v4.29.0 

func (ManagedPrivateEndpointOutput) ElementType() reflect.Type

func (ManagedPrivateEndpointOutput) ToManagedPrivateEndpointOutput added in v4.29.0 

func (o ManagedPrivateEndpointOutput) ToManagedPrivateEndpointOutput() ManagedPrivateEndpointOutput

func (ManagedPrivateEndpointOutput) ToManagedPrivateEndpointOutputWithContext added in v4.29.0 

func (o ManagedPrivateEndpointOutput) ToManagedPrivateEndpointOutputWithContext(ctx context.Context) ManagedPrivateEndpointOutput

type ManagedPrivateEndpointState added in v4.29.0 

type ManagedPrivateEndpointState struct {
	// The name which should be used for this Stream Analytics Managed Private Endpoint. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Managed Private Endpoint should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The name of the Stream Analytics Cluster where the Managed Private Endpoint should be created. Changing this forces a new resource to be created.
	StreamAnalyticsClusterName pulumi.StringPtrInput
	// Specifies the sub resource name which the Stream Analytics Private Endpoint is able to connect to. Changing this forces a new resource to be created.
	SubresourceName pulumi.StringPtrInput
	// The ID of the Private Link Enabled Remote Resource which this Stream Analytics Private endpoint should be connected to. Changing this forces a new resource to be created.
	TargetResourceId pulumi.StringPtrInput
}

func (ManagedPrivateEndpointState) ElementType added in v4.29.0 

func (ManagedPrivateEndpointState) ElementType() reflect.Type

type OutputBlob 

type OutputBlob struct {
	pulumi.CustomResourceState

	// The maximum wait time per batch in `hh:mm:ss` e.g. `00:02:00` for two minutes.
	BatchMaxWaitTime pulumi.StringPtrOutput `pulumi:"batchMaxWaitTime"`
	// The minimum number of rows per batch (must be between `0` and `10000`).
	BatchMinRows pulumi.Float64PtrOutput `pulumi:"batchMinRows"`
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringOutput `pulumi:"dateFormat"`
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringOutput `pulumi:"pathPattern"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization OutputBlobSerializationOutput `pulumi:"serialization"`
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringOutput `pulumi:"storageAccountKey"`
	// The name of the Storage Account.
	StorageAccountName pulumi.StringOutput `pulumi:"storageAccountName"`
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringOutput `pulumi:"storageContainerName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringOutput `pulumi:"timeFormat"`
}

Manages a Stream Analytics Output to Blob Storage.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      pulumi.String(exampleResourceGroup.Name),
			Location:               pulumi.String(exampleResourceGroup.Location),
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		exampleContainer, err := storage.NewContainer(ctx, "exampleContainer", &storage.ContainerArgs{
			StorageAccountName:  exampleAccount.Name,
			ContainerAccessType: pulumi.String("private"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputBlob(ctx, "exampleOutputBlob", &streamanalytics.OutputBlobArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			StorageAccountName:     exampleAccount.Name,
			StorageAccountKey:      exampleAccount.PrimaryAccessKey,
			StorageContainerName:   exampleContainer.Name,
			PathPattern:            pulumi.String("some-pattern"),
			DateFormat:             pulumi.String("yyyy-MM-dd"),
			TimeFormat:             pulumi.String("HH"),
			Serialization: &streamanalytics.OutputBlobSerializationArgs{
				Type:           pulumi.String("Csv"),
				Encoding:       pulumi.String("UTF8"),
				FieldDelimiter: pulumi.String(","),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Outputs to Blob Storage can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputBlob:OutputBlob example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputBlob 

func GetOutputBlob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputBlobState, opts ...pulumi.ResourceOption) (*OutputBlob, error)

GetOutputBlob gets an existing OutputBlob 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 NewOutputBlob 

func NewOutputBlob(ctx *pulumi.Context,
	name string, args *OutputBlobArgs, opts ...pulumi.ResourceOption) (*OutputBlob, error)

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

func (*OutputBlob) ElementType 

func (*OutputBlob) ElementType() reflect.Type

func (*OutputBlob) ToOutputBlobOutput 

func (i *OutputBlob) ToOutputBlobOutput() OutputBlobOutput

func (*OutputBlob) ToOutputBlobOutputWithContext 

func (i *OutputBlob) ToOutputBlobOutputWithContext(ctx context.Context) OutputBlobOutput

type OutputBlobArgs 

type OutputBlobArgs struct {
	// The maximum wait time per batch in `hh:mm:ss` e.g. `00:02:00` for two minutes.
	BatchMaxWaitTime pulumi.StringPtrInput
	// The minimum number of rows per batch (must be between `0` and `10000`).
	BatchMinRows pulumi.Float64PtrInput
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization OutputBlobSerializationInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringInput
}

The set of arguments for constructing a OutputBlob resource.

func (OutputBlobArgs) ElementType 

func (OutputBlobArgs) ElementType() reflect.Type

type OutputBlobArray 

type OutputBlobArray []OutputBlobInput

func (OutputBlobArray) ElementType 

func (OutputBlobArray) ElementType() reflect.Type

func (OutputBlobArray) ToOutputBlobArrayOutput 

func (i OutputBlobArray) ToOutputBlobArrayOutput() OutputBlobArrayOutput

func (OutputBlobArray) ToOutputBlobArrayOutputWithContext 

func (i OutputBlobArray) ToOutputBlobArrayOutputWithContext(ctx context.Context) OutputBlobArrayOutput

type OutputBlobArrayInput 

type OutputBlobArrayInput interface {
	pulumi.Input

	ToOutputBlobArrayOutput() OutputBlobArrayOutput
	ToOutputBlobArrayOutputWithContext(context.Context) OutputBlobArrayOutput
}

OutputBlobArrayInput is an input type that accepts OutputBlobArray and OutputBlobArrayOutput values. You can construct a concrete instance of `OutputBlobArrayInput` via: 

OutputBlobArray{ OutputBlobArgs{...} }

type OutputBlobArrayOutput 

type OutputBlobArrayOutput struct{ *pulumi.OutputState }

func (OutputBlobArrayOutput) ElementType 

func (OutputBlobArrayOutput) ElementType() reflect.Type

func (OutputBlobArrayOutput) Index 

func (o OutputBlobArrayOutput) Index(i pulumi.IntInput) OutputBlobOutput

func (OutputBlobArrayOutput) ToOutputBlobArrayOutput 

func (o OutputBlobArrayOutput) ToOutputBlobArrayOutput() OutputBlobArrayOutput

func (OutputBlobArrayOutput) ToOutputBlobArrayOutputWithContext 

func (o OutputBlobArrayOutput) ToOutputBlobArrayOutputWithContext(ctx context.Context) OutputBlobArrayOutput

type OutputBlobInput 

type OutputBlobInput interface {
	pulumi.Input

	ToOutputBlobOutput() OutputBlobOutput
	ToOutputBlobOutputWithContext(ctx context.Context) OutputBlobOutput
}

type OutputBlobMap 

type OutputBlobMap map[string]OutputBlobInput

func (OutputBlobMap) ElementType 

func (OutputBlobMap) ElementType() reflect.Type

func (OutputBlobMap) ToOutputBlobMapOutput 

func (i OutputBlobMap) ToOutputBlobMapOutput() OutputBlobMapOutput

func (OutputBlobMap) ToOutputBlobMapOutputWithContext 

func (i OutputBlobMap) ToOutputBlobMapOutputWithContext(ctx context.Context) OutputBlobMapOutput

type OutputBlobMapInput 

type OutputBlobMapInput interface {
	pulumi.Input

	ToOutputBlobMapOutput() OutputBlobMapOutput
	ToOutputBlobMapOutputWithContext(context.Context) OutputBlobMapOutput
}

OutputBlobMapInput is an input type that accepts OutputBlobMap and OutputBlobMapOutput values. You can construct a concrete instance of `OutputBlobMapInput` via: 

OutputBlobMap{ "key": OutputBlobArgs{...} }

type OutputBlobMapOutput 

type OutputBlobMapOutput struct{ *pulumi.OutputState }

func (OutputBlobMapOutput) ElementType 

func (OutputBlobMapOutput) ElementType() reflect.Type

func (OutputBlobMapOutput) MapIndex 

func (o OutputBlobMapOutput) MapIndex(k pulumi.StringInput) OutputBlobOutput

func (OutputBlobMapOutput) ToOutputBlobMapOutput 

func (o OutputBlobMapOutput) ToOutputBlobMapOutput() OutputBlobMapOutput

func (OutputBlobMapOutput) ToOutputBlobMapOutputWithContext 

func (o OutputBlobMapOutput) ToOutputBlobMapOutputWithContext(ctx context.Context) OutputBlobMapOutput

type OutputBlobOutput 

type OutputBlobOutput struct{ *pulumi.OutputState }

func (OutputBlobOutput) ElementType 

func (OutputBlobOutput) ElementType() reflect.Type

func (OutputBlobOutput) ToOutputBlobOutput 

func (o OutputBlobOutput) ToOutputBlobOutput() OutputBlobOutput

func (OutputBlobOutput) ToOutputBlobOutputWithContext 

func (o OutputBlobOutput) ToOutputBlobOutputWithContext(ctx context.Context) OutputBlobOutput

type OutputBlobSerialization 

type OutputBlobSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format *string `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv`, `Json` and `Parquet`.
	Type string `pulumi:"type"`
}

type OutputBlobSerializationArgs 

type OutputBlobSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format pulumi.StringPtrInput `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv`, `Json` and `Parquet`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (OutputBlobSerializationArgs) ElementType 

func (OutputBlobSerializationArgs) ElementType() reflect.Type

func (OutputBlobSerializationArgs) ToOutputBlobSerializationOutput 

func (i OutputBlobSerializationArgs) ToOutputBlobSerializationOutput() OutputBlobSerializationOutput

func (OutputBlobSerializationArgs) ToOutputBlobSerializationOutputWithContext 

func (i OutputBlobSerializationArgs) ToOutputBlobSerializationOutputWithContext(ctx context.Context) OutputBlobSerializationOutput

func (OutputBlobSerializationArgs) ToOutputBlobSerializationPtrOutput 

func (i OutputBlobSerializationArgs) ToOutputBlobSerializationPtrOutput() OutputBlobSerializationPtrOutput

func (OutputBlobSerializationArgs) ToOutputBlobSerializationPtrOutputWithContext 

func (i OutputBlobSerializationArgs) ToOutputBlobSerializationPtrOutputWithContext(ctx context.Context) OutputBlobSerializationPtrOutput

type OutputBlobSerializationInput 

type OutputBlobSerializationInput interface {
	pulumi.Input

	ToOutputBlobSerializationOutput() OutputBlobSerializationOutput
	ToOutputBlobSerializationOutputWithContext(context.Context) OutputBlobSerializationOutput
}

OutputBlobSerializationInput is an input type that accepts OutputBlobSerializationArgs and OutputBlobSerializationOutput values. You can construct a concrete instance of `OutputBlobSerializationInput` via: 

OutputBlobSerializationArgs{...}

type OutputBlobSerializationOutput 

type OutputBlobSerializationOutput struct{ *pulumi.OutputState }

func (OutputBlobSerializationOutput) ElementType 

func (OutputBlobSerializationOutput) ElementType() reflect.Type

func (OutputBlobSerializationOutput) Encoding 

func (o OutputBlobSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputBlobSerializationOutput) FieldDelimiter 

func (o OutputBlobSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputBlobSerializationOutput) Format 

func (o OutputBlobSerializationOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputBlobSerializationOutput) ToOutputBlobSerializationOutput 

func (o OutputBlobSerializationOutput) ToOutputBlobSerializationOutput() OutputBlobSerializationOutput

func (OutputBlobSerializationOutput) ToOutputBlobSerializationOutputWithContext 

func (o OutputBlobSerializationOutput) ToOutputBlobSerializationOutputWithContext(ctx context.Context) OutputBlobSerializationOutput

func (OutputBlobSerializationOutput) ToOutputBlobSerializationPtrOutput 

func (o OutputBlobSerializationOutput) ToOutputBlobSerializationPtrOutput() OutputBlobSerializationPtrOutput

func (OutputBlobSerializationOutput) ToOutputBlobSerializationPtrOutputWithContext 

func (o OutputBlobSerializationOutput) ToOutputBlobSerializationPtrOutputWithContext(ctx context.Context) OutputBlobSerializationPtrOutput

func (OutputBlobSerializationOutput) Type 

func (o OutputBlobSerializationOutput) Type() pulumi.StringOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv`, `Json` and `Parquet`.

type OutputBlobSerializationPtrInput 

type OutputBlobSerializationPtrInput interface {
	pulumi.Input

	ToOutputBlobSerializationPtrOutput() OutputBlobSerializationPtrOutput
	ToOutputBlobSerializationPtrOutputWithContext(context.Context) OutputBlobSerializationPtrOutput
}

OutputBlobSerializationPtrInput is an input type that accepts OutputBlobSerializationArgs, OutputBlobSerializationPtr and OutputBlobSerializationPtrOutput values. You can construct a concrete instance of `OutputBlobSerializationPtrInput` via: 

        OutputBlobSerializationArgs{...}

or:

        nil

func OutputBlobSerializationPtr 

func OutputBlobSerializationPtr(v *OutputBlobSerializationArgs) OutputBlobSerializationPtrInput

type OutputBlobSerializationPtrOutput 

type OutputBlobSerializationPtrOutput struct{ *pulumi.OutputState }

func (OutputBlobSerializationPtrOutput) Elem 

func (o OutputBlobSerializationPtrOutput) Elem() OutputBlobSerializationOutput

func (OutputBlobSerializationPtrOutput) ElementType 

func (OutputBlobSerializationPtrOutput) ElementType() reflect.Type

func (OutputBlobSerializationPtrOutput) Encoding 

func (o OutputBlobSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputBlobSerializationPtrOutput) FieldDelimiter 

func (o OutputBlobSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputBlobSerializationPtrOutput) Format 

func (o OutputBlobSerializationPtrOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputBlobSerializationPtrOutput) ToOutputBlobSerializationPtrOutput 

func (o OutputBlobSerializationPtrOutput) ToOutputBlobSerializationPtrOutput() OutputBlobSerializationPtrOutput

func (OutputBlobSerializationPtrOutput) ToOutputBlobSerializationPtrOutputWithContext 

func (o OutputBlobSerializationPtrOutput) ToOutputBlobSerializationPtrOutputWithContext(ctx context.Context) OutputBlobSerializationPtrOutput

func (OutputBlobSerializationPtrOutput) Type 

func (o OutputBlobSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv`, `Json` and `Parquet`.

type OutputBlobState 

type OutputBlobState struct {
	// The maximum wait time per batch in `hh:mm:ss` e.g. `00:02:00` for two minutes.
	BatchMaxWaitTime pulumi.StringPtrInput
	// The minimum number of rows per batch (must be between `0` and `10000`).
	BatchMinRows pulumi.Float64PtrInput
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringPtrInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization OutputBlobSerializationPtrInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringPtrInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringPtrInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringPtrInput
}

func (OutputBlobState) ElementType 

func (OutputBlobState) ElementType() reflect.Type

type OutputEventHub 

type OutputEventHub struct {
	pulumi.CustomResourceState

	// The name of the Event Hub.
	EventhubName pulumi.StringOutput `pulumi:"eventhubName"`
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The column that is used for the Event Hub partition key.
	PartitionKey pulumi.StringPtrOutput `pulumi:"partitionKey"`
	// A list of property columns to add to the Event Hub output.
	PropertyColumns pulumi.StringArrayOutput `pulumi:"propertyColumns"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization OutputEventHubSerializationOutput `pulumi:"serialization"`
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringOutput `pulumi:"servicebusNamespace"`
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringOutput `pulumi:"sharedAccessPolicyKey"`
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringOutput `pulumi:"sharedAccessPolicyName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a Stream Analytics Output to an EventHub.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/eventhub"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleEventHubNamespace, err := eventhub.NewEventHubNamespace(ctx, "exampleEventHubNamespace", &eventhub.EventHubNamespaceArgs{
			Location:          pulumi.String(exampleResourceGroup.Location),
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			Sku:               pulumi.String("Standard"),
			Capacity:          pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		exampleEventHub, err := eventhub.NewEventHub(ctx, "exampleEventHub", &eventhub.EventHubArgs{
			NamespaceName:     exampleEventHubNamespace.Name,
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			PartitionCount:    pulumi.Int(2),
			MessageRetention:  pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputEventHub(ctx, "exampleOutputEventHub", &streamanalytics.OutputEventHubArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			EventhubName:           exampleEventHub.Name,
			ServicebusNamespace:    exampleEventHubNamespace.Name,
			SharedAccessPolicyKey:  exampleEventHubNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName: pulumi.String("RootManageSharedAccessKey"),
			Serialization: &streamanalytics.OutputEventHubSerializationArgs{
				Type: pulumi.String("Avro"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Outputs to an EventHub can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputEventHub:OutputEventHub example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputEventHub 

func GetOutputEventHub(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputEventHubState, opts ...pulumi.ResourceOption) (*OutputEventHub, error)

GetOutputEventHub gets an existing OutputEventHub 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 NewOutputEventHub 

func NewOutputEventHub(ctx *pulumi.Context,
	name string, args *OutputEventHubArgs, opts ...pulumi.ResourceOption) (*OutputEventHub, error)

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

func (*OutputEventHub) ElementType 

func (*OutputEventHub) ElementType() reflect.Type

func (*OutputEventHub) ToOutputEventHubOutput 

func (i *OutputEventHub) ToOutputEventHubOutput() OutputEventHubOutput

func (*OutputEventHub) ToOutputEventHubOutputWithContext 

func (i *OutputEventHub) ToOutputEventHubOutputWithContext(ctx context.Context) OutputEventHubOutput

type OutputEventHubArgs 

type OutputEventHubArgs struct {
	// The name of the Event Hub.
	EventhubName pulumi.StringInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The column that is used for the Event Hub partition key.
	PartitionKey pulumi.StringPtrInput
	// A list of property columns to add to the Event Hub output.
	PropertyColumns pulumi.StringArrayInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization OutputEventHubSerializationInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a OutputEventHub resource.

func (OutputEventHubArgs) ElementType 

func (OutputEventHubArgs) ElementType() reflect.Type

type OutputEventHubArray 

type OutputEventHubArray []OutputEventHubInput

func (OutputEventHubArray) ElementType 

func (OutputEventHubArray) ElementType() reflect.Type

func (OutputEventHubArray) ToOutputEventHubArrayOutput 

func (i OutputEventHubArray) ToOutputEventHubArrayOutput() OutputEventHubArrayOutput

func (OutputEventHubArray) ToOutputEventHubArrayOutputWithContext 

func (i OutputEventHubArray) ToOutputEventHubArrayOutputWithContext(ctx context.Context) OutputEventHubArrayOutput

type OutputEventHubArrayInput 

type OutputEventHubArrayInput interface {
	pulumi.Input

	ToOutputEventHubArrayOutput() OutputEventHubArrayOutput
	ToOutputEventHubArrayOutputWithContext(context.Context) OutputEventHubArrayOutput
}

OutputEventHubArrayInput is an input type that accepts OutputEventHubArray and OutputEventHubArrayOutput values. You can construct a concrete instance of `OutputEventHubArrayInput` via: 

OutputEventHubArray{ OutputEventHubArgs{...} }

type OutputEventHubArrayOutput 

type OutputEventHubArrayOutput struct{ *pulumi.OutputState }

func (OutputEventHubArrayOutput) ElementType 

func (OutputEventHubArrayOutput) ElementType() reflect.Type

func (OutputEventHubArrayOutput) Index 

func (o OutputEventHubArrayOutput) Index(i pulumi.IntInput) OutputEventHubOutput

func (OutputEventHubArrayOutput) ToOutputEventHubArrayOutput 

func (o OutputEventHubArrayOutput) ToOutputEventHubArrayOutput() OutputEventHubArrayOutput

func (OutputEventHubArrayOutput) ToOutputEventHubArrayOutputWithContext 

func (o OutputEventHubArrayOutput) ToOutputEventHubArrayOutputWithContext(ctx context.Context) OutputEventHubArrayOutput

type OutputEventHubInput 

type OutputEventHubInput interface {
	pulumi.Input

	ToOutputEventHubOutput() OutputEventHubOutput
	ToOutputEventHubOutputWithContext(ctx context.Context) OutputEventHubOutput
}

type OutputEventHubMap 

type OutputEventHubMap map[string]OutputEventHubInput

func (OutputEventHubMap) ElementType 

func (OutputEventHubMap) ElementType() reflect.Type

func (OutputEventHubMap) ToOutputEventHubMapOutput 

func (i OutputEventHubMap) ToOutputEventHubMapOutput() OutputEventHubMapOutput

func (OutputEventHubMap) ToOutputEventHubMapOutputWithContext 

func (i OutputEventHubMap) ToOutputEventHubMapOutputWithContext(ctx context.Context) OutputEventHubMapOutput

type OutputEventHubMapInput 

type OutputEventHubMapInput interface {
	pulumi.Input

	ToOutputEventHubMapOutput() OutputEventHubMapOutput
	ToOutputEventHubMapOutputWithContext(context.Context) OutputEventHubMapOutput
}

OutputEventHubMapInput is an input type that accepts OutputEventHubMap and OutputEventHubMapOutput values. You can construct a concrete instance of `OutputEventHubMapInput` via: 

OutputEventHubMap{ "key": OutputEventHubArgs{...} }

type OutputEventHubMapOutput 

type OutputEventHubMapOutput struct{ *pulumi.OutputState }

func (OutputEventHubMapOutput) ElementType 

func (OutputEventHubMapOutput) ElementType() reflect.Type

func (OutputEventHubMapOutput) MapIndex 

func (o OutputEventHubMapOutput) MapIndex(k pulumi.StringInput) OutputEventHubOutput

func (OutputEventHubMapOutput) ToOutputEventHubMapOutput 

func (o OutputEventHubMapOutput) ToOutputEventHubMapOutput() OutputEventHubMapOutput

func (OutputEventHubMapOutput) ToOutputEventHubMapOutputWithContext 

func (o OutputEventHubMapOutput) ToOutputEventHubMapOutputWithContext(ctx context.Context) OutputEventHubMapOutput

type OutputEventHubOutput 

type OutputEventHubOutput struct{ *pulumi.OutputState }

func (OutputEventHubOutput) ElementType 

func (OutputEventHubOutput) ElementType() reflect.Type

func (OutputEventHubOutput) ToOutputEventHubOutput 

func (o OutputEventHubOutput) ToOutputEventHubOutput() OutputEventHubOutput

func (OutputEventHubOutput) ToOutputEventHubOutputWithContext 

func (o OutputEventHubOutput) ToOutputEventHubOutputWithContext(ctx context.Context) OutputEventHubOutput

type OutputEventHubSerialization 

type OutputEventHubSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format *string `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type OutputEventHubSerializationArgs 

type OutputEventHubSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format pulumi.StringPtrInput `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (OutputEventHubSerializationArgs) ElementType 

func (OutputEventHubSerializationArgs) ElementType() reflect.Type

func (OutputEventHubSerializationArgs) ToOutputEventHubSerializationOutput 

func (i OutputEventHubSerializationArgs) ToOutputEventHubSerializationOutput() OutputEventHubSerializationOutput

func (OutputEventHubSerializationArgs) ToOutputEventHubSerializationOutputWithContext 

func (i OutputEventHubSerializationArgs) ToOutputEventHubSerializationOutputWithContext(ctx context.Context) OutputEventHubSerializationOutput

func (OutputEventHubSerializationArgs) ToOutputEventHubSerializationPtrOutput 

func (i OutputEventHubSerializationArgs) ToOutputEventHubSerializationPtrOutput() OutputEventHubSerializationPtrOutput

func (OutputEventHubSerializationArgs) ToOutputEventHubSerializationPtrOutputWithContext 

func (i OutputEventHubSerializationArgs) ToOutputEventHubSerializationPtrOutputWithContext(ctx context.Context) OutputEventHubSerializationPtrOutput

type OutputEventHubSerializationInput 

type OutputEventHubSerializationInput interface {
	pulumi.Input

	ToOutputEventHubSerializationOutput() OutputEventHubSerializationOutput
	ToOutputEventHubSerializationOutputWithContext(context.Context) OutputEventHubSerializationOutput
}

OutputEventHubSerializationInput is an input type that accepts OutputEventHubSerializationArgs and OutputEventHubSerializationOutput values. You can construct a concrete instance of `OutputEventHubSerializationInput` via: 

OutputEventHubSerializationArgs{...}

type OutputEventHubSerializationOutput 

type OutputEventHubSerializationOutput struct{ *pulumi.OutputState }

func (OutputEventHubSerializationOutput) ElementType 

func (OutputEventHubSerializationOutput) ElementType() reflect.Type

func (OutputEventHubSerializationOutput) Encoding 

func (o OutputEventHubSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputEventHubSerializationOutput) FieldDelimiter 

func (o OutputEventHubSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputEventHubSerializationOutput) Format 

func (o OutputEventHubSerializationOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputEventHubSerializationOutput) ToOutputEventHubSerializationOutput 

func (o OutputEventHubSerializationOutput) ToOutputEventHubSerializationOutput() OutputEventHubSerializationOutput

func (OutputEventHubSerializationOutput) ToOutputEventHubSerializationOutputWithContext 

func (o OutputEventHubSerializationOutput) ToOutputEventHubSerializationOutputWithContext(ctx context.Context) OutputEventHubSerializationOutput

func (OutputEventHubSerializationOutput) ToOutputEventHubSerializationPtrOutput 

func (o OutputEventHubSerializationOutput) ToOutputEventHubSerializationPtrOutput() OutputEventHubSerializationPtrOutput

func (OutputEventHubSerializationOutput) ToOutputEventHubSerializationPtrOutputWithContext 

func (o OutputEventHubSerializationOutput) ToOutputEventHubSerializationPtrOutputWithContext(ctx context.Context) OutputEventHubSerializationPtrOutput

func (OutputEventHubSerializationOutput) Type 

func (o OutputEventHubSerializationOutput) Type() pulumi.StringOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputEventHubSerializationPtrInput 

type OutputEventHubSerializationPtrInput interface {
	pulumi.Input

	ToOutputEventHubSerializationPtrOutput() OutputEventHubSerializationPtrOutput
	ToOutputEventHubSerializationPtrOutputWithContext(context.Context) OutputEventHubSerializationPtrOutput
}

OutputEventHubSerializationPtrInput is an input type that accepts OutputEventHubSerializationArgs, OutputEventHubSerializationPtr and OutputEventHubSerializationPtrOutput values. You can construct a concrete instance of `OutputEventHubSerializationPtrInput` via: 

        OutputEventHubSerializationArgs{...}

or:

        nil

func OutputEventHubSerializationPtr 

func OutputEventHubSerializationPtr(v *OutputEventHubSerializationArgs) OutputEventHubSerializationPtrInput

type OutputEventHubSerializationPtrOutput 

type OutputEventHubSerializationPtrOutput struct{ *pulumi.OutputState }

func (OutputEventHubSerializationPtrOutput) Elem 

func (o OutputEventHubSerializationPtrOutput) Elem() OutputEventHubSerializationOutput

func (OutputEventHubSerializationPtrOutput) ElementType 

func (OutputEventHubSerializationPtrOutput) ElementType() reflect.Type

func (OutputEventHubSerializationPtrOutput) Encoding 

func (o OutputEventHubSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputEventHubSerializationPtrOutput) FieldDelimiter 

func (o OutputEventHubSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputEventHubSerializationPtrOutput) Format 

func (o OutputEventHubSerializationPtrOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputEventHubSerializationPtrOutput) ToOutputEventHubSerializationPtrOutput 

func (o OutputEventHubSerializationPtrOutput) ToOutputEventHubSerializationPtrOutput() OutputEventHubSerializationPtrOutput

func (OutputEventHubSerializationPtrOutput) ToOutputEventHubSerializationPtrOutputWithContext 

func (o OutputEventHubSerializationPtrOutput) ToOutputEventHubSerializationPtrOutputWithContext(ctx context.Context) OutputEventHubSerializationPtrOutput

func (OutputEventHubSerializationPtrOutput) Type 

func (o OutputEventHubSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputEventHubState 

type OutputEventHubState struct {
	// The name of the Event Hub.
	EventhubName pulumi.StringPtrInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The column that is used for the Event Hub partition key.
	PartitionKey pulumi.StringPtrInput
	// A list of property columns to add to the Event Hub output.
	PropertyColumns pulumi.StringArrayInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization OutputEventHubSerializationPtrInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringPtrInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringPtrInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (OutputEventHubState) ElementType 

func (OutputEventHubState) ElementType() reflect.Type

type OutputFunction added in v4.38.0 

type OutputFunction struct {
	pulumi.CustomResourceState

	// The API key for the Function.
	ApiKey pulumi.StringOutput `pulumi:"apiKey"`
	// The maximum number of events in each batch that's sent to the function. Defaults to `100`.
	BatchMaxCount pulumi.IntPtrOutput `pulumi:"batchMaxCount"`
	// The maximum batch size in bytes that's sent to the function. Defaults to `262144` (256 kB).
	BatchMaxInBytes pulumi.IntPtrOutput `pulumi:"batchMaxInBytes"`
	// The name of the Function App.
	FunctionApp pulumi.StringOutput `pulumi:"functionApp"`
	// The name of the function in the Function App.
	FunctionName pulumi.StringOutput `pulumi:"functionName"`
	// The name which should be used for this Stream Analytics Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the Resource Group where the Stream Analytics Output should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a Stream Analytics Output Function.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/appservice"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      exampleResourceGroup.Name,
			Location:               exampleResourceGroup.Location,
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		examplePlan, err := appservice.NewPlan(ctx, "examplePlan", &appservice.PlanArgs{
			Location:          exampleResourceGroup.Location,
			ResourceGroupName: exampleResourceGroup.Name,
			Kind:              pulumi.Any("FunctionApp"),
			Reserved:          pulumi.Bool(true),
			Sku: &appservice.PlanSkuArgs{
				Tier: pulumi.String("Dynamic"),
				Size: pulumi.String("Y1"),
			},
		})
		if err != nil {
			return err
		}
		exampleFunctionApp, err := appservice.NewFunctionApp(ctx, "exampleFunctionApp", &appservice.FunctionAppArgs{
			Location:                exampleResourceGroup.Location,
			ResourceGroupName:       exampleResourceGroup.Name,
			AppServicePlanId:        examplePlan.ID(),
			StorageAccountName:      exampleAccount.Name,
			StorageAccountAccessKey: exampleAccount.PrimaryAccessKey,
			OsType:                  pulumi.String("linux"),
			Version:                 pulumi.String("~3"),
		})
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.NewJob(ctx, "exampleJob", &streamanalytics.JobArgs{
			ResourceGroupName:   exampleResourceGroup.Name,
			Location:            exampleResourceGroup.Location,
			StreamingUnits:      pulumi.Int(3),
			TransformationQuery: pulumi.String(fmt.Sprintf("%v%v%v", "    SELECT *\n", "    INTO [YourOutputAlias]\n", "    FROM [YourInputAlias]\n")),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputFunction(ctx, "exampleOutputFunction", &streamanalytics.OutputFunctionArgs{
			ResourceGroupName:      exampleJob.ResourceGroupName,
			StreamAnalyticsJobName: exampleJob.Name,
			FunctionApp:            exampleFunctionApp.Name,
			FunctionName:           pulumi.String("examplefunctionname"),
			ApiKey:                 pulumi.String("exampleapikey"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Output Functions can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputFunction:OutputFunction example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputFunction added in v4.38.0 

func GetOutputFunction(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputFunctionState, opts ...pulumi.ResourceOption) (*OutputFunction, error)

GetOutputFunction gets an existing OutputFunction 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 NewOutputFunction added in v4.38.0 

func NewOutputFunction(ctx *pulumi.Context,
	name string, args *OutputFunctionArgs, opts ...pulumi.ResourceOption) (*OutputFunction, error)

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

func (*OutputFunction) ElementType added in v4.38.0 

func (*OutputFunction) ElementType() reflect.Type

func (*OutputFunction) ToOutputFunctionOutput added in v4.38.0 

func (i *OutputFunction) ToOutputFunctionOutput() OutputFunctionOutput

func (*OutputFunction) ToOutputFunctionOutputWithContext added in v4.38.0 

func (i *OutputFunction) ToOutputFunctionOutputWithContext(ctx context.Context) OutputFunctionOutput

type OutputFunctionArgs added in v4.38.0 

type OutputFunctionArgs struct {
	// The API key for the Function.
	ApiKey pulumi.StringInput
	// The maximum number of events in each batch that's sent to the function. Defaults to `100`.
	BatchMaxCount pulumi.IntPtrInput
	// The maximum batch size in bytes that's sent to the function. Defaults to `262144` (256 kB).
	BatchMaxInBytes pulumi.IntPtrInput
	// The name of the Function App.
	FunctionApp pulumi.StringInput
	// The name of the function in the Function App.
	FunctionName pulumi.StringInput
	// The name which should be used for this Stream Analytics Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Output should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a OutputFunction resource.

func (OutputFunctionArgs) ElementType added in v4.38.0 

func (OutputFunctionArgs) ElementType() reflect.Type

type OutputFunctionArray added in v4.38.0 

type OutputFunctionArray []OutputFunctionInput

func (OutputFunctionArray) ElementType added in v4.38.0 

func (OutputFunctionArray) ElementType() reflect.Type

func (OutputFunctionArray) ToOutputFunctionArrayOutput added in v4.38.0 

func (i OutputFunctionArray) ToOutputFunctionArrayOutput() OutputFunctionArrayOutput

func (OutputFunctionArray) ToOutputFunctionArrayOutputWithContext added in v4.38.0 

func (i OutputFunctionArray) ToOutputFunctionArrayOutputWithContext(ctx context.Context) OutputFunctionArrayOutput

type OutputFunctionArrayInput added in v4.38.0 

type OutputFunctionArrayInput interface {
	pulumi.Input

	ToOutputFunctionArrayOutput() OutputFunctionArrayOutput
	ToOutputFunctionArrayOutputWithContext(context.Context) OutputFunctionArrayOutput
}

OutputFunctionArrayInput is an input type that accepts OutputFunctionArray and OutputFunctionArrayOutput values. You can construct a concrete instance of `OutputFunctionArrayInput` via: 

OutputFunctionArray{ OutputFunctionArgs{...} }

type OutputFunctionArrayOutput added in v4.38.0 

type OutputFunctionArrayOutput struct{ *pulumi.OutputState }

func (OutputFunctionArrayOutput) ElementType added in v4.38.0 

func (OutputFunctionArrayOutput) ElementType() reflect.Type

func (OutputFunctionArrayOutput) Index added in v4.38.0 

func (o OutputFunctionArrayOutput) Index(i pulumi.IntInput) OutputFunctionOutput

func (OutputFunctionArrayOutput) ToOutputFunctionArrayOutput added in v4.38.0 

func (o OutputFunctionArrayOutput) ToOutputFunctionArrayOutput() OutputFunctionArrayOutput

func (OutputFunctionArrayOutput) ToOutputFunctionArrayOutputWithContext added in v4.38.0 

func (o OutputFunctionArrayOutput) ToOutputFunctionArrayOutputWithContext(ctx context.Context) OutputFunctionArrayOutput

type OutputFunctionInput added in v4.38.0 

type OutputFunctionInput interface {
	pulumi.Input

	ToOutputFunctionOutput() OutputFunctionOutput
	ToOutputFunctionOutputWithContext(ctx context.Context) OutputFunctionOutput
}

type OutputFunctionMap added in v4.38.0 

type OutputFunctionMap map[string]OutputFunctionInput

func (OutputFunctionMap) ElementType added in v4.38.0 

func (OutputFunctionMap) ElementType() reflect.Type

func (OutputFunctionMap) ToOutputFunctionMapOutput added in v4.38.0 

func (i OutputFunctionMap) ToOutputFunctionMapOutput() OutputFunctionMapOutput

func (OutputFunctionMap) ToOutputFunctionMapOutputWithContext added in v4.38.0 

func (i OutputFunctionMap) ToOutputFunctionMapOutputWithContext(ctx context.Context) OutputFunctionMapOutput

type OutputFunctionMapInput added in v4.38.0 

type OutputFunctionMapInput interface {
	pulumi.Input

	ToOutputFunctionMapOutput() OutputFunctionMapOutput
	ToOutputFunctionMapOutputWithContext(context.Context) OutputFunctionMapOutput
}

OutputFunctionMapInput is an input type that accepts OutputFunctionMap and OutputFunctionMapOutput values. You can construct a concrete instance of `OutputFunctionMapInput` via: 

OutputFunctionMap{ "key": OutputFunctionArgs{...} }

type OutputFunctionMapOutput added in v4.38.0 

type OutputFunctionMapOutput struct{ *pulumi.OutputState }

func (OutputFunctionMapOutput) ElementType added in v4.38.0 

func (OutputFunctionMapOutput) ElementType() reflect.Type

func (OutputFunctionMapOutput) MapIndex added in v4.38.0 

func (o OutputFunctionMapOutput) MapIndex(k pulumi.StringInput) OutputFunctionOutput

func (OutputFunctionMapOutput) ToOutputFunctionMapOutput added in v4.38.0 

func (o OutputFunctionMapOutput) ToOutputFunctionMapOutput() OutputFunctionMapOutput

func (OutputFunctionMapOutput) ToOutputFunctionMapOutputWithContext added in v4.38.0 

func (o OutputFunctionMapOutput) ToOutputFunctionMapOutputWithContext(ctx context.Context) OutputFunctionMapOutput

type OutputFunctionOutput added in v4.38.0 

type OutputFunctionOutput struct{ *pulumi.OutputState }

func (OutputFunctionOutput) ElementType added in v4.38.0 

func (OutputFunctionOutput) ElementType() reflect.Type

func (OutputFunctionOutput) ToOutputFunctionOutput added in v4.38.0 

func (o OutputFunctionOutput) ToOutputFunctionOutput() OutputFunctionOutput

func (OutputFunctionOutput) ToOutputFunctionOutputWithContext added in v4.38.0 

func (o OutputFunctionOutput) ToOutputFunctionOutputWithContext(ctx context.Context) OutputFunctionOutput

type OutputFunctionState added in v4.38.0 

type OutputFunctionState struct {
	// The API key for the Function.
	ApiKey pulumi.StringPtrInput
	// The maximum number of events in each batch that's sent to the function. Defaults to `100`.
	BatchMaxCount pulumi.IntPtrInput
	// The maximum batch size in bytes that's sent to the function. Defaults to `262144` (256 kB).
	BatchMaxInBytes pulumi.IntPtrInput
	// The name of the Function App.
	FunctionApp pulumi.StringPtrInput
	// The name of the function in the Function App.
	FunctionName pulumi.StringPtrInput
	// The name which should be used for this Stream Analytics Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Output should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (OutputFunctionState) ElementType added in v4.38.0 

func (OutputFunctionState) ElementType() reflect.Type

type OutputMssql 

type OutputMssql struct {
	pulumi.CustomResourceState

	Database pulumi.StringOutput `pulumi:"database"`
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	Password pulumi.StringOutput `pulumi:"password"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The SQL server url. Changing this forces a new resource to be created.
	Server pulumi.StringOutput `pulumi:"server"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// Table in the database that the output points to. Changing this forces a new resource to be created.
	Table pulumi.StringOutput `pulumi:"table"`
	// Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	User pulumi.StringOutput `pulumi:"user"`
}

Manages a Stream Analytics Output to Microsoft SQL Server Database.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/sql"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleSqlServer, err := sql.NewSqlServer(ctx, "exampleSqlServer", &sql.SqlServerArgs{
			ResourceGroupName:          pulumi.Any(azurerm_resource_group.Example.Name),
			Location:                   pulumi.Any(azurerm_resource_group.Example.Location),
			Version:                    pulumi.String("12.0"),
			AdministratorLogin:         pulumi.String("dbadmin"),
			AdministratorLoginPassword: pulumi.String("example-password"),
		})
		if err != nil {
			return err
		}
		exampleDatabase, err := sql.NewDatabase(ctx, "exampleDatabase", &sql.DatabaseArgs{
			ResourceGroupName:             pulumi.Any(azurerm_resource_group.Example.Name),
			Location:                      pulumi.Any(azurerm_resource_group.Example.Location),
			ServerName:                    exampleSqlServer.Name,
			RequestedServiceObjectiveName: pulumi.String("S0"),
			Collation:                     pulumi.String("SQL_LATIN1_GENERAL_CP1_CI_AS"),
			MaxSizeBytes:                  pulumi.String("268435456000"),
			CreateMode:                    pulumi.String("Default"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputMssql(ctx, "exampleOutputMssql", &streamanalytics.OutputMssqlArgs{
			StreamAnalyticsJobName: pulumi.Any(azurerm_stream_analytics_job.Example.Name),
			ResourceGroupName:      pulumi.Any(azurerm_stream_analytics_job.Example.Resource_group_name),
			Server:                 exampleSqlServer.FullyQualifiedDomainName,
			User:                   exampleSqlServer.AdministratorLogin,
			Password:               exampleSqlServer.AdministratorLoginPassword,
			Database:               exampleDatabase.Name,
			Table:                  pulumi.String("ExampleTable"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Outputs to Microsoft SQL Server Database can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputMssql:OutputMssql example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputMssql 

func GetOutputMssql(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputMssqlState, opts ...pulumi.ResourceOption) (*OutputMssql, error)

GetOutputMssql gets an existing OutputMssql 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 NewOutputMssql 

func NewOutputMssql(ctx *pulumi.Context,
	name string, args *OutputMssqlArgs, opts ...pulumi.ResourceOption) (*OutputMssql, error)

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

func (*OutputMssql) ElementType 

func (*OutputMssql) ElementType() reflect.Type

func (*OutputMssql) ToOutputMssqlOutput 

func (i *OutputMssql) ToOutputMssqlOutput() OutputMssqlOutput

func (*OutputMssql) ToOutputMssqlOutputWithContext 

func (i *OutputMssql) ToOutputMssqlOutputWithContext(ctx context.Context) OutputMssqlOutput

type OutputMssqlArgs 

type OutputMssqlArgs struct {
	Database pulumi.StringInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	Password pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The SQL server url. Changing this forces a new resource to be created.
	Server pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// Table in the database that the output points to. Changing this forces a new resource to be created.
	Table pulumi.StringInput
	// Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	User pulumi.StringInput
}

The set of arguments for constructing a OutputMssql resource.

func (OutputMssqlArgs) ElementType 

func (OutputMssqlArgs) ElementType() reflect.Type

type OutputMssqlArray 

type OutputMssqlArray []OutputMssqlInput

func (OutputMssqlArray) ElementType 

func (OutputMssqlArray) ElementType() reflect.Type

func (OutputMssqlArray) ToOutputMssqlArrayOutput 

func (i OutputMssqlArray) ToOutputMssqlArrayOutput() OutputMssqlArrayOutput

func (OutputMssqlArray) ToOutputMssqlArrayOutputWithContext 

func (i OutputMssqlArray) ToOutputMssqlArrayOutputWithContext(ctx context.Context) OutputMssqlArrayOutput

type OutputMssqlArrayInput 

type OutputMssqlArrayInput interface {
	pulumi.Input

	ToOutputMssqlArrayOutput() OutputMssqlArrayOutput
	ToOutputMssqlArrayOutputWithContext(context.Context) OutputMssqlArrayOutput
}

OutputMssqlArrayInput is an input type that accepts OutputMssqlArray and OutputMssqlArrayOutput values. You can construct a concrete instance of `OutputMssqlArrayInput` via: 

OutputMssqlArray{ OutputMssqlArgs{...} }

type OutputMssqlArrayOutput 

type OutputMssqlArrayOutput struct{ *pulumi.OutputState }

func (OutputMssqlArrayOutput) ElementType 

func (OutputMssqlArrayOutput) ElementType() reflect.Type

func (OutputMssqlArrayOutput) Index 

func (o OutputMssqlArrayOutput) Index(i pulumi.IntInput) OutputMssqlOutput

func (OutputMssqlArrayOutput) ToOutputMssqlArrayOutput 

func (o OutputMssqlArrayOutput) ToOutputMssqlArrayOutput() OutputMssqlArrayOutput

func (OutputMssqlArrayOutput) ToOutputMssqlArrayOutputWithContext 

func (o OutputMssqlArrayOutput) ToOutputMssqlArrayOutputWithContext(ctx context.Context) OutputMssqlArrayOutput

type OutputMssqlInput 

type OutputMssqlInput interface {
	pulumi.Input

	ToOutputMssqlOutput() OutputMssqlOutput
	ToOutputMssqlOutputWithContext(ctx context.Context) OutputMssqlOutput
}

type OutputMssqlMap 

type OutputMssqlMap map[string]OutputMssqlInput

func (OutputMssqlMap) ElementType 

func (OutputMssqlMap) ElementType() reflect.Type

func (OutputMssqlMap) ToOutputMssqlMapOutput 

func (i OutputMssqlMap) ToOutputMssqlMapOutput() OutputMssqlMapOutput

func (OutputMssqlMap) ToOutputMssqlMapOutputWithContext 

func (i OutputMssqlMap) ToOutputMssqlMapOutputWithContext(ctx context.Context) OutputMssqlMapOutput

type OutputMssqlMapInput 

type OutputMssqlMapInput interface {
	pulumi.Input

	ToOutputMssqlMapOutput() OutputMssqlMapOutput
	ToOutputMssqlMapOutputWithContext(context.Context) OutputMssqlMapOutput
}

OutputMssqlMapInput is an input type that accepts OutputMssqlMap and OutputMssqlMapOutput values. You can construct a concrete instance of `OutputMssqlMapInput` via: 

OutputMssqlMap{ "key": OutputMssqlArgs{...} }

type OutputMssqlMapOutput 

type OutputMssqlMapOutput struct{ *pulumi.OutputState }

func (OutputMssqlMapOutput) ElementType 

func (OutputMssqlMapOutput) ElementType() reflect.Type

func (OutputMssqlMapOutput) MapIndex 

func (o OutputMssqlMapOutput) MapIndex(k pulumi.StringInput) OutputMssqlOutput

func (OutputMssqlMapOutput) ToOutputMssqlMapOutput 

func (o OutputMssqlMapOutput) ToOutputMssqlMapOutput() OutputMssqlMapOutput

func (OutputMssqlMapOutput) ToOutputMssqlMapOutputWithContext 

func (o OutputMssqlMapOutput) ToOutputMssqlMapOutputWithContext(ctx context.Context) OutputMssqlMapOutput

type OutputMssqlOutput 

type OutputMssqlOutput struct{ *pulumi.OutputState }

func (OutputMssqlOutput) ElementType 

func (OutputMssqlOutput) ElementType() reflect.Type

func (OutputMssqlOutput) ToOutputMssqlOutput 

func (o OutputMssqlOutput) ToOutputMssqlOutput() OutputMssqlOutput

func (OutputMssqlOutput) ToOutputMssqlOutputWithContext 

func (o OutputMssqlOutput) ToOutputMssqlOutputWithContext(ctx context.Context) OutputMssqlOutput

type OutputMssqlState 

type OutputMssqlState struct {
	Database pulumi.StringPtrInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	Password pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The SQL server url. Changing this forces a new resource to be created.
	Server pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// Table in the database that the output points to. Changing this forces a new resource to be created.
	Table pulumi.StringPtrInput
	// Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
	User pulumi.StringPtrInput
}

func (OutputMssqlState) ElementType 

func (OutputMssqlState) ElementType() reflect.Type

type OutputServiceBusQueue 

type OutputServiceBusQueue struct {
	pulumi.CustomResourceState

	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the Service Bus Queue.
	QueueName pulumi.StringOutput `pulumi:"queueName"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization OutputServiceBusQueueSerializationOutput `pulumi:"serialization"`
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringOutput `pulumi:"servicebusNamespace"`
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringOutput `pulumi:"sharedAccessPolicyKey"`
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringOutput `pulumi:"sharedAccessPolicyName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a Stream Analytics Output to a ServiceBus Queue.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/servicebus"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleNamespace, err := servicebus.NewNamespace(ctx, "exampleNamespace", &servicebus.NamespaceArgs{
			Location:          pulumi.String(exampleResourceGroup.Location),
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			Sku:               pulumi.String("Standard"),
		})
		if err != nil {
			return err
		}
		exampleQueue, err := servicebus.NewQueue(ctx, "exampleQueue", &servicebus.QueueArgs{
			NamespaceId:        exampleNamespace.ID(),
			EnablePartitioning: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputServiceBusQueue(ctx, "exampleOutputServiceBusQueue", &streamanalytics.OutputServiceBusQueueArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			QueueName:              exampleQueue.Name,
			ServicebusNamespace:    exampleNamespace.Name,
			SharedAccessPolicyKey:  exampleNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName: pulumi.String("RootManageSharedAccessKey"),
			Serialization: &streamanalytics.OutputServiceBusQueueSerializationArgs{
				Format: pulumi.String("Avro"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Output ServiceBus Queue's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputServiceBusQueue:OutputServiceBusQueue example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputServiceBusQueue 

func GetOutputServiceBusQueue(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputServiceBusQueueState, opts ...pulumi.ResourceOption) (*OutputServiceBusQueue, error)

GetOutputServiceBusQueue gets an existing OutputServiceBusQueue 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 NewOutputServiceBusQueue 

func NewOutputServiceBusQueue(ctx *pulumi.Context,
	name string, args *OutputServiceBusQueueArgs, opts ...pulumi.ResourceOption) (*OutputServiceBusQueue, error)

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

func (*OutputServiceBusQueue) ElementType 

func (*OutputServiceBusQueue) ElementType() reflect.Type

func (*OutputServiceBusQueue) ToOutputServiceBusQueueOutput 

func (i *OutputServiceBusQueue) ToOutputServiceBusQueueOutput() OutputServiceBusQueueOutput

func (*OutputServiceBusQueue) ToOutputServiceBusQueueOutputWithContext 

func (i *OutputServiceBusQueue) ToOutputServiceBusQueueOutputWithContext(ctx context.Context) OutputServiceBusQueueOutput

type OutputServiceBusQueueArgs 

type OutputServiceBusQueueArgs struct {
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Service Bus Queue.
	QueueName pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization OutputServiceBusQueueSerializationInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a OutputServiceBusQueue resource.

func (OutputServiceBusQueueArgs) ElementType 

func (OutputServiceBusQueueArgs) ElementType() reflect.Type

type OutputServiceBusQueueArray 

type OutputServiceBusQueueArray []OutputServiceBusQueueInput

func (OutputServiceBusQueueArray) ElementType 

func (OutputServiceBusQueueArray) ElementType() reflect.Type

func (OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutput 

func (i OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutput() OutputServiceBusQueueArrayOutput

func (OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutputWithContext 

func (i OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutputWithContext(ctx context.Context) OutputServiceBusQueueArrayOutput

type OutputServiceBusQueueArrayInput 

type OutputServiceBusQueueArrayInput interface {
	pulumi.Input

	ToOutputServiceBusQueueArrayOutput() OutputServiceBusQueueArrayOutput
	ToOutputServiceBusQueueArrayOutputWithContext(context.Context) OutputServiceBusQueueArrayOutput
}

OutputServiceBusQueueArrayInput is an input type that accepts OutputServiceBusQueueArray and OutputServiceBusQueueArrayOutput values. You can construct a concrete instance of `OutputServiceBusQueueArrayInput` via: 

OutputServiceBusQueueArray{ OutputServiceBusQueueArgs{...} }

type OutputServiceBusQueueArrayOutput 

type OutputServiceBusQueueArrayOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueArrayOutput) ElementType 

func (OutputServiceBusQueueArrayOutput) ElementType() reflect.Type

func (OutputServiceBusQueueArrayOutput) Index 

func (o OutputServiceBusQueueArrayOutput) Index(i pulumi.IntInput) OutputServiceBusQueueOutput

func (OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutput 

func (o OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutput() OutputServiceBusQueueArrayOutput

func (OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutputWithContext 

func (o OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutputWithContext(ctx context.Context) OutputServiceBusQueueArrayOutput

type OutputServiceBusQueueInput 

type OutputServiceBusQueueInput interface {
	pulumi.Input

	ToOutputServiceBusQueueOutput() OutputServiceBusQueueOutput
	ToOutputServiceBusQueueOutputWithContext(ctx context.Context) OutputServiceBusQueueOutput
}

type OutputServiceBusQueueMap 

type OutputServiceBusQueueMap map[string]OutputServiceBusQueueInput

func (OutputServiceBusQueueMap) ElementType 

func (OutputServiceBusQueueMap) ElementType() reflect.Type

func (OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutput 

func (i OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutput() OutputServiceBusQueueMapOutput

func (OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutputWithContext 

func (i OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutputWithContext(ctx context.Context) OutputServiceBusQueueMapOutput

type OutputServiceBusQueueMapInput 

type OutputServiceBusQueueMapInput interface {
	pulumi.Input

	ToOutputServiceBusQueueMapOutput() OutputServiceBusQueueMapOutput
	ToOutputServiceBusQueueMapOutputWithContext(context.Context) OutputServiceBusQueueMapOutput
}

OutputServiceBusQueueMapInput is an input type that accepts OutputServiceBusQueueMap and OutputServiceBusQueueMapOutput values. You can construct a concrete instance of `OutputServiceBusQueueMapInput` via: 

OutputServiceBusQueueMap{ "key": OutputServiceBusQueueArgs{...} }

type OutputServiceBusQueueMapOutput 

type OutputServiceBusQueueMapOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueMapOutput) ElementType 

func (OutputServiceBusQueueMapOutput) ElementType() reflect.Type

func (OutputServiceBusQueueMapOutput) MapIndex 

func (o OutputServiceBusQueueMapOutput) MapIndex(k pulumi.StringInput) OutputServiceBusQueueOutput

func (OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutput 

func (o OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutput() OutputServiceBusQueueMapOutput

func (OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutputWithContext 

func (o OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutputWithContext(ctx context.Context) OutputServiceBusQueueMapOutput

type OutputServiceBusQueueOutput 

type OutputServiceBusQueueOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueOutput) ElementType 

func (OutputServiceBusQueueOutput) ElementType() reflect.Type

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutput 

func (o OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutput() OutputServiceBusQueueOutput

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutputWithContext 

func (o OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutputWithContext(ctx context.Context) OutputServiceBusQueueOutput

type OutputServiceBusQueueSerialization 

type OutputServiceBusQueueSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format *string `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type OutputServiceBusQueueSerializationArgs 

type OutputServiceBusQueueSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format pulumi.StringPtrInput `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (OutputServiceBusQueueSerializationArgs) ElementType 

func (OutputServiceBusQueueSerializationArgs) ElementType() reflect.Type

func (OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationOutput 

func (i OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationOutput() OutputServiceBusQueueSerializationOutput

func (OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationOutputWithContext 

func (i OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationOutputWithContext(ctx context.Context) OutputServiceBusQueueSerializationOutput

func (OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationPtrOutput 

func (i OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationPtrOutput() OutputServiceBusQueueSerializationPtrOutput

func (OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationPtrOutputWithContext 

func (i OutputServiceBusQueueSerializationArgs) ToOutputServiceBusQueueSerializationPtrOutputWithContext(ctx context.Context) OutputServiceBusQueueSerializationPtrOutput

type OutputServiceBusQueueSerializationInput 

type OutputServiceBusQueueSerializationInput interface {
	pulumi.Input

	ToOutputServiceBusQueueSerializationOutput() OutputServiceBusQueueSerializationOutput
	ToOutputServiceBusQueueSerializationOutputWithContext(context.Context) OutputServiceBusQueueSerializationOutput
}

OutputServiceBusQueueSerializationInput is an input type that accepts OutputServiceBusQueueSerializationArgs and OutputServiceBusQueueSerializationOutput values. You can construct a concrete instance of `OutputServiceBusQueueSerializationInput` via: 

OutputServiceBusQueueSerializationArgs{...}

type OutputServiceBusQueueSerializationOutput 

type OutputServiceBusQueueSerializationOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueSerializationOutput) ElementType 

func (OutputServiceBusQueueSerializationOutput) ElementType() reflect.Type

func (OutputServiceBusQueueSerializationOutput) Encoding 

func (o OutputServiceBusQueueSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputServiceBusQueueSerializationOutput) FieldDelimiter 

func (o OutputServiceBusQueueSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputServiceBusQueueSerializationOutput) Format 

func (o OutputServiceBusQueueSerializationOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationOutput 

func (o OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationOutput() OutputServiceBusQueueSerializationOutput

func (OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationOutputWithContext 

func (o OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationOutputWithContext(ctx context.Context) OutputServiceBusQueueSerializationOutput

func (OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationPtrOutput 

func (o OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationPtrOutput() OutputServiceBusQueueSerializationPtrOutput

func (OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationPtrOutputWithContext 

func (o OutputServiceBusQueueSerializationOutput) ToOutputServiceBusQueueSerializationPtrOutputWithContext(ctx context.Context) OutputServiceBusQueueSerializationPtrOutput

func (OutputServiceBusQueueSerializationOutput) Type 

func (o OutputServiceBusQueueSerializationOutput) Type() pulumi.StringOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputServiceBusQueueSerializationPtrInput 

type OutputServiceBusQueueSerializationPtrInput interface {
	pulumi.Input

	ToOutputServiceBusQueueSerializationPtrOutput() OutputServiceBusQueueSerializationPtrOutput
	ToOutputServiceBusQueueSerializationPtrOutputWithContext(context.Context) OutputServiceBusQueueSerializationPtrOutput
}

OutputServiceBusQueueSerializationPtrInput is an input type that accepts OutputServiceBusQueueSerializationArgs, OutputServiceBusQueueSerializationPtr and OutputServiceBusQueueSerializationPtrOutput values. You can construct a concrete instance of `OutputServiceBusQueueSerializationPtrInput` via: 

        OutputServiceBusQueueSerializationArgs{...}

or:

        nil

func OutputServiceBusQueueSerializationPtr 

func OutputServiceBusQueueSerializationPtr(v *OutputServiceBusQueueSerializationArgs) OutputServiceBusQueueSerializationPtrInput

type OutputServiceBusQueueSerializationPtrOutput 

type OutputServiceBusQueueSerializationPtrOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueSerializationPtrOutput) Elem 

func (o OutputServiceBusQueueSerializationPtrOutput) Elem() OutputServiceBusQueueSerializationOutput

func (OutputServiceBusQueueSerializationPtrOutput) ElementType 

func (OutputServiceBusQueueSerializationPtrOutput) ElementType() reflect.Type

func (OutputServiceBusQueueSerializationPtrOutput) Encoding 

func (o OutputServiceBusQueueSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputServiceBusQueueSerializationPtrOutput) FieldDelimiter 

func (o OutputServiceBusQueueSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputServiceBusQueueSerializationPtrOutput) Format 

func (o OutputServiceBusQueueSerializationPtrOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputServiceBusQueueSerializationPtrOutput) ToOutputServiceBusQueueSerializationPtrOutput 

func (o OutputServiceBusQueueSerializationPtrOutput) ToOutputServiceBusQueueSerializationPtrOutput() OutputServiceBusQueueSerializationPtrOutput

func (OutputServiceBusQueueSerializationPtrOutput) ToOutputServiceBusQueueSerializationPtrOutputWithContext 

func (o OutputServiceBusQueueSerializationPtrOutput) ToOutputServiceBusQueueSerializationPtrOutputWithContext(ctx context.Context) OutputServiceBusQueueSerializationPtrOutput

func (OutputServiceBusQueueSerializationPtrOutput) Type 

func (o OutputServiceBusQueueSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputServiceBusQueueState 

type OutputServiceBusQueueState struct {
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Service Bus Queue.
	QueueName pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization OutputServiceBusQueueSerializationPtrInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringPtrInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringPtrInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (OutputServiceBusQueueState) ElementType 

func (OutputServiceBusQueueState) ElementType() reflect.Type

type OutputServicebusTopic 

type OutputServicebusTopic struct {
	pulumi.CustomResourceState

	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// A list of property columns to add to the Service Bus Topic output.
	PropertyColumns pulumi.StringArrayOutput `pulumi:"propertyColumns"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization OutputServicebusTopicSerializationOutput `pulumi:"serialization"`
	// The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringOutput `pulumi:"servicebusNamespace"`
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringOutput `pulumi:"sharedAccessPolicyKey"`
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringOutput `pulumi:"sharedAccessPolicyName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The name of the Service Bus Topic.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

Manages a Stream Analytics Output to a ServiceBus Topic.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/servicebus"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleNamespace, err := servicebus.NewNamespace(ctx, "exampleNamespace", &servicebus.NamespaceArgs{
			Location:          pulumi.String(exampleResourceGroup.Location),
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			Sku:               pulumi.String("Standard"),
		})
		if err != nil {
			return err
		}
		exampleTopic, err := servicebus.NewTopic(ctx, "exampleTopic", &servicebus.TopicArgs{
			NamespaceId:        exampleNamespace.ID(),
			EnablePartitioning: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputServicebusTopic(ctx, "exampleOutputServicebusTopic", &streamanalytics.OutputServicebusTopicArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			TopicName:              exampleTopic.Name,
			ServicebusNamespace:    exampleNamespace.Name,
			SharedAccessPolicyKey:  exampleNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName: pulumi.String("RootManageSharedAccessKey"),
			PropertyColumns: pulumi.StringArray{
				pulumi.String("col1"),
				pulumi.String("col2"),
			},
			Serialization: &streamanalytics.OutputServicebusTopicSerializationArgs{
				Format: pulumi.String("Avro"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Output ServiceBus Topic's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputServicebusTopic:OutputServicebusTopic example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputServicebusTopic 

func GetOutputServicebusTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputServicebusTopicState, opts ...pulumi.ResourceOption) (*OutputServicebusTopic, error)

GetOutputServicebusTopic gets an existing OutputServicebusTopic 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 NewOutputServicebusTopic 

func NewOutputServicebusTopic(ctx *pulumi.Context,
	name string, args *OutputServicebusTopicArgs, opts ...pulumi.ResourceOption) (*OutputServicebusTopic, error)

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

func (*OutputServicebusTopic) ElementType 

func (*OutputServicebusTopic) ElementType() reflect.Type

func (*OutputServicebusTopic) ToOutputServicebusTopicOutput 

func (i *OutputServicebusTopic) ToOutputServicebusTopicOutput() OutputServicebusTopicOutput

func (*OutputServicebusTopic) ToOutputServicebusTopicOutputWithContext 

func (i *OutputServicebusTopic) ToOutputServicebusTopicOutputWithContext(ctx context.Context) OutputServicebusTopicOutput

type OutputServicebusTopicArgs 

type OutputServicebusTopicArgs struct {
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// A list of property columns to add to the Service Bus Topic output.
	PropertyColumns pulumi.StringArrayInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization OutputServicebusTopicSerializationInput
	// The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The name of the Service Bus Topic.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a OutputServicebusTopic resource.

func (OutputServicebusTopicArgs) ElementType 

func (OutputServicebusTopicArgs) ElementType() reflect.Type

type OutputServicebusTopicArray 

type OutputServicebusTopicArray []OutputServicebusTopicInput

func (OutputServicebusTopicArray) ElementType 

func (OutputServicebusTopicArray) ElementType() reflect.Type

func (OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutput 

func (i OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutput() OutputServicebusTopicArrayOutput

func (OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutputWithContext 

func (i OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutputWithContext(ctx context.Context) OutputServicebusTopicArrayOutput

type OutputServicebusTopicArrayInput 

type OutputServicebusTopicArrayInput interface {
	pulumi.Input

	ToOutputServicebusTopicArrayOutput() OutputServicebusTopicArrayOutput
	ToOutputServicebusTopicArrayOutputWithContext(context.Context) OutputServicebusTopicArrayOutput
}

OutputServicebusTopicArrayInput is an input type that accepts OutputServicebusTopicArray and OutputServicebusTopicArrayOutput values. You can construct a concrete instance of `OutputServicebusTopicArrayInput` via: 

OutputServicebusTopicArray{ OutputServicebusTopicArgs{...} }

type OutputServicebusTopicArrayOutput 

type OutputServicebusTopicArrayOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicArrayOutput) ElementType 

func (OutputServicebusTopicArrayOutput) ElementType() reflect.Type

func (OutputServicebusTopicArrayOutput) Index 

func (o OutputServicebusTopicArrayOutput) Index(i pulumi.IntInput) OutputServicebusTopicOutput

func (OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutput 

func (o OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutput() OutputServicebusTopicArrayOutput

func (OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutputWithContext 

func (o OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutputWithContext(ctx context.Context) OutputServicebusTopicArrayOutput

type OutputServicebusTopicInput 

type OutputServicebusTopicInput interface {
	pulumi.Input

	ToOutputServicebusTopicOutput() OutputServicebusTopicOutput
	ToOutputServicebusTopicOutputWithContext(ctx context.Context) OutputServicebusTopicOutput
}

type OutputServicebusTopicMap 

type OutputServicebusTopicMap map[string]OutputServicebusTopicInput

func (OutputServicebusTopicMap) ElementType 

func (OutputServicebusTopicMap) ElementType() reflect.Type

func (OutputServicebusTopicMap) ToOutputServicebusTopicMapOutput 

func (i OutputServicebusTopicMap) ToOutputServicebusTopicMapOutput() OutputServicebusTopicMapOutput

func (OutputServicebusTopicMap) ToOutputServicebusTopicMapOutputWithContext 

func (i OutputServicebusTopicMap) ToOutputServicebusTopicMapOutputWithContext(ctx context.Context) OutputServicebusTopicMapOutput

type OutputServicebusTopicMapInput 

type OutputServicebusTopicMapInput interface {
	pulumi.Input

	ToOutputServicebusTopicMapOutput() OutputServicebusTopicMapOutput
	ToOutputServicebusTopicMapOutputWithContext(context.Context) OutputServicebusTopicMapOutput
}

OutputServicebusTopicMapInput is an input type that accepts OutputServicebusTopicMap and OutputServicebusTopicMapOutput values. You can construct a concrete instance of `OutputServicebusTopicMapInput` via: 

OutputServicebusTopicMap{ "key": OutputServicebusTopicArgs{...} }

type OutputServicebusTopicMapOutput 

type OutputServicebusTopicMapOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicMapOutput) ElementType 

func (OutputServicebusTopicMapOutput) ElementType() reflect.Type

func (OutputServicebusTopicMapOutput) MapIndex 

func (o OutputServicebusTopicMapOutput) MapIndex(k pulumi.StringInput) OutputServicebusTopicOutput

func (OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutput 

func (o OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutput() OutputServicebusTopicMapOutput

func (OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutputWithContext 

func (o OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutputWithContext(ctx context.Context) OutputServicebusTopicMapOutput

type OutputServicebusTopicOutput 

type OutputServicebusTopicOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicOutput) ElementType 

func (OutputServicebusTopicOutput) ElementType() reflect.Type

func (OutputServicebusTopicOutput) ToOutputServicebusTopicOutput 

func (o OutputServicebusTopicOutput) ToOutputServicebusTopicOutput() OutputServicebusTopicOutput

func (OutputServicebusTopicOutput) ToOutputServicebusTopicOutputWithContext 

func (o OutputServicebusTopicOutput) ToOutputServicebusTopicOutputWithContext(ctx context.Context) OutputServicebusTopicOutput

type OutputServicebusTopicSerialization 

type OutputServicebusTopicSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format *string `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type OutputServicebusTopicSerializationArgs 

type OutputServicebusTopicSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.
	Format pulumi.StringPtrInput `pulumi:"format"`
	// The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (OutputServicebusTopicSerializationArgs) ElementType 

func (OutputServicebusTopicSerializationArgs) ElementType() reflect.Type

func (OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationOutput 

func (i OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationOutput() OutputServicebusTopicSerializationOutput

func (OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationOutputWithContext 

func (i OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationOutputWithContext(ctx context.Context) OutputServicebusTopicSerializationOutput

func (OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationPtrOutput 

func (i OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationPtrOutput() OutputServicebusTopicSerializationPtrOutput

func (OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationPtrOutputWithContext 

func (i OutputServicebusTopicSerializationArgs) ToOutputServicebusTopicSerializationPtrOutputWithContext(ctx context.Context) OutputServicebusTopicSerializationPtrOutput

type OutputServicebusTopicSerializationInput 

type OutputServicebusTopicSerializationInput interface {
	pulumi.Input

	ToOutputServicebusTopicSerializationOutput() OutputServicebusTopicSerializationOutput
	ToOutputServicebusTopicSerializationOutputWithContext(context.Context) OutputServicebusTopicSerializationOutput
}

OutputServicebusTopicSerializationInput is an input type that accepts OutputServicebusTopicSerializationArgs and OutputServicebusTopicSerializationOutput values. You can construct a concrete instance of `OutputServicebusTopicSerializationInput` via: 

OutputServicebusTopicSerializationArgs{...}

type OutputServicebusTopicSerializationOutput 

type OutputServicebusTopicSerializationOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicSerializationOutput) ElementType 

func (OutputServicebusTopicSerializationOutput) ElementType() reflect.Type

func (OutputServicebusTopicSerializationOutput) Encoding 

func (o OutputServicebusTopicSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputServicebusTopicSerializationOutput) FieldDelimiter 

func (o OutputServicebusTopicSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputServicebusTopicSerializationOutput) Format 

func (o OutputServicebusTopicSerializationOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationOutput 

func (o OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationOutput() OutputServicebusTopicSerializationOutput

func (OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationOutputWithContext 

func (o OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationOutputWithContext(ctx context.Context) OutputServicebusTopicSerializationOutput

func (OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationPtrOutput 

func (o OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationPtrOutput() OutputServicebusTopicSerializationPtrOutput

func (OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationPtrOutputWithContext 

func (o OutputServicebusTopicSerializationOutput) ToOutputServicebusTopicSerializationPtrOutputWithContext(ctx context.Context) OutputServicebusTopicSerializationPtrOutput

func (OutputServicebusTopicSerializationOutput) Type 

func (o OutputServicebusTopicSerializationOutput) Type() pulumi.StringOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputServicebusTopicSerializationPtrInput 

type OutputServicebusTopicSerializationPtrInput interface {
	pulumi.Input

	ToOutputServicebusTopicSerializationPtrOutput() OutputServicebusTopicSerializationPtrOutput
	ToOutputServicebusTopicSerializationPtrOutputWithContext(context.Context) OutputServicebusTopicSerializationPtrOutput
}

OutputServicebusTopicSerializationPtrInput is an input type that accepts OutputServicebusTopicSerializationArgs, OutputServicebusTopicSerializationPtr and OutputServicebusTopicSerializationPtrOutput values. You can construct a concrete instance of `OutputServicebusTopicSerializationPtrInput` via: 

        OutputServicebusTopicSerializationArgs{...}

or:

        nil

func OutputServicebusTopicSerializationPtr 

func OutputServicebusTopicSerializationPtr(v *OutputServicebusTopicSerializationArgs) OutputServicebusTopicSerializationPtrInput

type OutputServicebusTopicSerializationPtrOutput 

type OutputServicebusTopicSerializationPtrOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicSerializationPtrOutput) Elem 

func (o OutputServicebusTopicSerializationPtrOutput) Elem() OutputServicebusTopicSerializationOutput

func (OutputServicebusTopicSerializationPtrOutput) ElementType 

func (OutputServicebusTopicSerializationPtrOutput) ElementType() reflect.Type

func (OutputServicebusTopicSerializationPtrOutput) Encoding 

func (o OutputServicebusTopicSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (OutputServicebusTopicSerializationPtrOutput) FieldDelimiter 

func (o OutputServicebusTopicSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (OutputServicebusTopicSerializationPtrOutput) Format 

func (o OutputServicebusTopicSerializationPtrOutput) Format() pulumi.StringPtrOutput

Specifies the format of the JSON the output will be written in. Possible values are `Array` and `LineSeparated`.

func (OutputServicebusTopicSerializationPtrOutput) ToOutputServicebusTopicSerializationPtrOutput 

func (o OutputServicebusTopicSerializationPtrOutput) ToOutputServicebusTopicSerializationPtrOutput() OutputServicebusTopicSerializationPtrOutput

func (OutputServicebusTopicSerializationPtrOutput) ToOutputServicebusTopicSerializationPtrOutputWithContext 

func (o OutputServicebusTopicSerializationPtrOutput) ToOutputServicebusTopicSerializationPtrOutputWithContext(ctx context.Context) OutputServicebusTopicSerializationPtrOutput

func (OutputServicebusTopicSerializationPtrOutput) Type 

func (o OutputServicebusTopicSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for outgoing data streams. Possible values are `Avro`, `Csv` and `Json`.

type OutputServicebusTopicState 

type OutputServicebusTopicState struct {
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// A list of property columns to add to the Service Bus Topic output.
	PropertyColumns pulumi.StringArrayInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization OutputServicebusTopicSerializationPtrInput
	// The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringPtrInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringPtrInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The name of the Service Bus Topic.
	TopicName pulumi.StringPtrInput
}

func (OutputServicebusTopicState) ElementType 

func (OutputServicebusTopicState) ElementType() reflect.Type

type OutputSynapse added in v4.26.0 

type OutputSynapse struct {
	pulumi.CustomResourceState

	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	Database pulumi.StringOutput `pulumi:"database"`
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The password that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	Password pulumi.StringOutput `pulumi:"password"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	Server pulumi.StringOutput `pulumi:"server"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	Table pulumi.StringOutput `pulumi:"table"`
	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	User pulumi.StringOutput `pulumi:"user"`
}

Manages a Stream Analytics Output to an Azure Synapse Analytics Workspace.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/synapse"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      pulumi.Any(azurerm_resource_group.Example.Name),
			Location:               pulumi.Any(azurerm_resource_group.Example.Location),
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
			AccountKind:            pulumi.String("StorageV2"),
			IsHnsEnabled:           pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		exampleDataLakeGen2Filesystem, err := storage.NewDataLakeGen2Filesystem(ctx, "exampleDataLakeGen2Filesystem", &storage.DataLakeGen2FilesystemArgs{
			StorageAccountId: exampleAccount.ID(),
		})
		if err != nil {
			return err
		}
		_, err = synapse.NewWorkspace(ctx, "exampleWorkspace", &synapse.WorkspaceArgs{
			ResourceGroupName:               pulumi.Any(azurerm_resource_group.Example.Name),
			Location:                        pulumi.Any(azurerm_resource_group.Example.Location),
			StorageDataLakeGen2FilesystemId: exampleDataLakeGen2Filesystem.ID(),
			SqlAdministratorLogin:           pulumi.String("sqladminuser"),
			SqlAdministratorLoginPassword:   pulumi.String("H@Sh1CoR3!"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputSynapse(ctx, "exampleOutputSynapse", &streamanalytics.OutputSynapseArgs{
			StreamAnalyticsJobName: pulumi.Any(azurerm_stream_analytics_job.Example.Name),
			ResourceGroupName:      pulumi.Any(azurerm_stream_analytics_job.Example.Resource_group_name),
			Server:                 pulumi.Any(azurerm_synapse_workspace.Test.Connectivity_endpoints.SqlOnDemand),
			User:                   pulumi.Any(azurerm_synapse_workspace.Test.Sql_administrator_login),
			Password:               pulumi.Any(azurerm_synapse_workspace.Test.Sql_administrator_login_password),
			Database:               pulumi.String("master"),
			Table:                  pulumi.String("ExampleTable"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

A Stream Analytics Output to an Azure Synapse Analytics Workspace can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputSynapse:OutputSynapse example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputSynapse added in v4.26.0 

func GetOutputSynapse(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputSynapseState, opts ...pulumi.ResourceOption) (*OutputSynapse, error)

GetOutputSynapse gets an existing OutputSynapse 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 NewOutputSynapse added in v4.26.0 

func NewOutputSynapse(ctx *pulumi.Context,
	name string, args *OutputSynapseArgs, opts ...pulumi.ResourceOption) (*OutputSynapse, error)

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

func (*OutputSynapse) ElementType added in v4.26.0 

func (*OutputSynapse) ElementType() reflect.Type

func (*OutputSynapse) ToOutputSynapseOutput added in v4.26.0 

func (i *OutputSynapse) ToOutputSynapseOutput() OutputSynapseOutput

func (*OutputSynapse) ToOutputSynapseOutputWithContext added in v4.26.0 

func (i *OutputSynapse) ToOutputSynapseOutputWithContext(ctx context.Context) OutputSynapseOutput

type OutputSynapseArgs added in v4.26.0 

type OutputSynapseArgs struct {
	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	Database pulumi.StringInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The password that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	Password pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	Server pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	Table pulumi.StringInput
	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	User pulumi.StringInput
}

The set of arguments for constructing a OutputSynapse resource.

func (OutputSynapseArgs) ElementType added in v4.26.0 

func (OutputSynapseArgs) ElementType() reflect.Type

type OutputSynapseArray added in v4.26.0 

type OutputSynapseArray []OutputSynapseInput

func (OutputSynapseArray) ElementType added in v4.26.0 

func (OutputSynapseArray) ElementType() reflect.Type

func (OutputSynapseArray) ToOutputSynapseArrayOutput added in v4.26.0 

func (i OutputSynapseArray) ToOutputSynapseArrayOutput() OutputSynapseArrayOutput

func (OutputSynapseArray) ToOutputSynapseArrayOutputWithContext added in v4.26.0 

func (i OutputSynapseArray) ToOutputSynapseArrayOutputWithContext(ctx context.Context) OutputSynapseArrayOutput

type OutputSynapseArrayInput added in v4.26.0 

type OutputSynapseArrayInput interface {
	pulumi.Input

	ToOutputSynapseArrayOutput() OutputSynapseArrayOutput
	ToOutputSynapseArrayOutputWithContext(context.Context) OutputSynapseArrayOutput
}

OutputSynapseArrayInput is an input type that accepts OutputSynapseArray and OutputSynapseArrayOutput values. You can construct a concrete instance of `OutputSynapseArrayInput` via: 

OutputSynapseArray{ OutputSynapseArgs{...} }

type OutputSynapseArrayOutput added in v4.26.0 

type OutputSynapseArrayOutput struct{ *pulumi.OutputState }

func (OutputSynapseArrayOutput) ElementType added in v4.26.0 

func (OutputSynapseArrayOutput) ElementType() reflect.Type

func (OutputSynapseArrayOutput) Index added in v4.26.0 

func (o OutputSynapseArrayOutput) Index(i pulumi.IntInput) OutputSynapseOutput

func (OutputSynapseArrayOutput) ToOutputSynapseArrayOutput added in v4.26.0 

func (o OutputSynapseArrayOutput) ToOutputSynapseArrayOutput() OutputSynapseArrayOutput

func (OutputSynapseArrayOutput) ToOutputSynapseArrayOutputWithContext added in v4.26.0 

func (o OutputSynapseArrayOutput) ToOutputSynapseArrayOutputWithContext(ctx context.Context) OutputSynapseArrayOutput

type OutputSynapseInput added in v4.26.0 

type OutputSynapseInput interface {
	pulumi.Input

	ToOutputSynapseOutput() OutputSynapseOutput
	ToOutputSynapseOutputWithContext(ctx context.Context) OutputSynapseOutput
}

type OutputSynapseMap added in v4.26.0 

type OutputSynapseMap map[string]OutputSynapseInput

func (OutputSynapseMap) ElementType added in v4.26.0 

func (OutputSynapseMap) ElementType() reflect.Type

func (OutputSynapseMap) ToOutputSynapseMapOutput added in v4.26.0 

func (i OutputSynapseMap) ToOutputSynapseMapOutput() OutputSynapseMapOutput

func (OutputSynapseMap) ToOutputSynapseMapOutputWithContext added in v4.26.0 

func (i OutputSynapseMap) ToOutputSynapseMapOutputWithContext(ctx context.Context) OutputSynapseMapOutput

type OutputSynapseMapInput added in v4.26.0 

type OutputSynapseMapInput interface {
	pulumi.Input

	ToOutputSynapseMapOutput() OutputSynapseMapOutput
	ToOutputSynapseMapOutputWithContext(context.Context) OutputSynapseMapOutput
}

OutputSynapseMapInput is an input type that accepts OutputSynapseMap and OutputSynapseMapOutput values. You can construct a concrete instance of `OutputSynapseMapInput` via: 

OutputSynapseMap{ "key": OutputSynapseArgs{...} }

type OutputSynapseMapOutput added in v4.26.0 

type OutputSynapseMapOutput struct{ *pulumi.OutputState }

func (OutputSynapseMapOutput) ElementType added in v4.26.0 

func (OutputSynapseMapOutput) ElementType() reflect.Type

func (OutputSynapseMapOutput) MapIndex added in v4.26.0 

func (o OutputSynapseMapOutput) MapIndex(k pulumi.StringInput) OutputSynapseOutput

func (OutputSynapseMapOutput) ToOutputSynapseMapOutput added in v4.26.0 

func (o OutputSynapseMapOutput) ToOutputSynapseMapOutput() OutputSynapseMapOutput

func (OutputSynapseMapOutput) ToOutputSynapseMapOutputWithContext added in v4.26.0 

func (o OutputSynapseMapOutput) ToOutputSynapseMapOutputWithContext(ctx context.Context) OutputSynapseMapOutput

type OutputSynapseOutput added in v4.26.0 

type OutputSynapseOutput struct{ *pulumi.OutputState }

func (OutputSynapseOutput) ElementType added in v4.26.0 

func (OutputSynapseOutput) ElementType() reflect.Type

func (OutputSynapseOutput) ToOutputSynapseOutput added in v4.26.0 

func (o OutputSynapseOutput) ToOutputSynapseOutput() OutputSynapseOutput

func (OutputSynapseOutput) ToOutputSynapseOutputWithContext added in v4.26.0 

func (o OutputSynapseOutput) ToOutputSynapseOutputWithContext(ctx context.Context) OutputSynapseOutput

type OutputSynapseState added in v4.26.0 

type OutputSynapseState struct {
	// The name of the Azure SQL database. Changing this forces a new resource to be created.
	Database pulumi.StringPtrInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The password that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	Password pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.
	Server pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The name of the table in the Azure SQL database. Changing this forces a new resource to be created.
	Table pulumi.StringPtrInput
	// The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.
	User pulumi.StringPtrInput
}

func (OutputSynapseState) ElementType added in v4.26.0 

func (OutputSynapseState) ElementType() reflect.Type

type OutputTable added in v4.25.0 

type OutputTable struct {
	pulumi.CustomResourceState

	// The number of records for a batch operation. Must be between `1` and `100`.
	BatchSize pulumi.IntOutput `pulumi:"batchSize"`
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the output column that contains the partition key.
	PartitionKey pulumi.StringOutput `pulumi:"partitionKey"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The name of the output column that contains the row key.
	RowKey pulumi.StringOutput `pulumi:"rowKey"`
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringOutput `pulumi:"storageAccountKey"`
	// The name of the Storage Account.
	StorageAccountName pulumi.StringOutput `pulumi:"storageAccountName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The name of the table where the stream should be output to.
	Table pulumi.StringOutput `pulumi:"table"`
}

Manages a Stream Analytics Output Table.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      pulumi.String(exampleResourceGroup.Name),
			Location:               pulumi.String(exampleResourceGroup.Location),
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		exampleTable, err := storage.NewTable(ctx, "exampleTable", &storage.TableArgs{
			StorageAccountName: exampleAccount.Name,
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputTable(ctx, "exampleOutputTable", &streamanalytics.OutputTableArgs{
			StreamAnalyticsJobName: pulumi.Any(azurerm_stream_analytics_job.Example.Name),
			ResourceGroupName:      pulumi.Any(azurerm_stream_analytics_job.Example.Resource_group_name),
			StorageAccountName:     exampleAccount.Name,
			StorageAccountKey:      exampleAccount.PrimaryAccessKey,
			Table:                  exampleTable.Name,
			PartitionKey:           pulumi.String("foo"),
			RowKey:                 pulumi.String("bar"),
			BatchSize:              pulumi.Int(100),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Output to Table can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/outputTable:OutputTable example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/outputs/output1

```

func GetOutputTable added in v4.25.0 

func GetOutputTable(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OutputTableState, opts ...pulumi.ResourceOption) (*OutputTable, error)

GetOutputTable gets an existing OutputTable 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 NewOutputTable added in v4.25.0 

func NewOutputTable(ctx *pulumi.Context,
	name string, args *OutputTableArgs, opts ...pulumi.ResourceOption) (*OutputTable, error)

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

func (*OutputTable) ElementType added in v4.25.0 

func (*OutputTable) ElementType() reflect.Type

func (*OutputTable) ToOutputTableOutput added in v4.25.0 

func (i *OutputTable) ToOutputTableOutput() OutputTableOutput

func (*OutputTable) ToOutputTableOutputWithContext added in v4.25.0 

func (i *OutputTable) ToOutputTableOutputWithContext(ctx context.Context) OutputTableOutput

type OutputTableArgs added in v4.25.0 

type OutputTableArgs struct {
	// The number of records for a batch operation. Must be between `1` and `100`.
	BatchSize pulumi.IntInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the output column that contains the partition key.
	PartitionKey pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The name of the output column that contains the row key.
	RowKey pulumi.StringInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The name of the table where the stream should be output to.
	Table pulumi.StringInput
}

The set of arguments for constructing a OutputTable resource.

func (OutputTableArgs) ElementType added in v4.25.0 

func (OutputTableArgs) ElementType() reflect.Type

type OutputTableArray added in v4.25.0 

type OutputTableArray []OutputTableInput

func (OutputTableArray) ElementType added in v4.25.0 

func (OutputTableArray) ElementType() reflect.Type

func (OutputTableArray) ToOutputTableArrayOutput added in v4.25.0 

func (i OutputTableArray) ToOutputTableArrayOutput() OutputTableArrayOutput

func (OutputTableArray) ToOutputTableArrayOutputWithContext added in v4.25.0 

func (i OutputTableArray) ToOutputTableArrayOutputWithContext(ctx context.Context) OutputTableArrayOutput

type OutputTableArrayInput added in v4.25.0 

type OutputTableArrayInput interface {
	pulumi.Input

	ToOutputTableArrayOutput() OutputTableArrayOutput
	ToOutputTableArrayOutputWithContext(context.Context) OutputTableArrayOutput
}

OutputTableArrayInput is an input type that accepts OutputTableArray and OutputTableArrayOutput values. You can construct a concrete instance of `OutputTableArrayInput` via: 

OutputTableArray{ OutputTableArgs{...} }

type OutputTableArrayOutput added in v4.25.0 

type OutputTableArrayOutput struct{ *pulumi.OutputState }

func (OutputTableArrayOutput) ElementType added in v4.25.0 

func (OutputTableArrayOutput) ElementType() reflect.Type

func (OutputTableArrayOutput) Index added in v4.25.0 

func (o OutputTableArrayOutput) Index(i pulumi.IntInput) OutputTableOutput

func (OutputTableArrayOutput) ToOutputTableArrayOutput added in v4.25.0 

func (o OutputTableArrayOutput) ToOutputTableArrayOutput() OutputTableArrayOutput

func (OutputTableArrayOutput) ToOutputTableArrayOutputWithContext added in v4.25.0 

func (o OutputTableArrayOutput) ToOutputTableArrayOutputWithContext(ctx context.Context) OutputTableArrayOutput

type OutputTableInput added in v4.25.0 

type OutputTableInput interface {
	pulumi.Input

	ToOutputTableOutput() OutputTableOutput
	ToOutputTableOutputWithContext(ctx context.Context) OutputTableOutput
}

type OutputTableMap added in v4.25.0 

type OutputTableMap map[string]OutputTableInput

func (OutputTableMap) ElementType added in v4.25.0 

func (OutputTableMap) ElementType() reflect.Type

func (OutputTableMap) ToOutputTableMapOutput added in v4.25.0 

func (i OutputTableMap) ToOutputTableMapOutput() OutputTableMapOutput

func (OutputTableMap) ToOutputTableMapOutputWithContext added in v4.25.0 

func (i OutputTableMap) ToOutputTableMapOutputWithContext(ctx context.Context) OutputTableMapOutput

type OutputTableMapInput added in v4.25.0 

type OutputTableMapInput interface {
	pulumi.Input

	ToOutputTableMapOutput() OutputTableMapOutput
	ToOutputTableMapOutputWithContext(context.Context) OutputTableMapOutput
}

OutputTableMapInput is an input type that accepts OutputTableMap and OutputTableMapOutput values. You can construct a concrete instance of `OutputTableMapInput` via: 

OutputTableMap{ "key": OutputTableArgs{...} }

type OutputTableMapOutput added in v4.25.0 

type OutputTableMapOutput struct{ *pulumi.OutputState }

func (OutputTableMapOutput) ElementType added in v4.25.0 

func (OutputTableMapOutput) ElementType() reflect.Type

func (OutputTableMapOutput) MapIndex added in v4.25.0 

func (o OutputTableMapOutput) MapIndex(k pulumi.StringInput) OutputTableOutput

func (OutputTableMapOutput) ToOutputTableMapOutput added in v4.25.0 

func (o OutputTableMapOutput) ToOutputTableMapOutput() OutputTableMapOutput

func (OutputTableMapOutput) ToOutputTableMapOutputWithContext added in v4.25.0 

func (o OutputTableMapOutput) ToOutputTableMapOutputWithContext(ctx context.Context) OutputTableMapOutput

type OutputTableOutput added in v4.25.0 

type OutputTableOutput struct{ *pulumi.OutputState }

func (OutputTableOutput) ElementType added in v4.25.0 

func (OutputTableOutput) ElementType() reflect.Type

func (OutputTableOutput) ToOutputTableOutput added in v4.25.0 

func (o OutputTableOutput) ToOutputTableOutput() OutputTableOutput

func (OutputTableOutput) ToOutputTableOutputWithContext added in v4.25.0 

func (o OutputTableOutput) ToOutputTableOutputWithContext(ctx context.Context) OutputTableOutput

type OutputTableState added in v4.25.0 

type OutputTableState struct {
	// The number of records for a batch operation. Must be between `1` and `100`.
	BatchSize pulumi.IntPtrInput
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the output column that contains the partition key.
	PartitionKey pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The name of the output column that contains the row key.
	RowKey pulumi.StringPtrInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringPtrInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The name of the table where the stream should be output to.
	Table pulumi.StringPtrInput
}

func (OutputTableState) ElementType added in v4.25.0 

func (OutputTableState) ElementType() reflect.Type

type ReferenceInputBlob 

type ReferenceInputBlob struct {
	pulumi.CustomResourceState

	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringOutput `pulumi:"dateFormat"`
	// The name of the Reference Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringOutput `pulumi:"pathPattern"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization ReferenceInputBlobSerializationOutput `pulumi:"serialization"`
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringOutput `pulumi:"storageAccountKey"`
	// The name of the Storage Account that has the blob container with reference data.
	StorageAccountName pulumi.StringOutput `pulumi:"storageAccountName"`
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringOutput `pulumi:"storageContainerName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringOutput `pulumi:"timeFormat"`
}

Manages a Stream Analytics Reference Input Blob. Reference data (also known as a lookup table) is a finite data set that is static or slowly changing in nature, used to perform a lookup or to correlate with your data stream. Learn more [here](https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-use-reference-data#azure-blob-storage).

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      pulumi.Any(azurerm_resource_group.Example.Name),
			Location:               pulumi.Any(azurerm_resource_group.Example.Location),
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		exampleContainer, err := storage.NewContainer(ctx, "exampleContainer", &storage.ContainerArgs{
			StorageAccountName:  exampleAccount.Name,
			ContainerAccessType: pulumi.String("private"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewReferenceInputBlob(ctx, "test", &streamanalytics.ReferenceInputBlobArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			StorageAccountName:     exampleAccount.Name,
			StorageAccountKey:      exampleAccount.PrimaryAccessKey,
			StorageContainerName:   exampleContainer.Name,
			PathPattern:            pulumi.String("some-random-pattern"),
			DateFormat:             pulumi.String("yyyy/MM/dd"),
			TimeFormat:             pulumi.String("HH"),
			Serialization: &streamanalytics.ReferenceInputBlobSerializationArgs{
				Type:     pulumi.String("Json"),
				Encoding: pulumi.String("UTF8"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Reference Input Blob's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/referenceInputBlob:ReferenceInputBlob example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/inputs/input1

```

func GetReferenceInputBlob 

func GetReferenceInputBlob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReferenceInputBlobState, opts ...pulumi.ResourceOption) (*ReferenceInputBlob, error)

GetReferenceInputBlob gets an existing ReferenceInputBlob 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 NewReferenceInputBlob 

func NewReferenceInputBlob(ctx *pulumi.Context,
	name string, args *ReferenceInputBlobArgs, opts ...pulumi.ResourceOption) (*ReferenceInputBlob, error)

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

func (*ReferenceInputBlob) ElementType 

func (*ReferenceInputBlob) ElementType() reflect.Type

func (*ReferenceInputBlob) ToReferenceInputBlobOutput 

func (i *ReferenceInputBlob) ToReferenceInputBlobOutput() ReferenceInputBlobOutput

func (*ReferenceInputBlob) ToReferenceInputBlobOutputWithContext 

func (i *ReferenceInputBlob) ToReferenceInputBlobOutputWithContext(ctx context.Context) ReferenceInputBlobOutput

type ReferenceInputBlobArgs 

type ReferenceInputBlobArgs struct {
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringInput
	// The name of the Reference Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization ReferenceInputBlobSerializationInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringInput
	// The name of the Storage Account that has the blob container with reference data.
	StorageAccountName pulumi.StringInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringInput
}

The set of arguments for constructing a ReferenceInputBlob resource.

func (ReferenceInputBlobArgs) ElementType 

func (ReferenceInputBlobArgs) ElementType() reflect.Type

type ReferenceInputBlobArray 

type ReferenceInputBlobArray []ReferenceInputBlobInput

func (ReferenceInputBlobArray) ElementType 

func (ReferenceInputBlobArray) ElementType() reflect.Type

func (ReferenceInputBlobArray) ToReferenceInputBlobArrayOutput 

func (i ReferenceInputBlobArray) ToReferenceInputBlobArrayOutput() ReferenceInputBlobArrayOutput

func (ReferenceInputBlobArray) ToReferenceInputBlobArrayOutputWithContext 

func (i ReferenceInputBlobArray) ToReferenceInputBlobArrayOutputWithContext(ctx context.Context) ReferenceInputBlobArrayOutput

type ReferenceInputBlobArrayInput 

type ReferenceInputBlobArrayInput interface {
	pulumi.Input

	ToReferenceInputBlobArrayOutput() ReferenceInputBlobArrayOutput
	ToReferenceInputBlobArrayOutputWithContext(context.Context) ReferenceInputBlobArrayOutput
}

ReferenceInputBlobArrayInput is an input type that accepts ReferenceInputBlobArray and ReferenceInputBlobArrayOutput values. You can construct a concrete instance of `ReferenceInputBlobArrayInput` via: 

ReferenceInputBlobArray{ ReferenceInputBlobArgs{...} }

type ReferenceInputBlobArrayOutput 

type ReferenceInputBlobArrayOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobArrayOutput) ElementType 

func (ReferenceInputBlobArrayOutput) ElementType() reflect.Type

func (ReferenceInputBlobArrayOutput) Index 

func (o ReferenceInputBlobArrayOutput) Index(i pulumi.IntInput) ReferenceInputBlobOutput

func (ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutput 

func (o ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutput() ReferenceInputBlobArrayOutput

func (ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutputWithContext 

func (o ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutputWithContext(ctx context.Context) ReferenceInputBlobArrayOutput

type ReferenceInputBlobInput 

type ReferenceInputBlobInput interface {
	pulumi.Input

	ToReferenceInputBlobOutput() ReferenceInputBlobOutput
	ToReferenceInputBlobOutputWithContext(ctx context.Context) ReferenceInputBlobOutput
}

type ReferenceInputBlobMap 

type ReferenceInputBlobMap map[string]ReferenceInputBlobInput

func (ReferenceInputBlobMap) ElementType 

func (ReferenceInputBlobMap) ElementType() reflect.Type

func (ReferenceInputBlobMap) ToReferenceInputBlobMapOutput 

func (i ReferenceInputBlobMap) ToReferenceInputBlobMapOutput() ReferenceInputBlobMapOutput

func (ReferenceInputBlobMap) ToReferenceInputBlobMapOutputWithContext 

func (i ReferenceInputBlobMap) ToReferenceInputBlobMapOutputWithContext(ctx context.Context) ReferenceInputBlobMapOutput

type ReferenceInputBlobMapInput 

type ReferenceInputBlobMapInput interface {
	pulumi.Input

	ToReferenceInputBlobMapOutput() ReferenceInputBlobMapOutput
	ToReferenceInputBlobMapOutputWithContext(context.Context) ReferenceInputBlobMapOutput
}

ReferenceInputBlobMapInput is an input type that accepts ReferenceInputBlobMap and ReferenceInputBlobMapOutput values. You can construct a concrete instance of `ReferenceInputBlobMapInput` via: 

ReferenceInputBlobMap{ "key": ReferenceInputBlobArgs{...} }

type ReferenceInputBlobMapOutput 

type ReferenceInputBlobMapOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobMapOutput) ElementType 

func (ReferenceInputBlobMapOutput) ElementType() reflect.Type

func (ReferenceInputBlobMapOutput) MapIndex 

func (o ReferenceInputBlobMapOutput) MapIndex(k pulumi.StringInput) ReferenceInputBlobOutput

func (ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutput 

func (o ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutput() ReferenceInputBlobMapOutput

func (ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutputWithContext 

func (o ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutputWithContext(ctx context.Context) ReferenceInputBlobMapOutput

type ReferenceInputBlobOutput 

type ReferenceInputBlobOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobOutput) ElementType 

func (ReferenceInputBlobOutput) ElementType() reflect.Type

func (ReferenceInputBlobOutput) ToReferenceInputBlobOutput 

func (o ReferenceInputBlobOutput) ToReferenceInputBlobOutput() ReferenceInputBlobOutput

func (ReferenceInputBlobOutput) ToReferenceInputBlobOutputWithContext 

func (o ReferenceInputBlobOutput) ToReferenceInputBlobOutputWithContext(ctx context.Context) ReferenceInputBlobOutput

type ReferenceInputBlobSerialization 

type ReferenceInputBlobSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `	` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// The serialization format used for the reference data. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type ReferenceInputBlobSerializationArgs 

type ReferenceInputBlobSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `	` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// The serialization format used for the reference data. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (ReferenceInputBlobSerializationArgs) ElementType 

func (ReferenceInputBlobSerializationArgs) ElementType() reflect.Type

func (ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationOutput 

func (i ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationOutput() ReferenceInputBlobSerializationOutput

func (ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationOutputWithContext 

func (i ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationOutputWithContext(ctx context.Context) ReferenceInputBlobSerializationOutput

func (ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationPtrOutput 

func (i ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationPtrOutput() ReferenceInputBlobSerializationPtrOutput

func (ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationPtrOutputWithContext 

func (i ReferenceInputBlobSerializationArgs) ToReferenceInputBlobSerializationPtrOutputWithContext(ctx context.Context) ReferenceInputBlobSerializationPtrOutput

type ReferenceInputBlobSerializationInput 

type ReferenceInputBlobSerializationInput interface {
	pulumi.Input

	ToReferenceInputBlobSerializationOutput() ReferenceInputBlobSerializationOutput
	ToReferenceInputBlobSerializationOutputWithContext(context.Context) ReferenceInputBlobSerializationOutput
}

ReferenceInputBlobSerializationInput is an input type that accepts ReferenceInputBlobSerializationArgs and ReferenceInputBlobSerializationOutput values. You can construct a concrete instance of `ReferenceInputBlobSerializationInput` via: 

ReferenceInputBlobSerializationArgs{...}

type ReferenceInputBlobSerializationOutput 

type ReferenceInputBlobSerializationOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobSerializationOutput) ElementType 

func (ReferenceInputBlobSerializationOutput) ElementType() reflect.Type

func (ReferenceInputBlobSerializationOutput) Encoding 

func (o ReferenceInputBlobSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (ReferenceInputBlobSerializationOutput) FieldDelimiter 

func (o ReferenceInputBlobSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationOutput 

func (o ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationOutput() ReferenceInputBlobSerializationOutput

func (ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationOutputWithContext 

func (o ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationOutputWithContext(ctx context.Context) ReferenceInputBlobSerializationOutput

func (ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationPtrOutput 

func (o ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationPtrOutput() ReferenceInputBlobSerializationPtrOutput

func (ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationPtrOutputWithContext 

func (o ReferenceInputBlobSerializationOutput) ToReferenceInputBlobSerializationPtrOutputWithContext(ctx context.Context) ReferenceInputBlobSerializationPtrOutput

func (ReferenceInputBlobSerializationOutput) Type 

func (o ReferenceInputBlobSerializationOutput) Type() pulumi.StringOutput

The serialization format used for the reference data. Possible values are `Avro`, `Csv` and `Json`.

type ReferenceInputBlobSerializationPtrInput 

type ReferenceInputBlobSerializationPtrInput interface {
	pulumi.Input

	ToReferenceInputBlobSerializationPtrOutput() ReferenceInputBlobSerializationPtrOutput
	ToReferenceInputBlobSerializationPtrOutputWithContext(context.Context) ReferenceInputBlobSerializationPtrOutput
}

ReferenceInputBlobSerializationPtrInput is an input type that accepts ReferenceInputBlobSerializationArgs, ReferenceInputBlobSerializationPtr and ReferenceInputBlobSerializationPtrOutput values. You can construct a concrete instance of `ReferenceInputBlobSerializationPtrInput` via: 

        ReferenceInputBlobSerializationArgs{...}

or:

        nil

func ReferenceInputBlobSerializationPtr 

func ReferenceInputBlobSerializationPtr(v *ReferenceInputBlobSerializationArgs) ReferenceInputBlobSerializationPtrInput

type ReferenceInputBlobSerializationPtrOutput 

type ReferenceInputBlobSerializationPtrOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobSerializationPtrOutput) Elem 

func (o ReferenceInputBlobSerializationPtrOutput) Elem() ReferenceInputBlobSerializationOutput

func (ReferenceInputBlobSerializationPtrOutput) ElementType 

func (ReferenceInputBlobSerializationPtrOutput) ElementType() reflect.Type

func (ReferenceInputBlobSerializationPtrOutput) Encoding 

func (o ReferenceInputBlobSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (ReferenceInputBlobSerializationPtrOutput) FieldDelimiter 

func (o ReferenceInputBlobSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (ReferenceInputBlobSerializationPtrOutput) ToReferenceInputBlobSerializationPtrOutput 

func (o ReferenceInputBlobSerializationPtrOutput) ToReferenceInputBlobSerializationPtrOutput() ReferenceInputBlobSerializationPtrOutput

func (ReferenceInputBlobSerializationPtrOutput) ToReferenceInputBlobSerializationPtrOutputWithContext 

func (o ReferenceInputBlobSerializationPtrOutput) ToReferenceInputBlobSerializationPtrOutputWithContext(ctx context.Context) ReferenceInputBlobSerializationPtrOutput

func (ReferenceInputBlobSerializationPtrOutput) Type 

func (o ReferenceInputBlobSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for the reference data. Possible values are `Avro`, `Csv` and `Json`.

type ReferenceInputBlobState 

type ReferenceInputBlobState struct {
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringPtrInput
	// The name of the Reference Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization ReferenceInputBlobSerializationPtrInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringPtrInput
	// The name of the Storage Account that has the blob container with reference data.
	StorageAccountName pulumi.StringPtrInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringPtrInput
}

func (ReferenceInputBlobState) ElementType 

func (ReferenceInputBlobState) ElementType() reflect.Type

type ReferenceInputMssql added in v4.25.0 

type ReferenceInputMssql struct {
	pulumi.CustomResourceState

	// The MS SQL database name where the reference data exists.
	Database pulumi.StringOutput `pulumi:"database"`
	// The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when `refreshType` is `Static`.
	DeltaSnapshotQuery pulumi.StringPtrOutput `pulumi:"deltaSnapshotQuery"`
	// The query used to retrieve the reference data from the MS SQL database.
	FullSnapshotQuery pulumi.StringOutput `pulumi:"fullSnapshotQuery"`
	// The name of the Reference Input MS SQL data. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The username to connect to the MS SQL database.
	Password pulumi.StringOutput `pulumi:"password"`
	// The frequency in `hh:mm:ss` with which the reference data should be retrieved from the MS SQL database e.g. `00:20:00` for every 20 minutes. Must be set when `refreshType` is `RefreshPeriodicallyWithFull` or `RefreshPeriodicallyWithDelta`.
	RefreshIntervalDuration pulumi.StringPtrOutput `pulumi:"refreshIntervalDuration"`
	// Defines whether and how the reference data should be refreshed. Accepted values are `Static`, `RefreshPeriodicallyWithFull` and `RefreshPeriodicallyWithDelta`.
	RefreshType pulumi.StringOutput `pulumi:"refreshType"`
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// The fully qualified domain name of the MS SQL server.
	Server pulumi.StringOutput `pulumi:"server"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The username to connect to the MS SQL database.
	Username pulumi.StringOutput `pulumi:"username"`
}

Manages a Stream Analytics Reference Input from MS SQL. Reference data (also known as a lookup table) is a finite data set that is static or slowly changing in nature, used to perform a lookup or to correlate with your data stream. Learn more [here](https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-use-reference-data#azure-sql-database).

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/mssql"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleServer, err := mssql.NewServer(ctx, "exampleServer", &mssql.ServerArgs{
			ResourceGroupName:          pulumi.Any(azurerm_resource_group.Example.Name),
			Location:                   pulumi.Any(azurerm_resource_group.Example.Location),
			Version:                    pulumi.String("12.0"),
			AdministratorLogin:         pulumi.String("admin"),
			AdministratorLoginPassword: pulumi.String("password"),
		})
		if err != nil {
			return err
		}
		exampleDatabase, err := mssql.NewDatabase(ctx, "exampleDatabase", &mssql.DatabaseArgs{
			ServerId: exampleServer.ID(),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewReferenceInputMssql(ctx, "exampleReferenceInputMssql", &streamanalytics.ReferenceInputMssqlArgs{
			ResourceGroupName:       pulumi.Any(azurerm_stream_analytics_job.Example.Resource_group_name),
			StreamAnalyticsJobName:  pulumi.Any(azurerm_stream_analytics_job.Example.Name),
			Server:                  exampleServer.FullyQualifiedDomainName,
			Database:                exampleDatabase.Name,
			Username:                pulumi.String("exampleuser"),
			Password:                pulumi.String("examplepassword"),
			RefreshType:             pulumi.String("RefreshPeriodicallyWithFull"),
			RefreshIntervalDuration: pulumi.String("00:20:00"),
			FullSnapshotQuery:       pulumi.String(fmt.Sprintf("%v%v%v", "    SELECT *\n", "    INTO [YourOutputAlias]\n", "    FROM [YourInputAlias]\n")),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/referenceInputMssql:ReferenceInputMssql example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/inputs/input1

```

func GetReferenceInputMssql added in v4.25.0 

func GetReferenceInputMssql(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReferenceInputMssqlState, opts ...pulumi.ResourceOption) (*ReferenceInputMssql, error)

GetReferenceInputMssql gets an existing ReferenceInputMssql 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 NewReferenceInputMssql added in v4.25.0 

func NewReferenceInputMssql(ctx *pulumi.Context,
	name string, args *ReferenceInputMssqlArgs, opts ...pulumi.ResourceOption) (*ReferenceInputMssql, error)

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

func (*ReferenceInputMssql) ElementType added in v4.25.0 

func (*ReferenceInputMssql) ElementType() reflect.Type

func (*ReferenceInputMssql) ToReferenceInputMssqlOutput added in v4.25.0 

func (i *ReferenceInputMssql) ToReferenceInputMssqlOutput() ReferenceInputMssqlOutput

func (*ReferenceInputMssql) ToReferenceInputMssqlOutputWithContext added in v4.25.0 

func (i *ReferenceInputMssql) ToReferenceInputMssqlOutputWithContext(ctx context.Context) ReferenceInputMssqlOutput

type ReferenceInputMssqlArgs added in v4.25.0 

type ReferenceInputMssqlArgs struct {
	// The MS SQL database name where the reference data exists.
	Database pulumi.StringInput
	// The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when `refreshType` is `Static`.
	DeltaSnapshotQuery pulumi.StringPtrInput
	// The query used to retrieve the reference data from the MS SQL database.
	FullSnapshotQuery pulumi.StringInput
	// The name of the Reference Input MS SQL data. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The username to connect to the MS SQL database.
	Password pulumi.StringInput
	// The frequency in `hh:mm:ss` with which the reference data should be retrieved from the MS SQL database e.g. `00:20:00` for every 20 minutes. Must be set when `refreshType` is `RefreshPeriodicallyWithFull` or `RefreshPeriodicallyWithDelta`.
	RefreshIntervalDuration pulumi.StringPtrInput
	// Defines whether and how the reference data should be refreshed. Accepted values are `Static`, `RefreshPeriodicallyWithFull` and `RefreshPeriodicallyWithDelta`.
	RefreshType pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// The fully qualified domain name of the MS SQL server.
	Server pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The username to connect to the MS SQL database.
	Username pulumi.StringInput
}

The set of arguments for constructing a ReferenceInputMssql resource.

func (ReferenceInputMssqlArgs) ElementType added in v4.25.0 

func (ReferenceInputMssqlArgs) ElementType() reflect.Type

type ReferenceInputMssqlArray added in v4.25.0 

type ReferenceInputMssqlArray []ReferenceInputMssqlInput

func (ReferenceInputMssqlArray) ElementType added in v4.25.0 

func (ReferenceInputMssqlArray) ElementType() reflect.Type

func (ReferenceInputMssqlArray) ToReferenceInputMssqlArrayOutput added in v4.25.0 

func (i ReferenceInputMssqlArray) ToReferenceInputMssqlArrayOutput() ReferenceInputMssqlArrayOutput

func (ReferenceInputMssqlArray) ToReferenceInputMssqlArrayOutputWithContext added in v4.25.0 

func (i ReferenceInputMssqlArray) ToReferenceInputMssqlArrayOutputWithContext(ctx context.Context) ReferenceInputMssqlArrayOutput

type ReferenceInputMssqlArrayInput added in v4.25.0 

type ReferenceInputMssqlArrayInput interface {
	pulumi.Input

	ToReferenceInputMssqlArrayOutput() ReferenceInputMssqlArrayOutput
	ToReferenceInputMssqlArrayOutputWithContext(context.Context) ReferenceInputMssqlArrayOutput
}

ReferenceInputMssqlArrayInput is an input type that accepts ReferenceInputMssqlArray and ReferenceInputMssqlArrayOutput values. You can construct a concrete instance of `ReferenceInputMssqlArrayInput` via: 

ReferenceInputMssqlArray{ ReferenceInputMssqlArgs{...} }

type ReferenceInputMssqlArrayOutput added in v4.25.0 

type ReferenceInputMssqlArrayOutput struct{ *pulumi.OutputState }

func (ReferenceInputMssqlArrayOutput) ElementType added in v4.25.0 

func (ReferenceInputMssqlArrayOutput) ElementType() reflect.Type

func (ReferenceInputMssqlArrayOutput) Index added in v4.25.0 

func (o ReferenceInputMssqlArrayOutput) Index(i pulumi.IntInput) ReferenceInputMssqlOutput

func (ReferenceInputMssqlArrayOutput) ToReferenceInputMssqlArrayOutput added in v4.25.0 

func (o ReferenceInputMssqlArrayOutput) ToReferenceInputMssqlArrayOutput() ReferenceInputMssqlArrayOutput

func (ReferenceInputMssqlArrayOutput) ToReferenceInputMssqlArrayOutputWithContext added in v4.25.0 

func (o ReferenceInputMssqlArrayOutput) ToReferenceInputMssqlArrayOutputWithContext(ctx context.Context) ReferenceInputMssqlArrayOutput

type ReferenceInputMssqlInput added in v4.25.0 

type ReferenceInputMssqlInput interface {
	pulumi.Input

	ToReferenceInputMssqlOutput() ReferenceInputMssqlOutput
	ToReferenceInputMssqlOutputWithContext(ctx context.Context) ReferenceInputMssqlOutput
}

type ReferenceInputMssqlMap added in v4.25.0 

type ReferenceInputMssqlMap map[string]ReferenceInputMssqlInput

func (ReferenceInputMssqlMap) ElementType added in v4.25.0 

func (ReferenceInputMssqlMap) ElementType() reflect.Type

func (ReferenceInputMssqlMap) ToReferenceInputMssqlMapOutput added in v4.25.0 

func (i ReferenceInputMssqlMap) ToReferenceInputMssqlMapOutput() ReferenceInputMssqlMapOutput

func (ReferenceInputMssqlMap) ToReferenceInputMssqlMapOutputWithContext added in v4.25.0 

func (i ReferenceInputMssqlMap) ToReferenceInputMssqlMapOutputWithContext(ctx context.Context) ReferenceInputMssqlMapOutput

type ReferenceInputMssqlMapInput added in v4.25.0 

type ReferenceInputMssqlMapInput interface {
	pulumi.Input

	ToReferenceInputMssqlMapOutput() ReferenceInputMssqlMapOutput
	ToReferenceInputMssqlMapOutputWithContext(context.Context) ReferenceInputMssqlMapOutput
}

ReferenceInputMssqlMapInput is an input type that accepts ReferenceInputMssqlMap and ReferenceInputMssqlMapOutput values. You can construct a concrete instance of `ReferenceInputMssqlMapInput` via: 

ReferenceInputMssqlMap{ "key": ReferenceInputMssqlArgs{...} }

type ReferenceInputMssqlMapOutput added in v4.25.0 

type ReferenceInputMssqlMapOutput struct{ *pulumi.OutputState }

func (ReferenceInputMssqlMapOutput) ElementType added in v4.25.0 

func (ReferenceInputMssqlMapOutput) ElementType() reflect.Type

func (ReferenceInputMssqlMapOutput) MapIndex added in v4.25.0 

func (o ReferenceInputMssqlMapOutput) MapIndex(k pulumi.StringInput) ReferenceInputMssqlOutput

func (ReferenceInputMssqlMapOutput) ToReferenceInputMssqlMapOutput added in v4.25.0 

func (o ReferenceInputMssqlMapOutput) ToReferenceInputMssqlMapOutput() ReferenceInputMssqlMapOutput

func (ReferenceInputMssqlMapOutput) ToReferenceInputMssqlMapOutputWithContext added in v4.25.0 

func (o ReferenceInputMssqlMapOutput) ToReferenceInputMssqlMapOutputWithContext(ctx context.Context) ReferenceInputMssqlMapOutput

type ReferenceInputMssqlOutput added in v4.25.0 

type ReferenceInputMssqlOutput struct{ *pulumi.OutputState }

func (ReferenceInputMssqlOutput) ElementType added in v4.25.0 

func (ReferenceInputMssqlOutput) ElementType() reflect.Type

func (ReferenceInputMssqlOutput) ToReferenceInputMssqlOutput added in v4.25.0 

func (o ReferenceInputMssqlOutput) ToReferenceInputMssqlOutput() ReferenceInputMssqlOutput

func (ReferenceInputMssqlOutput) ToReferenceInputMssqlOutputWithContext added in v4.25.0 

func (o ReferenceInputMssqlOutput) ToReferenceInputMssqlOutputWithContext(ctx context.Context) ReferenceInputMssqlOutput

type ReferenceInputMssqlState added in v4.25.0 

type ReferenceInputMssqlState struct {
	// The MS SQL database name where the reference data exists.
	Database pulumi.StringPtrInput
	// The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when `refreshType` is `Static`.
	DeltaSnapshotQuery pulumi.StringPtrInput
	// The query used to retrieve the reference data from the MS SQL database.
	FullSnapshotQuery pulumi.StringPtrInput
	// The name of the Reference Input MS SQL data. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The username to connect to the MS SQL database.
	Password pulumi.StringPtrInput
	// The frequency in `hh:mm:ss` with which the reference data should be retrieved from the MS SQL database e.g. `00:20:00` for every 20 minutes. Must be set when `refreshType` is `RefreshPeriodicallyWithFull` or `RefreshPeriodicallyWithDelta`.
	RefreshIntervalDuration pulumi.StringPtrInput
	// Defines whether and how the reference data should be refreshed. Accepted values are `Static`, `RefreshPeriodicallyWithFull` and `RefreshPeriodicallyWithDelta`.
	RefreshType pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// The fully qualified domain name of the MS SQL server.
	Server pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The username to connect to the MS SQL database.
	Username pulumi.StringPtrInput
}

func (ReferenceInputMssqlState) ElementType added in v4.25.0 

func (ReferenceInputMssqlState) ElementType() reflect.Type

type StreamInputBlob 

type StreamInputBlob struct {
	pulumi.CustomResourceState

	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringOutput `pulumi:"dateFormat"`
	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringOutput `pulumi:"pathPattern"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization StreamInputBlobSerializationOutput `pulumi:"serialization"`
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringOutput `pulumi:"storageAccountKey"`
	// The name of the Storage Account.
	StorageAccountName pulumi.StringOutput `pulumi:"storageAccountName"`
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringOutput `pulumi:"storageContainerName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringOutput `pulumi:"timeFormat"`
}

Manages a Stream Analytics Stream Input Blob.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleAccount, err := storage.NewAccount(ctx, "exampleAccount", &storage.AccountArgs{
			ResourceGroupName:      pulumi.Any(azurerm_resource_group.Example.Name),
			Location:               pulumi.Any(azurerm_resource_group.Example.Location),
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		exampleContainer, err := storage.NewContainer(ctx, "exampleContainer", &storage.ContainerArgs{
			StorageAccountName:  exampleAccount.Name,
			ContainerAccessType: pulumi.String("private"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewStreamInputBlob(ctx, "exampleStreamInputBlob", &streamanalytics.StreamInputBlobArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			StorageAccountName:     exampleAccount.Name,
			StorageAccountKey:      exampleAccount.PrimaryAccessKey,
			StorageContainerName:   exampleContainer.Name,
			PathPattern:            pulumi.String("some-random-pattern"),
			DateFormat:             pulumi.String("yyyy/MM/dd"),
			TimeFormat:             pulumi.String("HH"),
			Serialization: &streamanalytics.StreamInputBlobSerializationArgs{
				Type:     pulumi.String("Json"),
				Encoding: pulumi.String("UTF8"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Stream Input Blob's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/streamInputBlob:StreamInputBlob example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/inputs/input1

```

func GetStreamInputBlob 

func GetStreamInputBlob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamInputBlobState, opts ...pulumi.ResourceOption) (*StreamInputBlob, error)

GetStreamInputBlob gets an existing StreamInputBlob 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 NewStreamInputBlob 

func NewStreamInputBlob(ctx *pulumi.Context,
	name string, args *StreamInputBlobArgs, opts ...pulumi.ResourceOption) (*StreamInputBlob, error)

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

func (*StreamInputBlob) ElementType 

func (*StreamInputBlob) ElementType() reflect.Type

func (*StreamInputBlob) ToStreamInputBlobOutput 

func (i *StreamInputBlob) ToStreamInputBlobOutput() StreamInputBlobOutput

func (*StreamInputBlob) ToStreamInputBlobOutputWithContext 

func (i *StreamInputBlob) ToStreamInputBlobOutputWithContext(ctx context.Context) StreamInputBlobOutput

type StreamInputBlobArgs 

type StreamInputBlobArgs struct {
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringInput
	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization StreamInputBlobSerializationInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringInput
}

The set of arguments for constructing a StreamInputBlob resource.

func (StreamInputBlobArgs) ElementType 

func (StreamInputBlobArgs) ElementType() reflect.Type

type StreamInputBlobArray 

type StreamInputBlobArray []StreamInputBlobInput

func (StreamInputBlobArray) ElementType 

func (StreamInputBlobArray) ElementType() reflect.Type

func (StreamInputBlobArray) ToStreamInputBlobArrayOutput 

func (i StreamInputBlobArray) ToStreamInputBlobArrayOutput() StreamInputBlobArrayOutput

func (StreamInputBlobArray) ToStreamInputBlobArrayOutputWithContext 

func (i StreamInputBlobArray) ToStreamInputBlobArrayOutputWithContext(ctx context.Context) StreamInputBlobArrayOutput

type StreamInputBlobArrayInput 

type StreamInputBlobArrayInput interface {
	pulumi.Input

	ToStreamInputBlobArrayOutput() StreamInputBlobArrayOutput
	ToStreamInputBlobArrayOutputWithContext(context.Context) StreamInputBlobArrayOutput
}

StreamInputBlobArrayInput is an input type that accepts StreamInputBlobArray and StreamInputBlobArrayOutput values. You can construct a concrete instance of `StreamInputBlobArrayInput` via: 

StreamInputBlobArray{ StreamInputBlobArgs{...} }

type StreamInputBlobArrayOutput 

type StreamInputBlobArrayOutput struct{ *pulumi.OutputState }

func (StreamInputBlobArrayOutput) ElementType 

func (StreamInputBlobArrayOutput) ElementType() reflect.Type

func (StreamInputBlobArrayOutput) Index 

func (o StreamInputBlobArrayOutput) Index(i pulumi.IntInput) StreamInputBlobOutput

func (StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutput 

func (o StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutput() StreamInputBlobArrayOutput

func (StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutputWithContext 

func (o StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutputWithContext(ctx context.Context) StreamInputBlobArrayOutput

type StreamInputBlobInput 

type StreamInputBlobInput interface {
	pulumi.Input

	ToStreamInputBlobOutput() StreamInputBlobOutput
	ToStreamInputBlobOutputWithContext(ctx context.Context) StreamInputBlobOutput
}

type StreamInputBlobMap 

type StreamInputBlobMap map[string]StreamInputBlobInput

func (StreamInputBlobMap) ElementType 

func (StreamInputBlobMap) ElementType() reflect.Type

func (StreamInputBlobMap) ToStreamInputBlobMapOutput 

func (i StreamInputBlobMap) ToStreamInputBlobMapOutput() StreamInputBlobMapOutput

func (StreamInputBlobMap) ToStreamInputBlobMapOutputWithContext 

func (i StreamInputBlobMap) ToStreamInputBlobMapOutputWithContext(ctx context.Context) StreamInputBlobMapOutput

type StreamInputBlobMapInput 

type StreamInputBlobMapInput interface {
	pulumi.Input

	ToStreamInputBlobMapOutput() StreamInputBlobMapOutput
	ToStreamInputBlobMapOutputWithContext(context.Context) StreamInputBlobMapOutput
}

StreamInputBlobMapInput is an input type that accepts StreamInputBlobMap and StreamInputBlobMapOutput values. You can construct a concrete instance of `StreamInputBlobMapInput` via: 

StreamInputBlobMap{ "key": StreamInputBlobArgs{...} }

type StreamInputBlobMapOutput 

type StreamInputBlobMapOutput struct{ *pulumi.OutputState }

func (StreamInputBlobMapOutput) ElementType 

func (StreamInputBlobMapOutput) ElementType() reflect.Type

func (StreamInputBlobMapOutput) MapIndex 

func (o StreamInputBlobMapOutput) MapIndex(k pulumi.StringInput) StreamInputBlobOutput

func (StreamInputBlobMapOutput) ToStreamInputBlobMapOutput 

func (o StreamInputBlobMapOutput) ToStreamInputBlobMapOutput() StreamInputBlobMapOutput

func (StreamInputBlobMapOutput) ToStreamInputBlobMapOutputWithContext 

func (o StreamInputBlobMapOutput) ToStreamInputBlobMapOutputWithContext(ctx context.Context) StreamInputBlobMapOutput

type StreamInputBlobOutput 

type StreamInputBlobOutput struct{ *pulumi.OutputState }

func (StreamInputBlobOutput) ElementType 

func (StreamInputBlobOutput) ElementType() reflect.Type

func (StreamInputBlobOutput) ToStreamInputBlobOutput 

func (o StreamInputBlobOutput) ToStreamInputBlobOutput() StreamInputBlobOutput

func (StreamInputBlobOutput) ToStreamInputBlobOutputWithContext 

func (o StreamInputBlobOutput) ToStreamInputBlobOutputWithContext(ctx context.Context) StreamInputBlobOutput

type StreamInputBlobSerialization 

type StreamInputBlobSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type StreamInputBlobSerializationArgs 

type StreamInputBlobSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (StreamInputBlobSerializationArgs) ElementType 

func (StreamInputBlobSerializationArgs) ElementType() reflect.Type

func (StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationOutput 

func (i StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationOutput() StreamInputBlobSerializationOutput

func (StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationOutputWithContext 

func (i StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationOutputWithContext(ctx context.Context) StreamInputBlobSerializationOutput

func (StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationPtrOutput 

func (i StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationPtrOutput() StreamInputBlobSerializationPtrOutput

func (StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationPtrOutputWithContext 

func (i StreamInputBlobSerializationArgs) ToStreamInputBlobSerializationPtrOutputWithContext(ctx context.Context) StreamInputBlobSerializationPtrOutput

type StreamInputBlobSerializationInput 

type StreamInputBlobSerializationInput interface {
	pulumi.Input

	ToStreamInputBlobSerializationOutput() StreamInputBlobSerializationOutput
	ToStreamInputBlobSerializationOutputWithContext(context.Context) StreamInputBlobSerializationOutput
}

StreamInputBlobSerializationInput is an input type that accepts StreamInputBlobSerializationArgs and StreamInputBlobSerializationOutput values. You can construct a concrete instance of `StreamInputBlobSerializationInput` via: 

StreamInputBlobSerializationArgs{...}

type StreamInputBlobSerializationOutput 

type StreamInputBlobSerializationOutput struct{ *pulumi.OutputState }

func (StreamInputBlobSerializationOutput) ElementType 

func (StreamInputBlobSerializationOutput) ElementType() reflect.Type

func (StreamInputBlobSerializationOutput) Encoding 

func (o StreamInputBlobSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputBlobSerializationOutput) FieldDelimiter 

func (o StreamInputBlobSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationOutput 

func (o StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationOutput() StreamInputBlobSerializationOutput

func (StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationOutputWithContext 

func (o StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationOutputWithContext(ctx context.Context) StreamInputBlobSerializationOutput

func (StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationPtrOutput 

func (o StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationPtrOutput() StreamInputBlobSerializationPtrOutput

func (StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationPtrOutputWithContext 

func (o StreamInputBlobSerializationOutput) ToStreamInputBlobSerializationPtrOutputWithContext(ctx context.Context) StreamInputBlobSerializationPtrOutput

func (StreamInputBlobSerializationOutput) Type 

func (o StreamInputBlobSerializationOutput) Type() pulumi.StringOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputBlobSerializationPtrInput 

type StreamInputBlobSerializationPtrInput interface {
	pulumi.Input

	ToStreamInputBlobSerializationPtrOutput() StreamInputBlobSerializationPtrOutput
	ToStreamInputBlobSerializationPtrOutputWithContext(context.Context) StreamInputBlobSerializationPtrOutput
}

StreamInputBlobSerializationPtrInput is an input type that accepts StreamInputBlobSerializationArgs, StreamInputBlobSerializationPtr and StreamInputBlobSerializationPtrOutput values. You can construct a concrete instance of `StreamInputBlobSerializationPtrInput` via: 

        StreamInputBlobSerializationArgs{...}

or:

        nil

func StreamInputBlobSerializationPtr 

func StreamInputBlobSerializationPtr(v *StreamInputBlobSerializationArgs) StreamInputBlobSerializationPtrInput

type StreamInputBlobSerializationPtrOutput 

type StreamInputBlobSerializationPtrOutput struct{ *pulumi.OutputState }

func (StreamInputBlobSerializationPtrOutput) Elem 

func (o StreamInputBlobSerializationPtrOutput) Elem() StreamInputBlobSerializationOutput

func (StreamInputBlobSerializationPtrOutput) ElementType 

func (StreamInputBlobSerializationPtrOutput) ElementType() reflect.Type

func (StreamInputBlobSerializationPtrOutput) Encoding 

func (o StreamInputBlobSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputBlobSerializationPtrOutput) FieldDelimiter 

func (o StreamInputBlobSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputBlobSerializationPtrOutput) ToStreamInputBlobSerializationPtrOutput 

func (o StreamInputBlobSerializationPtrOutput) ToStreamInputBlobSerializationPtrOutput() StreamInputBlobSerializationPtrOutput

func (StreamInputBlobSerializationPtrOutput) ToStreamInputBlobSerializationPtrOutputWithContext 

func (o StreamInputBlobSerializationPtrOutput) ToStreamInputBlobSerializationPtrOutputWithContext(ctx context.Context) StreamInputBlobSerializationPtrOutput

func (StreamInputBlobSerializationPtrOutput) Type 

func (o StreamInputBlobSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputBlobState 

type StreamInputBlobState struct {
	// The date format. Wherever `{date}` appears in `pathPattern`, the value of this property is used as the date format instead.
	DateFormat pulumi.StringPtrInput
	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.
	PathPattern pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization StreamInputBlobSerializationPtrInput
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey pulumi.StringPtrInput
	// The name of the Storage Account.
	StorageAccountName pulumi.StringPtrInput
	// The name of the Container within the Storage Account.
	StorageContainerName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
	// The time format. Wherever `{time}` appears in `pathPattern`, the value of this property is used as the time format instead.
	TimeFormat pulumi.StringPtrInput
}

func (StreamInputBlobState) ElementType 

func (StreamInputBlobState) ElementType() reflect.Type

type StreamInputEventHub 

type StreamInputEventHub struct {
	pulumi.CustomResourceState

	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.
	EventhubConsumerGroupName pulumi.StringPtrOutput `pulumi:"eventhubConsumerGroupName"`
	// The name of the Event Hub.
	EventhubName pulumi.StringOutput `pulumi:"eventhubName"`
	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The property the input Event Hub has been partitioned by.
	PartitionKey pulumi.StringPtrOutput `pulumi:"partitionKey"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization StreamInputEventHubSerializationOutput `pulumi:"serialization"`
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringOutput `pulumi:"servicebusNamespace"`
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringOutput `pulumi:"sharedAccessPolicyKey"`
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringOutput `pulumi:"sharedAccessPolicyName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a Stream Analytics Stream Input EventHub.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/eventhub"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleEventHubNamespace, err := eventhub.NewEventHubNamespace(ctx, "exampleEventHubNamespace", &eventhub.EventHubNamespaceArgs{
			Location:          pulumi.String(exampleResourceGroup.Location),
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			Sku:               pulumi.String("Standard"),
			Capacity:          pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		exampleEventHub, err := eventhub.NewEventHub(ctx, "exampleEventHub", &eventhub.EventHubArgs{
			NamespaceName:     exampleEventHubNamespace.Name,
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			PartitionCount:    pulumi.Int(2),
			MessageRetention:  pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		exampleConsumerGroup, err := eventhub.NewConsumerGroup(ctx, "exampleConsumerGroup", &eventhub.ConsumerGroupArgs{
			NamespaceName:     exampleEventHubNamespace.Name,
			EventhubName:      exampleEventHub.Name,
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewStreamInputEventHub(ctx, "exampleStreamInputEventHub", &streamanalytics.StreamInputEventHubArgs{
			StreamAnalyticsJobName:    pulumi.String(exampleJob.Name),
			ResourceGroupName:         pulumi.String(exampleJob.ResourceGroupName),
			EventhubConsumerGroupName: exampleConsumerGroup.Name,
			EventhubName:              exampleEventHub.Name,
			ServicebusNamespace:       exampleEventHubNamespace.Name,
			SharedAccessPolicyKey:     exampleEventHubNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName:    pulumi.String("RootManageSharedAccessKey"),
			Serialization: &streamanalytics.StreamInputEventHubSerializationArgs{
				Type:     pulumi.String("Json"),
				Encoding: pulumi.String("UTF8"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Stream Input EventHub's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/streamInputEventHub:StreamInputEventHub example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/inputs/input1

```

func GetStreamInputEventHub 

func GetStreamInputEventHub(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamInputEventHubState, opts ...pulumi.ResourceOption) (*StreamInputEventHub, error)

GetStreamInputEventHub gets an existing StreamInputEventHub 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 NewStreamInputEventHub 

func NewStreamInputEventHub(ctx *pulumi.Context,
	name string, args *StreamInputEventHubArgs, opts ...pulumi.ResourceOption) (*StreamInputEventHub, error)

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

func (*StreamInputEventHub) ElementType 

func (*StreamInputEventHub) ElementType() reflect.Type

func (*StreamInputEventHub) ToStreamInputEventHubOutput 

func (i *StreamInputEventHub) ToStreamInputEventHubOutput() StreamInputEventHubOutput

func (*StreamInputEventHub) ToStreamInputEventHubOutputWithContext 

func (i *StreamInputEventHub) ToStreamInputEventHubOutputWithContext(ctx context.Context) StreamInputEventHubOutput

type StreamInputEventHubArgs 

type StreamInputEventHubArgs struct {
	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.
	EventhubConsumerGroupName pulumi.StringPtrInput
	// The name of the Event Hub.
	EventhubName pulumi.StringInput
	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The property the input Event Hub has been partitioned by.
	PartitionKey pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization StreamInputEventHubSerializationInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a StreamInputEventHub resource.

func (StreamInputEventHubArgs) ElementType 

func (StreamInputEventHubArgs) ElementType() reflect.Type

type StreamInputEventHubArray 

type StreamInputEventHubArray []StreamInputEventHubInput

func (StreamInputEventHubArray) ElementType 

func (StreamInputEventHubArray) ElementType() reflect.Type

func (StreamInputEventHubArray) ToStreamInputEventHubArrayOutput 

func (i StreamInputEventHubArray) ToStreamInputEventHubArrayOutput() StreamInputEventHubArrayOutput

func (StreamInputEventHubArray) ToStreamInputEventHubArrayOutputWithContext 

func (i StreamInputEventHubArray) ToStreamInputEventHubArrayOutputWithContext(ctx context.Context) StreamInputEventHubArrayOutput

type StreamInputEventHubArrayInput 

type StreamInputEventHubArrayInput interface {
	pulumi.Input

	ToStreamInputEventHubArrayOutput() StreamInputEventHubArrayOutput
	ToStreamInputEventHubArrayOutputWithContext(context.Context) StreamInputEventHubArrayOutput
}

StreamInputEventHubArrayInput is an input type that accepts StreamInputEventHubArray and StreamInputEventHubArrayOutput values. You can construct a concrete instance of `StreamInputEventHubArrayInput` via: 

StreamInputEventHubArray{ StreamInputEventHubArgs{...} }

type StreamInputEventHubArrayOutput 

type StreamInputEventHubArrayOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubArrayOutput) ElementType 

func (StreamInputEventHubArrayOutput) ElementType() reflect.Type

func (StreamInputEventHubArrayOutput) Index 

func (o StreamInputEventHubArrayOutput) Index(i pulumi.IntInput) StreamInputEventHubOutput

func (StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutput 

func (o StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutput() StreamInputEventHubArrayOutput

func (StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutputWithContext 

func (o StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutputWithContext(ctx context.Context) StreamInputEventHubArrayOutput

type StreamInputEventHubInput 

type StreamInputEventHubInput interface {
	pulumi.Input

	ToStreamInputEventHubOutput() StreamInputEventHubOutput
	ToStreamInputEventHubOutputWithContext(ctx context.Context) StreamInputEventHubOutput
}

type StreamInputEventHubMap 

type StreamInputEventHubMap map[string]StreamInputEventHubInput

func (StreamInputEventHubMap) ElementType 

func (StreamInputEventHubMap) ElementType() reflect.Type

func (StreamInputEventHubMap) ToStreamInputEventHubMapOutput 

func (i StreamInputEventHubMap) ToStreamInputEventHubMapOutput() StreamInputEventHubMapOutput

func (StreamInputEventHubMap) ToStreamInputEventHubMapOutputWithContext 

func (i StreamInputEventHubMap) ToStreamInputEventHubMapOutputWithContext(ctx context.Context) StreamInputEventHubMapOutput

type StreamInputEventHubMapInput 

type StreamInputEventHubMapInput interface {
	pulumi.Input

	ToStreamInputEventHubMapOutput() StreamInputEventHubMapOutput
	ToStreamInputEventHubMapOutputWithContext(context.Context) StreamInputEventHubMapOutput
}

StreamInputEventHubMapInput is an input type that accepts StreamInputEventHubMap and StreamInputEventHubMapOutput values. You can construct a concrete instance of `StreamInputEventHubMapInput` via: 

StreamInputEventHubMap{ "key": StreamInputEventHubArgs{...} }

type StreamInputEventHubMapOutput 

type StreamInputEventHubMapOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubMapOutput) ElementType 

func (StreamInputEventHubMapOutput) ElementType() reflect.Type

func (StreamInputEventHubMapOutput) MapIndex 

func (o StreamInputEventHubMapOutput) MapIndex(k pulumi.StringInput) StreamInputEventHubOutput

func (StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutput 

func (o StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutput() StreamInputEventHubMapOutput

func (StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutputWithContext 

func (o StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutputWithContext(ctx context.Context) StreamInputEventHubMapOutput

type StreamInputEventHubOutput 

type StreamInputEventHubOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubOutput) ElementType 

func (StreamInputEventHubOutput) ElementType() reflect.Type

func (StreamInputEventHubOutput) ToStreamInputEventHubOutput 

func (o StreamInputEventHubOutput) ToStreamInputEventHubOutput() StreamInputEventHubOutput

func (StreamInputEventHubOutput) ToStreamInputEventHubOutputWithContext 

func (o StreamInputEventHubOutput) ToStreamInputEventHubOutputWithContext(ctx context.Context) StreamInputEventHubOutput

type StreamInputEventHubSerialization 

type StreamInputEventHubSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type StreamInputEventHubSerializationArgs 

type StreamInputEventHubSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (StreamInputEventHubSerializationArgs) ElementType 

func (StreamInputEventHubSerializationArgs) ElementType() reflect.Type

func (StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationOutput 

func (i StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationOutput() StreamInputEventHubSerializationOutput

func (StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationOutputWithContext 

func (i StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationOutputWithContext(ctx context.Context) StreamInputEventHubSerializationOutput

func (StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationPtrOutput 

func (i StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationPtrOutput() StreamInputEventHubSerializationPtrOutput

func (StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationPtrOutputWithContext 

func (i StreamInputEventHubSerializationArgs) ToStreamInputEventHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputEventHubSerializationPtrOutput

type StreamInputEventHubSerializationInput 

type StreamInputEventHubSerializationInput interface {
	pulumi.Input

	ToStreamInputEventHubSerializationOutput() StreamInputEventHubSerializationOutput
	ToStreamInputEventHubSerializationOutputWithContext(context.Context) StreamInputEventHubSerializationOutput
}

StreamInputEventHubSerializationInput is an input type that accepts StreamInputEventHubSerializationArgs and StreamInputEventHubSerializationOutput values. You can construct a concrete instance of `StreamInputEventHubSerializationInput` via: 

StreamInputEventHubSerializationArgs{...}

type StreamInputEventHubSerializationOutput 

type StreamInputEventHubSerializationOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubSerializationOutput) ElementType 

func (StreamInputEventHubSerializationOutput) ElementType() reflect.Type

func (StreamInputEventHubSerializationOutput) Encoding 

func (o StreamInputEventHubSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputEventHubSerializationOutput) FieldDelimiter 

func (o StreamInputEventHubSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationOutput 

func (o StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationOutput() StreamInputEventHubSerializationOutput

func (StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationOutputWithContext 

func (o StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationOutputWithContext(ctx context.Context) StreamInputEventHubSerializationOutput

func (StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationPtrOutput 

func (o StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationPtrOutput() StreamInputEventHubSerializationPtrOutput

func (StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationPtrOutputWithContext 

func (o StreamInputEventHubSerializationOutput) ToStreamInputEventHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputEventHubSerializationPtrOutput

func (StreamInputEventHubSerializationOutput) Type 

func (o StreamInputEventHubSerializationOutput) Type() pulumi.StringOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputEventHubSerializationPtrInput 

type StreamInputEventHubSerializationPtrInput interface {
	pulumi.Input

	ToStreamInputEventHubSerializationPtrOutput() StreamInputEventHubSerializationPtrOutput
	ToStreamInputEventHubSerializationPtrOutputWithContext(context.Context) StreamInputEventHubSerializationPtrOutput
}

StreamInputEventHubSerializationPtrInput is an input type that accepts StreamInputEventHubSerializationArgs, StreamInputEventHubSerializationPtr and StreamInputEventHubSerializationPtrOutput values. You can construct a concrete instance of `StreamInputEventHubSerializationPtrInput` via: 

        StreamInputEventHubSerializationArgs{...}

or:

        nil

func StreamInputEventHubSerializationPtr 

func StreamInputEventHubSerializationPtr(v *StreamInputEventHubSerializationArgs) StreamInputEventHubSerializationPtrInput

type StreamInputEventHubSerializationPtrOutput 

type StreamInputEventHubSerializationPtrOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubSerializationPtrOutput) Elem 

func (o StreamInputEventHubSerializationPtrOutput) Elem() StreamInputEventHubSerializationOutput

func (StreamInputEventHubSerializationPtrOutput) ElementType 

func (StreamInputEventHubSerializationPtrOutput) ElementType() reflect.Type

func (StreamInputEventHubSerializationPtrOutput) Encoding 

func (o StreamInputEventHubSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputEventHubSerializationPtrOutput) FieldDelimiter 

func (o StreamInputEventHubSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputEventHubSerializationPtrOutput) ToStreamInputEventHubSerializationPtrOutput 

func (o StreamInputEventHubSerializationPtrOutput) ToStreamInputEventHubSerializationPtrOutput() StreamInputEventHubSerializationPtrOutput

func (StreamInputEventHubSerializationPtrOutput) ToStreamInputEventHubSerializationPtrOutputWithContext 

func (o StreamInputEventHubSerializationPtrOutput) ToStreamInputEventHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputEventHubSerializationPtrOutput

func (StreamInputEventHubSerializationPtrOutput) Type 

func (o StreamInputEventHubSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputEventHubState 

type StreamInputEventHubState struct {
	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.
	EventhubConsumerGroupName pulumi.StringPtrInput
	// The name of the Event Hub.
	EventhubName pulumi.StringPtrInput
	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The property the input Event Hub has been partitioned by.
	PartitionKey pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization StreamInputEventHubSerializationPtrInput
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace pulumi.StringPtrInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringPtrInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (StreamInputEventHubState) ElementType 

func (StreamInputEventHubState) ElementType() reflect.Type

type StreamInputIotHub 

type StreamInputIotHub struct {
	pulumi.CustomResourceState

	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint pulumi.StringOutput `pulumi:"endpoint"`
	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.
	EventhubConsumerGroupName pulumi.StringOutput `pulumi:"eventhubConsumerGroupName"`
	// The name or the URI of the IoT Hub.
	IothubNamespace pulumi.StringOutput `pulumi:"iothubNamespace"`
	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name pulumi.StringOutput `pulumi:"name"`
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringOutput `pulumi:"resourceGroupName"`
	// A `serialization` block as defined below.
	Serialization StreamInputIotHubSerializationOutput `pulumi:"serialization"`
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringOutput `pulumi:"sharedAccessPolicyKey"`
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringOutput `pulumi:"sharedAccessPolicyName"`
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringOutput `pulumi:"streamAnalyticsJobName"`
}

Manages a Stream Analytics Stream Input IoTHub.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/iot"
"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleIoTHub, err := iot.NewIoTHub(ctx, "exampleIoTHub", &iot.IoTHubArgs{
			ResourceGroupName: pulumi.Any(azurerm_resource_group.Example.Name),
			Location:          pulumi.Any(azurerm_resource_group.Example.Location),
			Sku: &iot.IoTHubSkuArgs{
				Name:     pulumi.String("S1"),
				Capacity: pulumi.Int(1),
			},
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewStreamInputIotHub(ctx, "exampleStreamInputIotHub", &streamanalytics.StreamInputIotHubArgs{
			StreamAnalyticsJobName:    pulumi.String(exampleJob.Name),
			ResourceGroupName:         pulumi.String(exampleJob.ResourceGroupName),
			Endpoint:                  pulumi.String("messages/events"),
			EventhubConsumerGroupName: pulumi.String(fmt.Sprintf("%v%v", "$", "Default")),
			IothubNamespace:           exampleIoTHub.Name,
			SharedAccessPolicyKey: exampleIoTHub.SharedAccessPolicies.ApplyT(func(sharedAccessPolicies []iot.IoTHubSharedAccessPolicy) (string, error) {
				return sharedAccessPolicies[0].PrimaryKey, nil
			}).(pulumi.StringOutput),
			SharedAccessPolicyName: pulumi.String("iothubowner"),
			Serialization: &streamanalytics.StreamInputIotHubSerializationArgs{
				Type:     pulumi.String("Json"),
				Encoding: pulumi.String("UTF8"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Stream Analytics Stream Input IoTHub's can be imported using the `resource id`, e.g.

```sh 

$ pulumi import azure:streamanalytics/streamInputIotHub:StreamInputIotHub example /subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/group1/providers/Microsoft.StreamAnalytics/streamingjobs/job1/inputs/input1

```

func GetStreamInputIotHub 

func GetStreamInputIotHub(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamInputIotHubState, opts ...pulumi.ResourceOption) (*StreamInputIotHub, error)

GetStreamInputIotHub gets an existing StreamInputIotHub 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 NewStreamInputIotHub 

func NewStreamInputIotHub(ctx *pulumi.Context,
	name string, args *StreamInputIotHubArgs, opts ...pulumi.ResourceOption) (*StreamInputIotHub, error)

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

func (*StreamInputIotHub) ElementType 

func (*StreamInputIotHub) ElementType() reflect.Type

func (*StreamInputIotHub) ToStreamInputIotHubOutput 

func (i *StreamInputIotHub) ToStreamInputIotHubOutput() StreamInputIotHubOutput

func (*StreamInputIotHub) ToStreamInputIotHubOutputWithContext 

func (i *StreamInputIotHub) ToStreamInputIotHubOutputWithContext(ctx context.Context) StreamInputIotHubOutput

type StreamInputIotHubArgs 

type StreamInputIotHubArgs struct {
	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint pulumi.StringInput
	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.
	EventhubConsumerGroupName pulumi.StringInput
	// The name or the URI of the IoT Hub.
	IothubNamespace pulumi.StringInput
	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringInput
	// A `serialization` block as defined below.
	Serialization StreamInputIotHubSerializationInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringInput
}

The set of arguments for constructing a StreamInputIotHub resource.

func (StreamInputIotHubArgs) ElementType 

func (StreamInputIotHubArgs) ElementType() reflect.Type

type StreamInputIotHubArray 

type StreamInputIotHubArray []StreamInputIotHubInput

func (StreamInputIotHubArray) ElementType 

func (StreamInputIotHubArray) ElementType() reflect.Type

func (StreamInputIotHubArray) ToStreamInputIotHubArrayOutput 

func (i StreamInputIotHubArray) ToStreamInputIotHubArrayOutput() StreamInputIotHubArrayOutput

func (StreamInputIotHubArray) ToStreamInputIotHubArrayOutputWithContext 

func (i StreamInputIotHubArray) ToStreamInputIotHubArrayOutputWithContext(ctx context.Context) StreamInputIotHubArrayOutput

type StreamInputIotHubArrayInput 

type StreamInputIotHubArrayInput interface {
	pulumi.Input

	ToStreamInputIotHubArrayOutput() StreamInputIotHubArrayOutput
	ToStreamInputIotHubArrayOutputWithContext(context.Context) StreamInputIotHubArrayOutput
}

StreamInputIotHubArrayInput is an input type that accepts StreamInputIotHubArray and StreamInputIotHubArrayOutput values. You can construct a concrete instance of `StreamInputIotHubArrayInput` via: 

StreamInputIotHubArray{ StreamInputIotHubArgs{...} }

type StreamInputIotHubArrayOutput 

type StreamInputIotHubArrayOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubArrayOutput) ElementType 

func (StreamInputIotHubArrayOutput) ElementType() reflect.Type

func (StreamInputIotHubArrayOutput) Index 

func (o StreamInputIotHubArrayOutput) Index(i pulumi.IntInput) StreamInputIotHubOutput

func (StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutput 

func (o StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutput() StreamInputIotHubArrayOutput

func (StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutputWithContext 

func (o StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutputWithContext(ctx context.Context) StreamInputIotHubArrayOutput

type StreamInputIotHubInput 

type StreamInputIotHubInput interface {
	pulumi.Input

	ToStreamInputIotHubOutput() StreamInputIotHubOutput
	ToStreamInputIotHubOutputWithContext(ctx context.Context) StreamInputIotHubOutput
}

type StreamInputIotHubMap 

type StreamInputIotHubMap map[string]StreamInputIotHubInput

func (StreamInputIotHubMap) ElementType 

func (StreamInputIotHubMap) ElementType() reflect.Type

func (StreamInputIotHubMap) ToStreamInputIotHubMapOutput 

func (i StreamInputIotHubMap) ToStreamInputIotHubMapOutput() StreamInputIotHubMapOutput

func (StreamInputIotHubMap) ToStreamInputIotHubMapOutputWithContext 

func (i StreamInputIotHubMap) ToStreamInputIotHubMapOutputWithContext(ctx context.Context) StreamInputIotHubMapOutput

type StreamInputIotHubMapInput 

type StreamInputIotHubMapInput interface {
	pulumi.Input

	ToStreamInputIotHubMapOutput() StreamInputIotHubMapOutput
	ToStreamInputIotHubMapOutputWithContext(context.Context) StreamInputIotHubMapOutput
}

StreamInputIotHubMapInput is an input type that accepts StreamInputIotHubMap and StreamInputIotHubMapOutput values. You can construct a concrete instance of `StreamInputIotHubMapInput` via: 

StreamInputIotHubMap{ "key": StreamInputIotHubArgs{...} }

type StreamInputIotHubMapOutput 

type StreamInputIotHubMapOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubMapOutput) ElementType 

func (StreamInputIotHubMapOutput) ElementType() reflect.Type

func (StreamInputIotHubMapOutput) MapIndex 

func (o StreamInputIotHubMapOutput) MapIndex(k pulumi.StringInput) StreamInputIotHubOutput

func (StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutput 

func (o StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutput() StreamInputIotHubMapOutput

func (StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutputWithContext 

func (o StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutputWithContext(ctx context.Context) StreamInputIotHubMapOutput

type StreamInputIotHubOutput 

type StreamInputIotHubOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubOutput) ElementType 

func (StreamInputIotHubOutput) ElementType() reflect.Type

func (StreamInputIotHubOutput) ToStreamInputIotHubOutput 

func (o StreamInputIotHubOutput) ToStreamInputIotHubOutput() StreamInputIotHubOutput

func (StreamInputIotHubOutput) ToStreamInputIotHubOutputWithContext 

func (o StreamInputIotHubOutput) ToStreamInputIotHubOutputWithContext(ctx context.Context) StreamInputIotHubOutput

type StreamInputIotHubSerialization 

type StreamInputIotHubSerialization struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding *string `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter *string `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type string `pulumi:"type"`
}

type StreamInputIotHubSerializationArgs 

type StreamInputIotHubSerializationArgs struct {
	// The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.
	Encoding pulumi.StringPtrInput `pulumi:"encoding"`
	// The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), `   ` (tab), `|` (pipe) and `;`.
	FieldDelimiter pulumi.StringPtrInput `pulumi:"fieldDelimiter"`
	// The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.
	Type pulumi.StringInput `pulumi:"type"`
}

func (StreamInputIotHubSerializationArgs) ElementType 

func (StreamInputIotHubSerializationArgs) ElementType() reflect.Type

func (StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationOutput 

func (i StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationOutput() StreamInputIotHubSerializationOutput

func (StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationOutputWithContext 

func (i StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationOutputWithContext(ctx context.Context) StreamInputIotHubSerializationOutput

func (StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationPtrOutput 

func (i StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationPtrOutput() StreamInputIotHubSerializationPtrOutput

func (StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationPtrOutputWithContext 

func (i StreamInputIotHubSerializationArgs) ToStreamInputIotHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputIotHubSerializationPtrOutput

type StreamInputIotHubSerializationInput 

type StreamInputIotHubSerializationInput interface {
	pulumi.Input

	ToStreamInputIotHubSerializationOutput() StreamInputIotHubSerializationOutput
	ToStreamInputIotHubSerializationOutputWithContext(context.Context) StreamInputIotHubSerializationOutput
}

StreamInputIotHubSerializationInput is an input type that accepts StreamInputIotHubSerializationArgs and StreamInputIotHubSerializationOutput values. You can construct a concrete instance of `StreamInputIotHubSerializationInput` via: 

StreamInputIotHubSerializationArgs{...}

type StreamInputIotHubSerializationOutput 

type StreamInputIotHubSerializationOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubSerializationOutput) ElementType 

func (StreamInputIotHubSerializationOutput) ElementType() reflect.Type

func (StreamInputIotHubSerializationOutput) Encoding 

func (o StreamInputIotHubSerializationOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputIotHubSerializationOutput) FieldDelimiter 

func (o StreamInputIotHubSerializationOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationOutput 

func (o StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationOutput() StreamInputIotHubSerializationOutput

func (StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationOutputWithContext 

func (o StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationOutputWithContext(ctx context.Context) StreamInputIotHubSerializationOutput

func (StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationPtrOutput 

func (o StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationPtrOutput() StreamInputIotHubSerializationPtrOutput

func (StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationPtrOutputWithContext 

func (o StreamInputIotHubSerializationOutput) ToStreamInputIotHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputIotHubSerializationPtrOutput

func (StreamInputIotHubSerializationOutput) Type 

func (o StreamInputIotHubSerializationOutput) Type() pulumi.StringOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputIotHubSerializationPtrInput 

type StreamInputIotHubSerializationPtrInput interface {
	pulumi.Input

	ToStreamInputIotHubSerializationPtrOutput() StreamInputIotHubSerializationPtrOutput
	ToStreamInputIotHubSerializationPtrOutputWithContext(context.Context) StreamInputIotHubSerializationPtrOutput
}

StreamInputIotHubSerializationPtrInput is an input type that accepts StreamInputIotHubSerializationArgs, StreamInputIotHubSerializationPtr and StreamInputIotHubSerializationPtrOutput values. You can construct a concrete instance of `StreamInputIotHubSerializationPtrInput` via: 

        StreamInputIotHubSerializationArgs{...}

or:

        nil

func StreamInputIotHubSerializationPtr 

func StreamInputIotHubSerializationPtr(v *StreamInputIotHubSerializationArgs) StreamInputIotHubSerializationPtrInput

type StreamInputIotHubSerializationPtrOutput 

type StreamInputIotHubSerializationPtrOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubSerializationPtrOutput) Elem 

func (o StreamInputIotHubSerializationPtrOutput) Elem() StreamInputIotHubSerializationOutput

func (StreamInputIotHubSerializationPtrOutput) ElementType 

func (StreamInputIotHubSerializationPtrOutput) ElementType() reflect.Type

func (StreamInputIotHubSerializationPtrOutput) Encoding 

func (o StreamInputIotHubSerializationPtrOutput) Encoding() pulumi.StringPtrOutput

The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to `UTF8`.

func (StreamInputIotHubSerializationPtrOutput) FieldDelimiter 

func (o StreamInputIotHubSerializationPtrOutput) FieldDelimiter() pulumi.StringPtrOutput

The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` ` (space), `,` (comma), ` ` (tab), `|` (pipe) and `;`.

func (StreamInputIotHubSerializationPtrOutput) ToStreamInputIotHubSerializationPtrOutput 

func (o StreamInputIotHubSerializationPtrOutput) ToStreamInputIotHubSerializationPtrOutput() StreamInputIotHubSerializationPtrOutput

func (StreamInputIotHubSerializationPtrOutput) ToStreamInputIotHubSerializationPtrOutputWithContext 

func (o StreamInputIotHubSerializationPtrOutput) ToStreamInputIotHubSerializationPtrOutputWithContext(ctx context.Context) StreamInputIotHubSerializationPtrOutput

func (StreamInputIotHubSerializationPtrOutput) Type 

func (o StreamInputIotHubSerializationPtrOutput) Type() pulumi.StringPtrOutput

The serialization format used for incoming data streams. Possible values are `Avro`, `Csv` and `Json`.

type StreamInputIotHubState 

type StreamInputIotHubState struct {
	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint pulumi.StringPtrInput
	// The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.
	EventhubConsumerGroupName pulumi.StringPtrInput
	// The name or the URI of the IoT Hub.
	IothubNamespace pulumi.StringPtrInput
	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name pulumi.StringPtrInput
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName pulumi.StringPtrInput
	// A `serialization` block as defined below.
	Serialization StreamInputIotHubSerializationPtrInput
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey pulumi.StringPtrInput
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName pulumi.StringPtrInput
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName pulumi.StringPtrInput
}

func (StreamInputIotHubState) ElementType 

func (StreamInputIotHubState) 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.