streamanalytics

package
v3.52.0 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2021 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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*FunctionJavaScriptUDF) ElementType() reflect.Type

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutput added in v3.31.1 

func (i *FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutput() FunctionJavaScriptUDFOutput

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFOutputWithContext added in v3.31.1 

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

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFPtrOutput added in v3.47.1 

func (i *FunctionJavaScriptUDF) ToFunctionJavaScriptUDFPtrOutput() FunctionJavaScriptUDFPtrOutput

func (*FunctionJavaScriptUDF) ToFunctionJavaScriptUDFPtrOutputWithContext added in v3.47.1 

func (i *FunctionJavaScriptUDF) ToFunctionJavaScriptUDFPtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFPtrOutput

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 added in v3.47.1 

type FunctionJavaScriptUDFArray []FunctionJavaScriptUDFInput

func (FunctionJavaScriptUDFArray) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFArray) ElementType() reflect.Type

func (FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutput added in v3.47.1 

func (i FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutput() FunctionJavaScriptUDFArrayOutput

func (FunctionJavaScriptUDFArray) ToFunctionJavaScriptUDFArrayOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFArrayInput added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFArrayOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFArrayOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFArrayOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFArrayOutput) Index added in v3.47.1 

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

func (FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutput added in v3.47.1 

func (o FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutput() FunctionJavaScriptUDFArrayOutput

func (FunctionJavaScriptUDFArrayOutput) ToFunctionJavaScriptUDFArrayOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFInput 

type FunctionJavaScriptUDFInput interface {
	pulumi.Input

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

type FunctionJavaScriptUDFInputType added in v3.47.1 

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 added in v3.47.1 

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 added in v3.47.1 

func (FunctionJavaScriptUDFInputTypeArgs) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutput added in v3.47.1 

func (i FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutput() FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeArgs) ToFunctionJavaScriptUDFInputTypeOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFInputTypeArray added in v3.47.1 

type FunctionJavaScriptUDFInputTypeArray []FunctionJavaScriptUDFInputTypeInput

func (FunctionJavaScriptUDFInputTypeArray) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFInputTypeArray) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutput added in v3.47.1 

func (i FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutput() FunctionJavaScriptUDFInputTypeArrayOutput

func (FunctionJavaScriptUDFInputTypeArray) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFInputTypeArrayInput added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFInputTypeArrayOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFInputTypeArrayOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFInputTypeArrayOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeArrayOutput) Index added in v3.47.1 

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

func (FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutput added in v3.47.1 

func (o FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutput() FunctionJavaScriptUDFInputTypeArrayOutput

func (FunctionJavaScriptUDFInputTypeArrayOutput) ToFunctionJavaScriptUDFInputTypeArrayOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFInputTypeInput added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFInputTypeOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFInputTypeOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFInputTypeOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutput added in v3.47.1 

func (o FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutput() FunctionJavaScriptUDFInputTypeOutput

func (FunctionJavaScriptUDFInputTypeOutput) ToFunctionJavaScriptUDFInputTypeOutputWithContext added in v3.47.1 

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

func (FunctionJavaScriptUDFInputTypeOutput) Type added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFMap map[string]FunctionJavaScriptUDFInput

func (FunctionJavaScriptUDFMap) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFMap) ElementType() reflect.Type

func (FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutput added in v3.47.1 

func (i FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutput() FunctionJavaScriptUDFMapOutput

func (FunctionJavaScriptUDFMap) ToFunctionJavaScriptUDFMapOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFMapInput added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFMapOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFMapOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFMapOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFMapOutput) MapIndex added in v3.47.1 

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

func (FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutput added in v3.47.1 

func (o FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutput() FunctionJavaScriptUDFMapOutput

func (FunctionJavaScriptUDFMapOutput) ToFunctionJavaScriptUDFMapOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFOutput 

type FunctionJavaScriptUDFOutput struct {
	*pulumi.OutputState
}

func (FunctionJavaScriptUDFOutput) ElementType added in v3.31.1 

func (FunctionJavaScriptUDFOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutput added in v3.31.1 

func (o FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutput() FunctionJavaScriptUDFOutput

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFOutputWithContext added in v3.31.1 

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

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFPtrOutput added in v3.47.1 

func (o FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFPtrOutput() FunctionJavaScriptUDFPtrOutput

func (FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFPtrOutputWithContext added in v3.47.1 

func (o FunctionJavaScriptUDFOutput) ToFunctionJavaScriptUDFPtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFPtrOutput

type FunctionJavaScriptUDFOutputType added in v3.47.1 

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 added in v3.47.1 

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 added in v3.47.1 

func (FunctionJavaScriptUDFOutputTypeArgs) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutput added in v3.47.1 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutput() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypeOutputWithContext added in v3.47.1 

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

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutput added in v3.47.1 

func (i FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypeArgs) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext added in v3.47.1 

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

type FunctionJavaScriptUDFOutputTypeInput added in v3.47.1 

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 added in v3.47.1 

type FunctionJavaScriptUDFOutputTypeOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFOutputTypeOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFOutputTypeOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutput added in v3.47.1 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutput() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypeOutputWithContext added in v3.47.1 

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

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput added in v3.47.1 

func (o FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypeOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext added in v3.47.1 

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

func (FunctionJavaScriptUDFOutputTypeOutput) Type added in v3.47.1 

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 added in v3.47.1 

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 added in v3.47.1 

func FunctionJavaScriptUDFOutputTypePtr(v *FunctionJavaScriptUDFOutputTypeArgs) FunctionJavaScriptUDFOutputTypePtrInput

type FunctionJavaScriptUDFOutputTypePtrOutput added in v3.47.1 

type FunctionJavaScriptUDFOutputTypePtrOutput struct{ *pulumi.OutputState }

func (FunctionJavaScriptUDFOutputTypePtrOutput) Elem added in v3.47.1 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) Elem() FunctionJavaScriptUDFOutputTypeOutput

func (FunctionJavaScriptUDFOutputTypePtrOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFOutputTypePtrOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput added in v3.47.1 

func (o FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutput() FunctionJavaScriptUDFOutputTypePtrOutput

func (FunctionJavaScriptUDFOutputTypePtrOutput) ToFunctionJavaScriptUDFOutputTypePtrOutputWithContext added in v3.47.1 

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

func (FunctionJavaScriptUDFOutputTypePtrOutput) Type added in v3.47.1 

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 FunctionJavaScriptUDFPtrInput added in v3.47.1 

type FunctionJavaScriptUDFPtrInput interface {
	pulumi.Input

	ToFunctionJavaScriptUDFPtrOutput() FunctionJavaScriptUDFPtrOutput
	ToFunctionJavaScriptUDFPtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFPtrOutput
}

type FunctionJavaScriptUDFPtrOutput added in v3.47.1 

type FunctionJavaScriptUDFPtrOutput struct {
	*pulumi.OutputState
}

func (FunctionJavaScriptUDFPtrOutput) ElementType added in v3.47.1 

func (FunctionJavaScriptUDFPtrOutput) ElementType() reflect.Type

func (FunctionJavaScriptUDFPtrOutput) ToFunctionJavaScriptUDFPtrOutput added in v3.47.1 

func (o FunctionJavaScriptUDFPtrOutput) ToFunctionJavaScriptUDFPtrOutput() FunctionJavaScriptUDFPtrOutput

func (FunctionJavaScriptUDFPtrOutput) ToFunctionJavaScriptUDFPtrOutputWithContext added in v3.47.1 

func (o FunctionJavaScriptUDFPtrOutput) ToFunctionJavaScriptUDFPtrOutputWithContext(ctx context.Context) FunctionJavaScriptUDFPtrOutput

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 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` and `1.1`.
	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"`
	// 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"`
	// 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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.1"),
			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 added in v3.31.1 

func (*Job) ElementType() reflect.Type

func (*Job) ToJobOutput added in v3.31.1 

func (i *Job) ToJobOutput() JobOutput

func (*Job) ToJobOutputWithContext added in v3.31.1 

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

func (*Job) ToJobPtrOutput added in v3.47.1 

func (i *Job) ToJobPtrOutput() JobPtrOutput

func (*Job) ToJobPtrOutputWithContext added in v3.47.1 

func (i *Job) ToJobPtrOutputWithContext(ctx context.Context) JobPtrOutput

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` and `1.1`.
	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
	// 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
	// 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 added in v3.47.1 

type JobArray []JobInput

func (JobArray) ElementType added in v3.47.1 

func (JobArray) ElementType() reflect.Type

func (JobArray) ToJobArrayOutput added in v3.47.1 

func (i JobArray) ToJobArrayOutput() JobArrayOutput

func (JobArray) ToJobArrayOutputWithContext added in v3.47.1 

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

type JobArrayInput added in v3.47.1 

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 added in v3.47.1 

type JobArrayOutput struct{ *pulumi.OutputState }

func (JobArrayOutput) ElementType added in v3.47.1 

func (JobArrayOutput) ElementType() reflect.Type

func (JobArrayOutput) Index added in v3.47.1 

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

func (JobArrayOutput) ToJobArrayOutput added in v3.47.1 

func (o JobArrayOutput) ToJobArrayOutput() JobArrayOutput

func (JobArrayOutput) ToJobArrayOutputWithContext added in v3.47.1 

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

type JobInput added in v3.31.1 

type JobInput interface {
	pulumi.Input

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

type JobMap added in v3.47.1 

type JobMap map[string]JobInput

func (JobMap) ElementType added in v3.47.1 

func (JobMap) ElementType() reflect.Type

func (JobMap) ToJobMapOutput added in v3.47.1 

func (i JobMap) ToJobMapOutput() JobMapOutput

func (JobMap) ToJobMapOutputWithContext added in v3.47.1 

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

type JobMapInput added in v3.47.1 

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 added in v3.47.1 

type JobMapOutput struct{ *pulumi.OutputState }

func (JobMapOutput) ElementType added in v3.47.1 

func (JobMapOutput) ElementType() reflect.Type

func (JobMapOutput) MapIndex added in v3.47.1 

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

func (JobMapOutput) ToJobMapOutput added in v3.47.1 

func (o JobMapOutput) ToJobMapOutput() JobMapOutput

func (JobMapOutput) ToJobMapOutputWithContext added in v3.47.1 

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

type JobOutput added in v3.31.1 

type JobOutput struct {
	*pulumi.OutputState
}

func (JobOutput) ElementType added in v3.31.1 

func (JobOutput) ElementType() reflect.Type

func (JobOutput) ToJobOutput added in v3.31.1 

func (o JobOutput) ToJobOutput() JobOutput

func (JobOutput) ToJobOutputWithContext added in v3.31.1 

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

func (JobOutput) ToJobPtrOutput added in v3.47.1 

func (o JobOutput) ToJobPtrOutput() JobPtrOutput

func (JobOutput) ToJobPtrOutputWithContext added in v3.47.1 

func (o JobOutput) ToJobPtrOutputWithContext(ctx context.Context) JobPtrOutput

type JobPtrInput added in v3.47.1 

type JobPtrInput interface {
	pulumi.Input

	ToJobPtrOutput() JobPtrOutput
	ToJobPtrOutputWithContext(ctx context.Context) JobPtrOutput
}

type JobPtrOutput added in v3.47.1 

type JobPtrOutput struct {
	*pulumi.OutputState
}

func (JobPtrOutput) ElementType added in v3.47.1 

func (JobPtrOutput) ElementType() reflect.Type

func (JobPtrOutput) ToJobPtrOutput added in v3.47.1 

func (o JobPtrOutput) ToJobPtrOutput() JobPtrOutput

func (JobPtrOutput) ToJobPtrOutputWithContext added in v3.47.1 

func (o JobPtrOutput) ToJobPtrOutputWithContext(ctx context.Context) JobPtrOutput

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` and `1.1`.
	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
	// 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
	// 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 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"`
	// 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/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 OutputBlob 

type OutputBlob 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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*OutputBlob) ElementType() reflect.Type

func (*OutputBlob) ToOutputBlobOutput added in v3.31.1 

func (i *OutputBlob) ToOutputBlobOutput() OutputBlobOutput

func (*OutputBlob) ToOutputBlobOutputWithContext added in v3.31.1 

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

func (*OutputBlob) ToOutputBlobPtrOutput added in v3.47.1 

func (i *OutputBlob) ToOutputBlobPtrOutput() OutputBlobPtrOutput

func (*OutputBlob) ToOutputBlobPtrOutputWithContext added in v3.47.1 

func (i *OutputBlob) ToOutputBlobPtrOutputWithContext(ctx context.Context) OutputBlobPtrOutput

type OutputBlobArgs 

type OutputBlobArgs 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 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 added in v3.47.1 

type OutputBlobArray []OutputBlobInput

func (OutputBlobArray) ElementType added in v3.47.1 

func (OutputBlobArray) ElementType() reflect.Type

func (OutputBlobArray) ToOutputBlobArrayOutput added in v3.47.1 

func (i OutputBlobArray) ToOutputBlobArrayOutput() OutputBlobArrayOutput

func (OutputBlobArray) ToOutputBlobArrayOutputWithContext added in v3.47.1 

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

type OutputBlobArrayInput added in v3.47.1 

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 added in v3.47.1 

type OutputBlobArrayOutput struct{ *pulumi.OutputState }

func (OutputBlobArrayOutput) ElementType added in v3.47.1 

func (OutputBlobArrayOutput) ElementType() reflect.Type

func (OutputBlobArrayOutput) Index added in v3.47.1 

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

func (OutputBlobArrayOutput) ToOutputBlobArrayOutput added in v3.47.1 

func (o OutputBlobArrayOutput) ToOutputBlobArrayOutput() OutputBlobArrayOutput

func (OutputBlobArrayOutput) ToOutputBlobArrayOutputWithContext added in v3.47.1 

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

type OutputBlobInput added in v3.31.1 

type OutputBlobInput interface {
	pulumi.Input

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

type OutputBlobMap added in v3.47.1 

type OutputBlobMap map[string]OutputBlobInput

func (OutputBlobMap) ElementType added in v3.47.1 

func (OutputBlobMap) ElementType() reflect.Type

func (OutputBlobMap) ToOutputBlobMapOutput added in v3.47.1 

func (i OutputBlobMap) ToOutputBlobMapOutput() OutputBlobMapOutput

func (OutputBlobMap) ToOutputBlobMapOutputWithContext added in v3.47.1 

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

type OutputBlobMapInput added in v3.47.1 

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 added in v3.47.1 

type OutputBlobMapOutput struct{ *pulumi.OutputState }

func (OutputBlobMapOutput) ElementType added in v3.47.1 

func (OutputBlobMapOutput) ElementType() reflect.Type

func (OutputBlobMapOutput) MapIndex added in v3.47.1 

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

func (OutputBlobMapOutput) ToOutputBlobMapOutput added in v3.47.1 

func (o OutputBlobMapOutput) ToOutputBlobMapOutput() OutputBlobMapOutput

func (OutputBlobMapOutput) ToOutputBlobMapOutputWithContext added in v3.47.1 

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

type OutputBlobOutput added in v3.31.1 

type OutputBlobOutput struct {
	*pulumi.OutputState
}

func (OutputBlobOutput) ElementType added in v3.31.1 

func (OutputBlobOutput) ElementType() reflect.Type

func (OutputBlobOutput) ToOutputBlobOutput added in v3.31.1 

func (o OutputBlobOutput) ToOutputBlobOutput() OutputBlobOutput

func (OutputBlobOutput) ToOutputBlobOutputWithContext added in v3.31.1 

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

func (OutputBlobOutput) ToOutputBlobPtrOutput added in v3.47.1 

func (o OutputBlobOutput) ToOutputBlobPtrOutput() OutputBlobPtrOutput

func (OutputBlobOutput) ToOutputBlobPtrOutputWithContext added in v3.47.1 

func (o OutputBlobOutput) ToOutputBlobPtrOutputWithContext(ctx context.Context) OutputBlobPtrOutput

type OutputBlobPtrInput added in v3.47.1 

type OutputBlobPtrInput interface {
	pulumi.Input

	ToOutputBlobPtrOutput() OutputBlobPtrOutput
	ToOutputBlobPtrOutputWithContext(ctx context.Context) OutputBlobPtrOutput
}

type OutputBlobPtrOutput added in v3.47.1 

type OutputBlobPtrOutput struct {
	*pulumi.OutputState
}

func (OutputBlobPtrOutput) ElementType added in v3.47.1 

func (OutputBlobPtrOutput) ElementType() reflect.Type

func (OutputBlobPtrOutput) ToOutputBlobPtrOutput added in v3.47.1 

func (o OutputBlobPtrOutput) ToOutputBlobPtrOutput() OutputBlobPtrOutput

func (OutputBlobPtrOutput) ToOutputBlobPtrOutputWithContext added in v3.47.1 

func (o OutputBlobPtrOutput) ToOutputBlobPtrOutputWithContext(ctx context.Context) OutputBlobPtrOutput

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` and `Json`.
	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` and `Json`.
	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` and `Json`.

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` and `Json`.

type OutputBlobState 

type OutputBlobState 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 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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/eventhub"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*OutputEventHub) ElementType() reflect.Type

func (*OutputEventHub) ToOutputEventHubOutput added in v3.31.1 

func (i *OutputEventHub) ToOutputEventHubOutput() OutputEventHubOutput

func (*OutputEventHub) ToOutputEventHubOutputWithContext added in v3.31.1 

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

func (*OutputEventHub) ToOutputEventHubPtrOutput added in v3.47.1 

func (i *OutputEventHub) ToOutputEventHubPtrOutput() OutputEventHubPtrOutput

func (*OutputEventHub) ToOutputEventHubPtrOutputWithContext added in v3.47.1 

func (i *OutputEventHub) ToOutputEventHubPtrOutputWithContext(ctx context.Context) OutputEventHubPtrOutput

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 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 added in v3.47.1 

type OutputEventHubArray []OutputEventHubInput

func (OutputEventHubArray) ElementType added in v3.47.1 

func (OutputEventHubArray) ElementType() reflect.Type

func (OutputEventHubArray) ToOutputEventHubArrayOutput added in v3.47.1 

func (i OutputEventHubArray) ToOutputEventHubArrayOutput() OutputEventHubArrayOutput

func (OutputEventHubArray) ToOutputEventHubArrayOutputWithContext added in v3.47.1 

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

type OutputEventHubArrayInput added in v3.47.1 

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 added in v3.47.1 

type OutputEventHubArrayOutput struct{ *pulumi.OutputState }

func (OutputEventHubArrayOutput) ElementType added in v3.47.1 

func (OutputEventHubArrayOutput) ElementType() reflect.Type

func (OutputEventHubArrayOutput) Index added in v3.47.1 

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

func (OutputEventHubArrayOutput) ToOutputEventHubArrayOutput added in v3.47.1 

func (o OutputEventHubArrayOutput) ToOutputEventHubArrayOutput() OutputEventHubArrayOutput

func (OutputEventHubArrayOutput) ToOutputEventHubArrayOutputWithContext added in v3.47.1 

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

type OutputEventHubInput added in v3.31.1 

type OutputEventHubInput interface {
	pulumi.Input

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

type OutputEventHubMap added in v3.47.1 

type OutputEventHubMap map[string]OutputEventHubInput

func (OutputEventHubMap) ElementType added in v3.47.1 

func (OutputEventHubMap) ElementType() reflect.Type

func (OutputEventHubMap) ToOutputEventHubMapOutput added in v3.47.1 

func (i OutputEventHubMap) ToOutputEventHubMapOutput() OutputEventHubMapOutput

func (OutputEventHubMap) ToOutputEventHubMapOutputWithContext added in v3.47.1 

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

type OutputEventHubMapInput added in v3.47.1 

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 added in v3.47.1 

type OutputEventHubMapOutput struct{ *pulumi.OutputState }

func (OutputEventHubMapOutput) ElementType added in v3.47.1 

func (OutputEventHubMapOutput) ElementType() reflect.Type

func (OutputEventHubMapOutput) MapIndex added in v3.47.1 

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

func (OutputEventHubMapOutput) ToOutputEventHubMapOutput added in v3.47.1 

func (o OutputEventHubMapOutput) ToOutputEventHubMapOutput() OutputEventHubMapOutput

func (OutputEventHubMapOutput) ToOutputEventHubMapOutputWithContext added in v3.47.1 

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

type OutputEventHubOutput added in v3.31.1 

type OutputEventHubOutput struct {
	*pulumi.OutputState
}

func (OutputEventHubOutput) ElementType added in v3.31.1 

func (OutputEventHubOutput) ElementType() reflect.Type

func (OutputEventHubOutput) ToOutputEventHubOutput added in v3.31.1 

func (o OutputEventHubOutput) ToOutputEventHubOutput() OutputEventHubOutput

func (OutputEventHubOutput) ToOutputEventHubOutputWithContext added in v3.31.1 

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

func (OutputEventHubOutput) ToOutputEventHubPtrOutput added in v3.47.1 

func (o OutputEventHubOutput) ToOutputEventHubPtrOutput() OutputEventHubPtrOutput

func (OutputEventHubOutput) ToOutputEventHubPtrOutputWithContext added in v3.47.1 

func (o OutputEventHubOutput) ToOutputEventHubPtrOutputWithContext(ctx context.Context) OutputEventHubPtrOutput

type OutputEventHubPtrInput added in v3.47.1 

type OutputEventHubPtrInput interface {
	pulumi.Input

	ToOutputEventHubPtrOutput() OutputEventHubPtrOutput
	ToOutputEventHubPtrOutputWithContext(ctx context.Context) OutputEventHubPtrOutput
}

type OutputEventHubPtrOutput added in v3.47.1 

type OutputEventHubPtrOutput struct {
	*pulumi.OutputState
}

func (OutputEventHubPtrOutput) ElementType added in v3.47.1 

func (OutputEventHubPtrOutput) ElementType() reflect.Type

func (OutputEventHubPtrOutput) ToOutputEventHubPtrOutput added in v3.47.1 

func (o OutputEventHubPtrOutput) ToOutputEventHubPtrOutput() OutputEventHubPtrOutput

func (OutputEventHubPtrOutput) ToOutputEventHubPtrOutputWithContext added in v3.47.1 

func (o OutputEventHubPtrOutput) ToOutputEventHubPtrOutputWithContext(ctx context.Context) OutputEventHubPtrOutput

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 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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/sql"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*OutputMssql) ElementType() reflect.Type

func (*OutputMssql) ToOutputMssqlOutput added in v3.31.1 

func (i *OutputMssql) ToOutputMssqlOutput() OutputMssqlOutput

func (*OutputMssql) ToOutputMssqlOutputWithContext added in v3.31.1 

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

func (*OutputMssql) ToOutputMssqlPtrOutput added in v3.47.1 

func (i *OutputMssql) ToOutputMssqlPtrOutput() OutputMssqlPtrOutput

func (*OutputMssql) ToOutputMssqlPtrOutputWithContext added in v3.47.1 

func (i *OutputMssql) ToOutputMssqlPtrOutputWithContext(ctx context.Context) OutputMssqlPtrOutput

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 added in v3.47.1 

type OutputMssqlArray []OutputMssqlInput

func (OutputMssqlArray) ElementType added in v3.47.1 

func (OutputMssqlArray) ElementType() reflect.Type

func (OutputMssqlArray) ToOutputMssqlArrayOutput added in v3.47.1 

func (i OutputMssqlArray) ToOutputMssqlArrayOutput() OutputMssqlArrayOutput

func (OutputMssqlArray) ToOutputMssqlArrayOutputWithContext added in v3.47.1 

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

type OutputMssqlArrayInput added in v3.47.1 

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 added in v3.47.1 

type OutputMssqlArrayOutput struct{ *pulumi.OutputState }

func (OutputMssqlArrayOutput) ElementType added in v3.47.1 

func (OutputMssqlArrayOutput) ElementType() reflect.Type

func (OutputMssqlArrayOutput) Index added in v3.47.1 

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

func (OutputMssqlArrayOutput) ToOutputMssqlArrayOutput added in v3.47.1 

func (o OutputMssqlArrayOutput) ToOutputMssqlArrayOutput() OutputMssqlArrayOutput

func (OutputMssqlArrayOutput) ToOutputMssqlArrayOutputWithContext added in v3.47.1 

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

type OutputMssqlInput added in v3.31.1 

type OutputMssqlInput interface {
	pulumi.Input

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

type OutputMssqlMap added in v3.47.1 

type OutputMssqlMap map[string]OutputMssqlInput

func (OutputMssqlMap) ElementType added in v3.47.1 

func (OutputMssqlMap) ElementType() reflect.Type

func (OutputMssqlMap) ToOutputMssqlMapOutput added in v3.47.1 

func (i OutputMssqlMap) ToOutputMssqlMapOutput() OutputMssqlMapOutput

func (OutputMssqlMap) ToOutputMssqlMapOutputWithContext added in v3.47.1 

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

type OutputMssqlMapInput added in v3.47.1 

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 added in v3.47.1 

type OutputMssqlMapOutput struct{ *pulumi.OutputState }

func (OutputMssqlMapOutput) ElementType added in v3.47.1 

func (OutputMssqlMapOutput) ElementType() reflect.Type

func (OutputMssqlMapOutput) MapIndex added in v3.47.1 

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

func (OutputMssqlMapOutput) ToOutputMssqlMapOutput added in v3.47.1 

func (o OutputMssqlMapOutput) ToOutputMssqlMapOutput() OutputMssqlMapOutput

func (OutputMssqlMapOutput) ToOutputMssqlMapOutputWithContext added in v3.47.1 

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

type OutputMssqlOutput added in v3.31.1 

type OutputMssqlOutput struct {
	*pulumi.OutputState
}

func (OutputMssqlOutput) ElementType added in v3.31.1 

func (OutputMssqlOutput) ElementType() reflect.Type

func (OutputMssqlOutput) ToOutputMssqlOutput added in v3.31.1 

func (o OutputMssqlOutput) ToOutputMssqlOutput() OutputMssqlOutput

func (OutputMssqlOutput) ToOutputMssqlOutputWithContext added in v3.31.1 

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

func (OutputMssqlOutput) ToOutputMssqlPtrOutput added in v3.47.1 

func (o OutputMssqlOutput) ToOutputMssqlPtrOutput() OutputMssqlPtrOutput

func (OutputMssqlOutput) ToOutputMssqlPtrOutputWithContext added in v3.47.1 

func (o OutputMssqlOutput) ToOutputMssqlPtrOutputWithContext(ctx context.Context) OutputMssqlPtrOutput

type OutputMssqlPtrInput added in v3.47.1 

type OutputMssqlPtrInput interface {
	pulumi.Input

	ToOutputMssqlPtrOutput() OutputMssqlPtrOutput
	ToOutputMssqlPtrOutputWithContext(ctx context.Context) OutputMssqlPtrOutput
}

type OutputMssqlPtrOutput added in v3.47.1 

type OutputMssqlPtrOutput struct {
	*pulumi.OutputState
}

func (OutputMssqlPtrOutput) ElementType added in v3.47.1 

func (OutputMssqlPtrOutput) ElementType() reflect.Type

func (OutputMssqlPtrOutput) ToOutputMssqlPtrOutput added in v3.47.1 

func (o OutputMssqlPtrOutput) ToOutputMssqlPtrOutput() OutputMssqlPtrOutput

func (OutputMssqlPtrOutput) ToOutputMssqlPtrOutputWithContext added in v3.47.1 

func (o OutputMssqlPtrOutput) ToOutputMssqlPtrOutputWithContext(ctx context.Context) OutputMssqlPtrOutput

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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/servicebus"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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{
			ResourceGroupName:  pulumi.String(exampleResourceGroup.Name),
			NamespaceName:      exampleNamespace.Name,
			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 added in v3.31.1 

func (*OutputServiceBusQueue) ElementType() reflect.Type

func (*OutputServiceBusQueue) ToOutputServiceBusQueueOutput added in v3.31.1 

func (i *OutputServiceBusQueue) ToOutputServiceBusQueueOutput() OutputServiceBusQueueOutput

func (*OutputServiceBusQueue) ToOutputServiceBusQueueOutputWithContext added in v3.31.1 

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

func (*OutputServiceBusQueue) ToOutputServiceBusQueuePtrOutput added in v3.47.1 

func (i *OutputServiceBusQueue) ToOutputServiceBusQueuePtrOutput() OutputServiceBusQueuePtrOutput

func (*OutputServiceBusQueue) ToOutputServiceBusQueuePtrOutputWithContext added in v3.47.1 

func (i *OutputServiceBusQueue) ToOutputServiceBusQueuePtrOutputWithContext(ctx context.Context) OutputServiceBusQueuePtrOutput

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 added in v3.47.1 

type OutputServiceBusQueueArray []OutputServiceBusQueueInput

func (OutputServiceBusQueueArray) ElementType added in v3.47.1 

func (OutputServiceBusQueueArray) ElementType() reflect.Type

func (OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutput added in v3.47.1 

func (i OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutput() OutputServiceBusQueueArrayOutput

func (OutputServiceBusQueueArray) ToOutputServiceBusQueueArrayOutputWithContext added in v3.47.1 

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

type OutputServiceBusQueueArrayInput added in v3.47.1 

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 added in v3.47.1 

type OutputServiceBusQueueArrayOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueArrayOutput) ElementType added in v3.47.1 

func (OutputServiceBusQueueArrayOutput) ElementType() reflect.Type

func (OutputServiceBusQueueArrayOutput) Index added in v3.47.1 

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

func (OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutput added in v3.47.1 

func (o OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutput() OutputServiceBusQueueArrayOutput

func (OutputServiceBusQueueArrayOutput) ToOutputServiceBusQueueArrayOutputWithContext added in v3.47.1 

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

type OutputServiceBusQueueInput added in v3.31.1 

type OutputServiceBusQueueInput interface {
	pulumi.Input

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

type OutputServiceBusQueueMap added in v3.47.1 

type OutputServiceBusQueueMap map[string]OutputServiceBusQueueInput

func (OutputServiceBusQueueMap) ElementType added in v3.47.1 

func (OutputServiceBusQueueMap) ElementType() reflect.Type

func (OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutput added in v3.47.1 

func (i OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutput() OutputServiceBusQueueMapOutput

func (OutputServiceBusQueueMap) ToOutputServiceBusQueueMapOutputWithContext added in v3.47.1 

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

type OutputServiceBusQueueMapInput added in v3.47.1 

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 added in v3.47.1 

type OutputServiceBusQueueMapOutput struct{ *pulumi.OutputState }

func (OutputServiceBusQueueMapOutput) ElementType added in v3.47.1 

func (OutputServiceBusQueueMapOutput) ElementType() reflect.Type

func (OutputServiceBusQueueMapOutput) MapIndex added in v3.47.1 

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

func (OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutput added in v3.47.1 

func (o OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutput() OutputServiceBusQueueMapOutput

func (OutputServiceBusQueueMapOutput) ToOutputServiceBusQueueMapOutputWithContext added in v3.47.1 

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

type OutputServiceBusQueueOutput added in v3.31.1 

type OutputServiceBusQueueOutput struct {
	*pulumi.OutputState
}

func (OutputServiceBusQueueOutput) ElementType added in v3.31.1 

func (OutputServiceBusQueueOutput) ElementType() reflect.Type

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutput added in v3.31.1 

func (o OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutput() OutputServiceBusQueueOutput

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueueOutputWithContext added in v3.31.1 

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

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueuePtrOutput added in v3.47.1 

func (o OutputServiceBusQueueOutput) ToOutputServiceBusQueuePtrOutput() OutputServiceBusQueuePtrOutput

func (OutputServiceBusQueueOutput) ToOutputServiceBusQueuePtrOutputWithContext added in v3.47.1 

func (o OutputServiceBusQueueOutput) ToOutputServiceBusQueuePtrOutputWithContext(ctx context.Context) OutputServiceBusQueuePtrOutput

type OutputServiceBusQueuePtrInput added in v3.47.1 

type OutputServiceBusQueuePtrInput interface {
	pulumi.Input

	ToOutputServiceBusQueuePtrOutput() OutputServiceBusQueuePtrOutput
	ToOutputServiceBusQueuePtrOutputWithContext(ctx context.Context) OutputServiceBusQueuePtrOutput
}

type OutputServiceBusQueuePtrOutput added in v3.47.1 

type OutputServiceBusQueuePtrOutput struct {
	*pulumi.OutputState
}

func (OutputServiceBusQueuePtrOutput) ElementType added in v3.47.1 

func (OutputServiceBusQueuePtrOutput) ElementType() reflect.Type

func (OutputServiceBusQueuePtrOutput) ToOutputServiceBusQueuePtrOutput added in v3.47.1 

func (o OutputServiceBusQueuePtrOutput) ToOutputServiceBusQueuePtrOutput() OutputServiceBusQueuePtrOutput

func (OutputServiceBusQueuePtrOutput) ToOutputServiceBusQueuePtrOutputWithContext added in v3.47.1 

func (o OutputServiceBusQueuePtrOutput) ToOutputServiceBusQueuePtrOutputWithContext(ctx context.Context) OutputServiceBusQueuePtrOutput

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"`
	// 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/servicebus"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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{
			ResourceGroupName:  pulumi.String(exampleResourceGroup.Name),
			NamespaceName:      exampleNamespace.Name,
			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"),
			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 added in v3.31.1 

func (*OutputServicebusTopic) ElementType() reflect.Type

func (*OutputServicebusTopic) ToOutputServicebusTopicOutput added in v3.31.1 

func (i *OutputServicebusTopic) ToOutputServicebusTopicOutput() OutputServicebusTopicOutput

func (*OutputServicebusTopic) ToOutputServicebusTopicOutputWithContext added in v3.31.1 

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

func (*OutputServicebusTopic) ToOutputServicebusTopicPtrOutput added in v3.47.1 

func (i *OutputServicebusTopic) ToOutputServicebusTopicPtrOutput() OutputServicebusTopicPtrOutput

func (*OutputServicebusTopic) ToOutputServicebusTopicPtrOutputWithContext added in v3.47.1 

func (i *OutputServicebusTopic) ToOutputServicebusTopicPtrOutputWithContext(ctx context.Context) OutputServicebusTopicPtrOutput

type OutputServicebusTopicArgs 

type OutputServicebusTopicArgs struct {
	// The name of the Stream Output. 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 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 added in v3.47.1 

type OutputServicebusTopicArray []OutputServicebusTopicInput

func (OutputServicebusTopicArray) ElementType added in v3.47.1 

func (OutputServicebusTopicArray) ElementType() reflect.Type

func (OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutput added in v3.47.1 

func (i OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutput() OutputServicebusTopicArrayOutput

func (OutputServicebusTopicArray) ToOutputServicebusTopicArrayOutputWithContext added in v3.47.1 

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

type OutputServicebusTopicArrayInput added in v3.47.1 

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 added in v3.47.1 

type OutputServicebusTopicArrayOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicArrayOutput) ElementType added in v3.47.1 

func (OutputServicebusTopicArrayOutput) ElementType() reflect.Type

func (OutputServicebusTopicArrayOutput) Index added in v3.47.1 

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

func (OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutput added in v3.47.1 

func (o OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutput() OutputServicebusTopicArrayOutput

func (OutputServicebusTopicArrayOutput) ToOutputServicebusTopicArrayOutputWithContext added in v3.47.1 

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

type OutputServicebusTopicInput added in v3.31.1 

type OutputServicebusTopicInput interface {
	pulumi.Input

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

type OutputServicebusTopicMap added in v3.47.1 

type OutputServicebusTopicMap map[string]OutputServicebusTopicInput

func (OutputServicebusTopicMap) ElementType added in v3.47.1 

func (OutputServicebusTopicMap) ElementType() reflect.Type

func (OutputServicebusTopicMap) ToOutputServicebusTopicMapOutput added in v3.47.1 

func (i OutputServicebusTopicMap) ToOutputServicebusTopicMapOutput() OutputServicebusTopicMapOutput

func (OutputServicebusTopicMap) ToOutputServicebusTopicMapOutputWithContext added in v3.47.1 

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

type OutputServicebusTopicMapInput added in v3.47.1 

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 added in v3.47.1 

type OutputServicebusTopicMapOutput struct{ *pulumi.OutputState }

func (OutputServicebusTopicMapOutput) ElementType added in v3.47.1 

func (OutputServicebusTopicMapOutput) ElementType() reflect.Type

func (OutputServicebusTopicMapOutput) MapIndex added in v3.47.1 

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

func (OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutput added in v3.47.1 

func (o OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutput() OutputServicebusTopicMapOutput

func (OutputServicebusTopicMapOutput) ToOutputServicebusTopicMapOutputWithContext added in v3.47.1 

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

type OutputServicebusTopicOutput added in v3.31.1 

type OutputServicebusTopicOutput struct {
	*pulumi.OutputState
}

func (OutputServicebusTopicOutput) ElementType added in v3.31.1 

func (OutputServicebusTopicOutput) ElementType() reflect.Type

func (OutputServicebusTopicOutput) ToOutputServicebusTopicOutput added in v3.31.1 

func (o OutputServicebusTopicOutput) ToOutputServicebusTopicOutput() OutputServicebusTopicOutput

func (OutputServicebusTopicOutput) ToOutputServicebusTopicOutputWithContext added in v3.31.1 

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

func (OutputServicebusTopicOutput) ToOutputServicebusTopicPtrOutput added in v3.47.1 

func (o OutputServicebusTopicOutput) ToOutputServicebusTopicPtrOutput() OutputServicebusTopicPtrOutput

func (OutputServicebusTopicOutput) ToOutputServicebusTopicPtrOutputWithContext added in v3.47.1 

func (o OutputServicebusTopicOutput) ToOutputServicebusTopicPtrOutputWithContext(ctx context.Context) OutputServicebusTopicPtrOutput

type OutputServicebusTopicPtrInput added in v3.47.1 

type OutputServicebusTopicPtrInput interface {
	pulumi.Input

	ToOutputServicebusTopicPtrOutput() OutputServicebusTopicPtrOutput
	ToOutputServicebusTopicPtrOutputWithContext(ctx context.Context) OutputServicebusTopicPtrOutput
}

type OutputServicebusTopicPtrOutput added in v3.47.1 

type OutputServicebusTopicPtrOutput struct {
	*pulumi.OutputState
}

func (OutputServicebusTopicPtrOutput) ElementType added in v3.47.1 

func (OutputServicebusTopicPtrOutput) ElementType() reflect.Type

func (OutputServicebusTopicPtrOutput) ToOutputServicebusTopicPtrOutput added in v3.47.1 

func (o OutputServicebusTopicPtrOutput) ToOutputServicebusTopicPtrOutput() OutputServicebusTopicPtrOutput

func (OutputServicebusTopicPtrOutput) ToOutputServicebusTopicPtrOutputWithContext added in v3.47.1 

func (o OutputServicebusTopicPtrOutput) ToOutputServicebusTopicPtrOutputWithContext(ctx context.Context) OutputServicebusTopicPtrOutput

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
	// 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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*ReferenceInputBlob) ElementType() reflect.Type

func (*ReferenceInputBlob) ToReferenceInputBlobOutput added in v3.31.1 

func (i *ReferenceInputBlob) ToReferenceInputBlobOutput() ReferenceInputBlobOutput

func (*ReferenceInputBlob) ToReferenceInputBlobOutputWithContext added in v3.31.1 

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

func (*ReferenceInputBlob) ToReferenceInputBlobPtrOutput added in v3.47.1 

func (i *ReferenceInputBlob) ToReferenceInputBlobPtrOutput() ReferenceInputBlobPtrOutput

func (*ReferenceInputBlob) ToReferenceInputBlobPtrOutputWithContext added in v3.47.1 

func (i *ReferenceInputBlob) ToReferenceInputBlobPtrOutputWithContext(ctx context.Context) ReferenceInputBlobPtrOutput

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 added in v3.47.1 

type ReferenceInputBlobArray []ReferenceInputBlobInput

func (ReferenceInputBlobArray) ElementType added in v3.47.1 

func (ReferenceInputBlobArray) ElementType() reflect.Type

func (ReferenceInputBlobArray) ToReferenceInputBlobArrayOutput added in v3.47.1 

func (i ReferenceInputBlobArray) ToReferenceInputBlobArrayOutput() ReferenceInputBlobArrayOutput

func (ReferenceInputBlobArray) ToReferenceInputBlobArrayOutputWithContext added in v3.47.1 

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

type ReferenceInputBlobArrayInput added in v3.47.1 

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 added in v3.47.1 

type ReferenceInputBlobArrayOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobArrayOutput) ElementType added in v3.47.1 

func (ReferenceInputBlobArrayOutput) ElementType() reflect.Type

func (ReferenceInputBlobArrayOutput) Index added in v3.47.1 

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

func (ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutput added in v3.47.1 

func (o ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutput() ReferenceInputBlobArrayOutput

func (ReferenceInputBlobArrayOutput) ToReferenceInputBlobArrayOutputWithContext added in v3.47.1 

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

type ReferenceInputBlobInput added in v3.31.1 

type ReferenceInputBlobInput interface {
	pulumi.Input

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

type ReferenceInputBlobMap added in v3.47.1 

type ReferenceInputBlobMap map[string]ReferenceInputBlobInput

func (ReferenceInputBlobMap) ElementType added in v3.47.1 

func (ReferenceInputBlobMap) ElementType() reflect.Type

func (ReferenceInputBlobMap) ToReferenceInputBlobMapOutput added in v3.47.1 

func (i ReferenceInputBlobMap) ToReferenceInputBlobMapOutput() ReferenceInputBlobMapOutput

func (ReferenceInputBlobMap) ToReferenceInputBlobMapOutputWithContext added in v3.47.1 

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

type ReferenceInputBlobMapInput added in v3.47.1 

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 added in v3.47.1 

type ReferenceInputBlobMapOutput struct{ *pulumi.OutputState }

func (ReferenceInputBlobMapOutput) ElementType added in v3.47.1 

func (ReferenceInputBlobMapOutput) ElementType() reflect.Type

func (ReferenceInputBlobMapOutput) MapIndex added in v3.47.1 

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

func (ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutput added in v3.47.1 

func (o ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutput() ReferenceInputBlobMapOutput

func (ReferenceInputBlobMapOutput) ToReferenceInputBlobMapOutputWithContext added in v3.47.1 

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

type ReferenceInputBlobOutput added in v3.31.1 

type ReferenceInputBlobOutput struct {
	*pulumi.OutputState
}

func (ReferenceInputBlobOutput) ElementType added in v3.31.1 

func (ReferenceInputBlobOutput) ElementType() reflect.Type

func (ReferenceInputBlobOutput) ToReferenceInputBlobOutput added in v3.31.1 

func (o ReferenceInputBlobOutput) ToReferenceInputBlobOutput() ReferenceInputBlobOutput

func (ReferenceInputBlobOutput) ToReferenceInputBlobOutputWithContext added in v3.31.1 

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

func (ReferenceInputBlobOutput) ToReferenceInputBlobPtrOutput added in v3.47.1 

func (o ReferenceInputBlobOutput) ToReferenceInputBlobPtrOutput() ReferenceInputBlobPtrOutput

func (ReferenceInputBlobOutput) ToReferenceInputBlobPtrOutputWithContext added in v3.47.1 

func (o ReferenceInputBlobOutput) ToReferenceInputBlobPtrOutputWithContext(ctx context.Context) ReferenceInputBlobPtrOutput

type ReferenceInputBlobPtrInput added in v3.47.1 

type ReferenceInputBlobPtrInput interface {
	pulumi.Input

	ToReferenceInputBlobPtrOutput() ReferenceInputBlobPtrOutput
	ToReferenceInputBlobPtrOutputWithContext(ctx context.Context) ReferenceInputBlobPtrOutput
}

type ReferenceInputBlobPtrOutput added in v3.47.1 

type ReferenceInputBlobPtrOutput struct {
	*pulumi.OutputState
}

func (ReferenceInputBlobPtrOutput) ElementType added in v3.47.1 

func (ReferenceInputBlobPtrOutput) ElementType() reflect.Type

func (ReferenceInputBlobPtrOutput) ToReferenceInputBlobPtrOutput added in v3.47.1 

func (o ReferenceInputBlobPtrOutput) ToReferenceInputBlobPtrOutput() ReferenceInputBlobPtrOutput

func (ReferenceInputBlobPtrOutput) ToReferenceInputBlobPtrOutputWithContext added in v3.47.1 

func (o ReferenceInputBlobPtrOutput) ToReferenceInputBlobPtrOutputWithContext(ctx context.Context) ReferenceInputBlobPtrOutput

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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/storage"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*StreamInputBlob) ElementType() reflect.Type

func (*StreamInputBlob) ToStreamInputBlobOutput added in v3.31.1 

func (i *StreamInputBlob) ToStreamInputBlobOutput() StreamInputBlobOutput

func (*StreamInputBlob) ToStreamInputBlobOutputWithContext added in v3.31.1 

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

func (*StreamInputBlob) ToStreamInputBlobPtrOutput added in v3.47.1 

func (i *StreamInputBlob) ToStreamInputBlobPtrOutput() StreamInputBlobPtrOutput

func (*StreamInputBlob) ToStreamInputBlobPtrOutputWithContext added in v3.47.1 

func (i *StreamInputBlob) ToStreamInputBlobPtrOutputWithContext(ctx context.Context) StreamInputBlobPtrOutput

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 added in v3.47.1 

type StreamInputBlobArray []StreamInputBlobInput

func (StreamInputBlobArray) ElementType added in v3.47.1 

func (StreamInputBlobArray) ElementType() reflect.Type

func (StreamInputBlobArray) ToStreamInputBlobArrayOutput added in v3.47.1 

func (i StreamInputBlobArray) ToStreamInputBlobArrayOutput() StreamInputBlobArrayOutput

func (StreamInputBlobArray) ToStreamInputBlobArrayOutputWithContext added in v3.47.1 

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

type StreamInputBlobArrayInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputBlobArrayOutput struct{ *pulumi.OutputState }

func (StreamInputBlobArrayOutput) ElementType added in v3.47.1 

func (StreamInputBlobArrayOutput) ElementType() reflect.Type

func (StreamInputBlobArrayOutput) Index added in v3.47.1 

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

func (StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutput added in v3.47.1 

func (o StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutput() StreamInputBlobArrayOutput

func (StreamInputBlobArrayOutput) ToStreamInputBlobArrayOutputWithContext added in v3.47.1 

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

type StreamInputBlobInput added in v3.31.1 

type StreamInputBlobInput interface {
	pulumi.Input

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

type StreamInputBlobMap added in v3.47.1 

type StreamInputBlobMap map[string]StreamInputBlobInput

func (StreamInputBlobMap) ElementType added in v3.47.1 

func (StreamInputBlobMap) ElementType() reflect.Type

func (StreamInputBlobMap) ToStreamInputBlobMapOutput added in v3.47.1 

func (i StreamInputBlobMap) ToStreamInputBlobMapOutput() StreamInputBlobMapOutput

func (StreamInputBlobMap) ToStreamInputBlobMapOutputWithContext added in v3.47.1 

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

type StreamInputBlobMapInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputBlobMapOutput struct{ *pulumi.OutputState }

func (StreamInputBlobMapOutput) ElementType added in v3.47.1 

func (StreamInputBlobMapOutput) ElementType() reflect.Type

func (StreamInputBlobMapOutput) MapIndex added in v3.47.1 

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

func (StreamInputBlobMapOutput) ToStreamInputBlobMapOutput added in v3.47.1 

func (o StreamInputBlobMapOutput) ToStreamInputBlobMapOutput() StreamInputBlobMapOutput

func (StreamInputBlobMapOutput) ToStreamInputBlobMapOutputWithContext added in v3.47.1 

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

type StreamInputBlobOutput added in v3.31.1 

type StreamInputBlobOutput struct {
	*pulumi.OutputState
}

func (StreamInputBlobOutput) ElementType added in v3.31.1 

func (StreamInputBlobOutput) ElementType() reflect.Type

func (StreamInputBlobOutput) ToStreamInputBlobOutput added in v3.31.1 

func (o StreamInputBlobOutput) ToStreamInputBlobOutput() StreamInputBlobOutput

func (StreamInputBlobOutput) ToStreamInputBlobOutputWithContext added in v3.31.1 

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

func (StreamInputBlobOutput) ToStreamInputBlobPtrOutput added in v3.47.1 

func (o StreamInputBlobOutput) ToStreamInputBlobPtrOutput() StreamInputBlobPtrOutput

func (StreamInputBlobOutput) ToStreamInputBlobPtrOutputWithContext added in v3.47.1 

func (o StreamInputBlobOutput) ToStreamInputBlobPtrOutputWithContext(ctx context.Context) StreamInputBlobPtrOutput

type StreamInputBlobPtrInput added in v3.47.1 

type StreamInputBlobPtrInput interface {
	pulumi.Input

	ToStreamInputBlobPtrOutput() StreamInputBlobPtrOutput
	ToStreamInputBlobPtrOutputWithContext(ctx context.Context) StreamInputBlobPtrOutput
}

type StreamInputBlobPtrOutput added in v3.47.1 

type StreamInputBlobPtrOutput struct {
	*pulumi.OutputState
}

func (StreamInputBlobPtrOutput) ElementType added in v3.47.1 

func (StreamInputBlobPtrOutput) ElementType() reflect.Type

func (StreamInputBlobPtrOutput) ToStreamInputBlobPtrOutput added in v3.47.1 

func (o StreamInputBlobPtrOutput) ToStreamInputBlobPtrOutput() StreamInputBlobPtrOutput

func (StreamInputBlobPtrOutput) ToStreamInputBlobPtrOutputWithContext added in v3.47.1 

func (o StreamInputBlobPtrOutput) ToStreamInputBlobPtrOutputWithContext(ctx context.Context) StreamInputBlobPtrOutput

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.
	EventhubConsumerGroupName pulumi.StringOutput `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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/eventhub"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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 added in v3.31.1 

func (*StreamInputEventHub) ElementType() reflect.Type

func (*StreamInputEventHub) ToStreamInputEventHubOutput added in v3.31.1 

func (i *StreamInputEventHub) ToStreamInputEventHubOutput() StreamInputEventHubOutput

func (*StreamInputEventHub) ToStreamInputEventHubOutputWithContext added in v3.31.1 

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

func (*StreamInputEventHub) ToStreamInputEventHubPtrOutput added in v3.47.1 

func (i *StreamInputEventHub) ToStreamInputEventHubPtrOutput() StreamInputEventHubPtrOutput

func (*StreamInputEventHub) ToStreamInputEventHubPtrOutputWithContext added in v3.47.1 

func (i *StreamInputEventHub) ToStreamInputEventHubPtrOutputWithContext(ctx context.Context) StreamInputEventHubPtrOutput

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.
	EventhubConsumerGroupName pulumi.StringInput
	// 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 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 added in v3.47.1 

type StreamInputEventHubArray []StreamInputEventHubInput

func (StreamInputEventHubArray) ElementType added in v3.47.1 

func (StreamInputEventHubArray) ElementType() reflect.Type

func (StreamInputEventHubArray) ToStreamInputEventHubArrayOutput added in v3.47.1 

func (i StreamInputEventHubArray) ToStreamInputEventHubArrayOutput() StreamInputEventHubArrayOutput

func (StreamInputEventHubArray) ToStreamInputEventHubArrayOutputWithContext added in v3.47.1 

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

type StreamInputEventHubArrayInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputEventHubArrayOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubArrayOutput) ElementType added in v3.47.1 

func (StreamInputEventHubArrayOutput) ElementType() reflect.Type

func (StreamInputEventHubArrayOutput) Index added in v3.47.1 

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

func (StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutput added in v3.47.1 

func (o StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutput() StreamInputEventHubArrayOutput

func (StreamInputEventHubArrayOutput) ToStreamInputEventHubArrayOutputWithContext added in v3.47.1 

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

type StreamInputEventHubInput added in v3.31.1 

type StreamInputEventHubInput interface {
	pulumi.Input

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

type StreamInputEventHubMap added in v3.47.1 

type StreamInputEventHubMap map[string]StreamInputEventHubInput

func (StreamInputEventHubMap) ElementType added in v3.47.1 

func (StreamInputEventHubMap) ElementType() reflect.Type

func (StreamInputEventHubMap) ToStreamInputEventHubMapOutput added in v3.47.1 

func (i StreamInputEventHubMap) ToStreamInputEventHubMapOutput() StreamInputEventHubMapOutput

func (StreamInputEventHubMap) ToStreamInputEventHubMapOutputWithContext added in v3.47.1 

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

type StreamInputEventHubMapInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputEventHubMapOutput struct{ *pulumi.OutputState }

func (StreamInputEventHubMapOutput) ElementType added in v3.47.1 

func (StreamInputEventHubMapOutput) ElementType() reflect.Type

func (StreamInputEventHubMapOutput) MapIndex added in v3.47.1 

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

func (StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutput added in v3.47.1 

func (o StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutput() StreamInputEventHubMapOutput

func (StreamInputEventHubMapOutput) ToStreamInputEventHubMapOutputWithContext added in v3.47.1 

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

type StreamInputEventHubOutput added in v3.31.1 

type StreamInputEventHubOutput struct {
	*pulumi.OutputState
}

func (StreamInputEventHubOutput) ElementType added in v3.31.1 

func (StreamInputEventHubOutput) ElementType() reflect.Type

func (StreamInputEventHubOutput) ToStreamInputEventHubOutput added in v3.31.1 

func (o StreamInputEventHubOutput) ToStreamInputEventHubOutput() StreamInputEventHubOutput

func (StreamInputEventHubOutput) ToStreamInputEventHubOutputWithContext added in v3.31.1 

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

func (StreamInputEventHubOutput) ToStreamInputEventHubPtrOutput added in v3.47.1 

func (o StreamInputEventHubOutput) ToStreamInputEventHubPtrOutput() StreamInputEventHubPtrOutput

func (StreamInputEventHubOutput) ToStreamInputEventHubPtrOutputWithContext added in v3.47.1 

func (o StreamInputEventHubOutput) ToStreamInputEventHubPtrOutputWithContext(ctx context.Context) StreamInputEventHubPtrOutput

type StreamInputEventHubPtrInput added in v3.47.1 

type StreamInputEventHubPtrInput interface {
	pulumi.Input

	ToStreamInputEventHubPtrOutput() StreamInputEventHubPtrOutput
	ToStreamInputEventHubPtrOutputWithContext(ctx context.Context) StreamInputEventHubPtrOutput
}

type StreamInputEventHubPtrOutput added in v3.47.1 

type StreamInputEventHubPtrOutput struct {
	*pulumi.OutputState
}

func (StreamInputEventHubPtrOutput) ElementType added in v3.47.1 

func (StreamInputEventHubPtrOutput) ElementType() reflect.Type

func (StreamInputEventHubPtrOutput) ToStreamInputEventHubPtrOutput added in v3.47.1 

func (o StreamInputEventHubPtrOutput) ToStreamInputEventHubPtrOutput() StreamInputEventHubPtrOutput

func (StreamInputEventHubPtrOutput) ToStreamInputEventHubPtrOutputWithContext added in v3.47.1 

func (o StreamInputEventHubPtrOutput) ToStreamInputEventHubPtrOutputWithContext(ctx context.Context) StreamInputEventHubPtrOutput

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.
	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 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/v3/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/iot"
"github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v2/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: pulumi.String(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 added in v3.31.1 

func (*StreamInputIotHub) ElementType() reflect.Type

func (*StreamInputIotHub) ToStreamInputIotHubOutput added in v3.31.1 

func (i *StreamInputIotHub) ToStreamInputIotHubOutput() StreamInputIotHubOutput

func (*StreamInputIotHub) ToStreamInputIotHubOutputWithContext added in v3.31.1 

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

func (*StreamInputIotHub) ToStreamInputIotHubPtrOutput added in v3.47.1 

func (i *StreamInputIotHub) ToStreamInputIotHubPtrOutput() StreamInputIotHubPtrOutput

func (*StreamInputIotHub) ToStreamInputIotHubPtrOutputWithContext added in v3.47.1 

func (i *StreamInputIotHub) ToStreamInputIotHubPtrOutputWithContext(ctx context.Context) StreamInputIotHubPtrOutput

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 added in v3.47.1 

type StreamInputIotHubArray []StreamInputIotHubInput

func (StreamInputIotHubArray) ElementType added in v3.47.1 

func (StreamInputIotHubArray) ElementType() reflect.Type

func (StreamInputIotHubArray) ToStreamInputIotHubArrayOutput added in v3.47.1 

func (i StreamInputIotHubArray) ToStreamInputIotHubArrayOutput() StreamInputIotHubArrayOutput

func (StreamInputIotHubArray) ToStreamInputIotHubArrayOutputWithContext added in v3.47.1 

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

type StreamInputIotHubArrayInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputIotHubArrayOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubArrayOutput) ElementType added in v3.47.1 

func (StreamInputIotHubArrayOutput) ElementType() reflect.Type

func (StreamInputIotHubArrayOutput) Index added in v3.47.1 

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

func (StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutput added in v3.47.1 

func (o StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutput() StreamInputIotHubArrayOutput

func (StreamInputIotHubArrayOutput) ToStreamInputIotHubArrayOutputWithContext added in v3.47.1 

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

type StreamInputIotHubInput added in v3.31.1 

type StreamInputIotHubInput interface {
	pulumi.Input

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

type StreamInputIotHubMap added in v3.47.1 

type StreamInputIotHubMap map[string]StreamInputIotHubInput

func (StreamInputIotHubMap) ElementType added in v3.47.1 

func (StreamInputIotHubMap) ElementType() reflect.Type

func (StreamInputIotHubMap) ToStreamInputIotHubMapOutput added in v3.47.1 

func (i StreamInputIotHubMap) ToStreamInputIotHubMapOutput() StreamInputIotHubMapOutput

func (StreamInputIotHubMap) ToStreamInputIotHubMapOutputWithContext added in v3.47.1 

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

type StreamInputIotHubMapInput added in v3.47.1 

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 added in v3.47.1 

type StreamInputIotHubMapOutput struct{ *pulumi.OutputState }

func (StreamInputIotHubMapOutput) ElementType added in v3.47.1 

func (StreamInputIotHubMapOutput) ElementType() reflect.Type

func (StreamInputIotHubMapOutput) MapIndex added in v3.47.1 

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

func (StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutput added in v3.47.1 

func (o StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutput() StreamInputIotHubMapOutput

func (StreamInputIotHubMapOutput) ToStreamInputIotHubMapOutputWithContext added in v3.47.1 

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

type StreamInputIotHubOutput added in v3.31.1 

type StreamInputIotHubOutput struct {
	*pulumi.OutputState
}

func (StreamInputIotHubOutput) ElementType added in v3.31.1 

func (StreamInputIotHubOutput) ElementType() reflect.Type

func (StreamInputIotHubOutput) ToStreamInputIotHubOutput added in v3.31.1 

func (o StreamInputIotHubOutput) ToStreamInputIotHubOutput() StreamInputIotHubOutput

func (StreamInputIotHubOutput) ToStreamInputIotHubOutputWithContext added in v3.31.1 

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

func (StreamInputIotHubOutput) ToStreamInputIotHubPtrOutput added in v3.47.1 

func (o StreamInputIotHubOutput) ToStreamInputIotHubPtrOutput() StreamInputIotHubPtrOutput

func (StreamInputIotHubOutput) ToStreamInputIotHubPtrOutputWithContext added in v3.47.1 

func (o StreamInputIotHubOutput) ToStreamInputIotHubPtrOutputWithContext(ctx context.Context) StreamInputIotHubPtrOutput

type StreamInputIotHubPtrInput added in v3.47.1 

type StreamInputIotHubPtrInput interface {
	pulumi.Input

	ToStreamInputIotHubPtrOutput() StreamInputIotHubPtrOutput
	ToStreamInputIotHubPtrOutputWithContext(ctx context.Context) StreamInputIotHubPtrOutput
}

type StreamInputIotHubPtrOutput added in v3.47.1 

type StreamInputIotHubPtrOutput struct {
	*pulumi.OutputState
}

func (StreamInputIotHubPtrOutput) ElementType added in v3.47.1 

func (StreamInputIotHubPtrOutput) ElementType() reflect.Type

func (StreamInputIotHubPtrOutput) ToStreamInputIotHubPtrOutput added in v3.47.1 

func (o StreamInputIotHubPtrOutput) ToStreamInputIotHubPtrOutput() StreamInputIotHubPtrOutput

func (StreamInputIotHubPtrOutput) ToStreamInputIotHubPtrOutputWithContext added in v3.47.1 

func (o StreamInputIotHubPtrOutput) ToStreamInputIotHubPtrOutputWithContext(ctx context.Context) StreamInputIotHubPtrOutput

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.