streamanalytics

package
v0.18.5 Latest Latest
Warning

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

 Go to latest Published: May 26, 2019 License: Apache-2.0 Imports: 2 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 {
	// contains filtered or unexported fields
}

Manages a JavaScript UDF Function within Stream Analytics Streaming Job.

func GetFunctionJavaScriptUDF 

func GetFunctionJavaScriptUDF(ctx *pulumi.Context,
	name string, id pulumi.ID, state *FunctionJavaScriptUDFState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*FunctionJavaScriptUDF, error)

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

func (*FunctionJavaScriptUDF) ID 

func (r *FunctionJavaScriptUDF) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*FunctionJavaScriptUDF) Inputs 

func (r *FunctionJavaScriptUDF) Inputs() *pulumi.ArrayOutput

One or more `input` blocks as defined below.

func (*FunctionJavaScriptUDF) Name 

func (r *FunctionJavaScriptUDF) Name() *pulumi.StringOutput

The name of the JavaScript UDF Function. Changing this forces a new resource to be created.

func (*FunctionJavaScriptUDF) Output 

func (r *FunctionJavaScriptUDF) Output() *pulumi.Output

An `output` blocks as defined below.

func (*FunctionJavaScriptUDF) ResourceGroupName 

func (r *FunctionJavaScriptUDF) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*FunctionJavaScriptUDF) Script 

func (r *FunctionJavaScriptUDF) Script() *pulumi.StringOutput

The JavaScript of this UDF Function.

func (*FunctionJavaScriptUDF) StreamAnalyticsJobName 

func (r *FunctionJavaScriptUDF) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

func (*FunctionJavaScriptUDF) URN 

func (r *FunctionJavaScriptUDF) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type FunctionJavaScriptUDFArgs 

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

The set of arguments for constructing a FunctionJavaScriptUDF resource.

type FunctionJavaScriptUDFState 

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

Input properties used for looking up and filtering FunctionJavaScriptUDF resources.

type GetJobArgs 

type GetJobArgs struct {
	// Specifies the name of the Stream Analytics Job.
	Name interface{}
	// Specifies the name of the resource group the Stream Analytics Job is located in.
	ResourceGroupName interface{}
}

A collection of arguments for invoking getJob.

type GetJobResult 

type GetJobResult struct {
	// The compatibility level for this job.
	CompatibilityLevel interface{}
	// The Data Locale of the Job.
	DataLocale interface{}
	// The maximum tolerable delay in seconds where events arriving late could be included.
	EventsLateArrivalMaxDelayInSeconds interface{}
	// The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
	EventsOutOfOrderMaxDelayInSeconds interface{}
	// The policy which should be applied to events which arrive out of order in the input event stream.
	EventsOutOfOrderPolicy interface{}
	// The Job ID assigned by the Stream Analytics Job.
	JobId interface{}
	// The Azure location where the Stream Analytics Job exists.
	Location interface{}
	Name     interface{}
	// 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 interface{}
	ResourceGroupName interface{}
	// The number of streaming units that the streaming job uses.
	StreamingUnits interface{}
	// 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 interface{}
	// id is the provider-assigned unique ID for this managed resource.
	Id interface{}
}

A collection of values returned by getJob.

func LookupJob 

func LookupJob(ctx *pulumi.Context, args *GetJobArgs) (*GetJobResult, error)

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

type Job 

type Job struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Job.

func GetJob 

func GetJob(ctx *pulumi.Context,
	name string, id pulumi.ID, state *JobState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*Job, error)

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

func (*Job) CompatibilityLevel 

func (r *Job) CompatibilityLevel() *pulumi.StringOutput

Specifies the compatibility level for this job - which controls certain runtime behaviors of the streaming job. Possible values are `1.0` and 1.1`.

func (*Job) DataLocale 

func (r *Job) DataLocale() *pulumi.StringOutput

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).

func (*Job) EventsLateArrivalMaxDelayInSeconds 

func (r *Job) EventsLateArrivalMaxDelayInSeconds() *pulumi.IntOutput

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).

func (*Job) EventsOutOfOrderMaxDelayInSeconds 

func (r *Job) EventsOutOfOrderMaxDelayInSeconds() *pulumi.IntOutput

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).

func (*Job) EventsOutOfOrderPolicy 

func (r *Job) EventsOutOfOrderPolicy() *pulumi.StringOutput

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

func (*Job) ID 

func (r *Job) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Job) JobId 

func (r *Job) JobId() *pulumi.StringOutput

The Job ID assigned by the Stream Analytics Job.

func (*Job) Location 

func (r *Job) Location() *pulumi.StringOutput

The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

func (*Job) Name 

func (r *Job) Name() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*Job) OutputErrorPolicy 

func (r *Job) OutputErrorPolicy() *pulumi.StringOutput

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

func (*Job) ResourceGroupName 

func (r *Job) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.

func (*Job) StreamingUnits 

func (r *Job) StreamingUnits() *pulumi.IntOutput

Specifies the number of streaming units that the streaming job uses. Supported values are `1`, `3`, `6` and multiples of `6` up to `120`.

func (*Job) Tags added in v0.18.3 

func (r *Job) Tags() *pulumi.MapOutput

A mapping of tags assigned to the resource.

func (*Job) TransformationQuery 

func (r *Job) TransformationQuery() *pulumi.StringOutput

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).

func (*Job) URN 

func (r *Job) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type JobArgs 

type JobArgs struct {
	// Specifies the compatibility level for this job - which controls certain runtime behaviors of the streaming job. Possible values are `1.0` and 1.1`.
	CompatibilityLevel interface{}
	// 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 interface{}
	// 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).
	EventsLateArrivalMaxDelayInSeconds interface{}
	// 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).
	EventsOutOfOrderMaxDelayInSeconds interface{}
	// 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`.
	EventsOutOfOrderPolicy interface{}
	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	Name interface{}
	// 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`.
	OutputErrorPolicy interface{}
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// 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 interface{}
	// A mapping of tags assigned to the resource.
	Tags interface{}
	// 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 interface{}
}

The set of arguments for constructing a Job resource.

type JobState 

type JobState struct {
	// Specifies the compatibility level for this job - which controls certain runtime behaviors of the streaming job. Possible values are `1.0` and 1.1`.
	CompatibilityLevel interface{}
	// 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 interface{}
	// 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).
	EventsLateArrivalMaxDelayInSeconds interface{}
	// 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).
	EventsOutOfOrderMaxDelayInSeconds interface{}
	// 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`.
	EventsOutOfOrderPolicy interface{}
	// The Job ID assigned by the Stream Analytics Job.
	JobId interface{}
	// The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
	Location interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	Name interface{}
	// 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`.
	OutputErrorPolicy interface{}
	// The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// 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 interface{}
	// A mapping of tags assigned to the resource.
	Tags interface{}
	// 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 interface{}
}

Input properties used for looking up and filtering Job resources.

type OutputBlob 

type OutputBlob struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Output to Blob Storage.

func GetOutputBlob 

func GetOutputBlob(ctx *pulumi.Context,
	name string, id pulumi.ID, state *OutputBlobState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*OutputBlob, error)

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

func (*OutputBlob) DateFormat 

func (r *OutputBlob) DateFormat() *pulumi.StringOutput

The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.

func (*OutputBlob) ID 

func (r *OutputBlob) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*OutputBlob) Name 

func (r *OutputBlob) Name() *pulumi.StringOutput

The name of the Stream Output. Changing this forces a new resource to be created.

func (*OutputBlob) PathPattern 

func (r *OutputBlob) PathPattern() *pulumi.StringOutput

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.

func (*OutputBlob) ResourceGroupName 

func (r *OutputBlob) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*OutputBlob) Serialization 

func (r *OutputBlob) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*OutputBlob) StorageAccountKey 

func (r *OutputBlob) StorageAccountKey() *pulumi.StringOutput

The Access Key which should be used to connect to this Storage Account.

func (*OutputBlob) StorageAccountName 

func (r *OutputBlob) StorageAccountName() *pulumi.StringOutput

The name of the Storage Account.

func (*OutputBlob) StorageContainerName 

func (r *OutputBlob) StorageContainerName() *pulumi.StringOutput

The name of the Container within the Storage Account.

func (*OutputBlob) StreamAnalyticsJobName 

func (r *OutputBlob) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*OutputBlob) TimeFormat 

func (r *OutputBlob) TimeFormat() *pulumi.StringOutput

The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.

func (*OutputBlob) URN 

func (r *OutputBlob) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type OutputBlobArgs 

type OutputBlobArgs struct {
	// The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.
	DateFormat interface{}
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name interface{}
	// 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 interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey interface{}
	// The name of the Storage Account.
	StorageAccountName interface{}
	// The name of the Container within the Storage Account.
	StorageContainerName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
	// The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.
	TimeFormat interface{}
}

The set of arguments for constructing a OutputBlob resource.

type OutputBlobState 

type OutputBlobState struct {
	// The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.
	DateFormat interface{}
	// The name of the Stream Output. Changing this forces a new resource to be created.
	Name interface{}
	// 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 interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey interface{}
	// The name of the Storage Account.
	StorageAccountName interface{}
	// The name of the Container within the Storage Account.
	StorageContainerName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
	// The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.
	TimeFormat interface{}
}

Input properties used for looking up and filtering OutputBlob resources.

type OutputEventHub 

type OutputEventHub struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Output to an EventHub.

func GetOutputEventHub 

func GetOutputEventHub(ctx *pulumi.Context,
	name string, id pulumi.ID, state *OutputEventHubState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*OutputEventHub, error)

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

func (*OutputEventHub) EventhubName 

func (r *OutputEventHub) EventhubName() *pulumi.StringOutput

The name of the Event Hub.

func (*OutputEventHub) ID 

func (r *OutputEventHub) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*OutputEventHub) Name 

func (r *OutputEventHub) Name() *pulumi.StringOutput

The name of the Stream Output. Changing this forces a new resource to be created.

func (*OutputEventHub) ResourceGroupName 

func (r *OutputEventHub) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*OutputEventHub) Serialization 

func (r *OutputEventHub) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*OutputEventHub) ServicebusNamespace 

func (r *OutputEventHub) ServicebusNamespace() *pulumi.StringOutput

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*OutputEventHub) SharedAccessPolicyKey 

func (r *OutputEventHub) SharedAccessPolicyKey() *pulumi.StringOutput

The shared access policy key for the specified shared access policy.

func (*OutputEventHub) SharedAccessPolicyName 

func (r *OutputEventHub) SharedAccessPolicyName() *pulumi.StringOutput

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*OutputEventHub) StreamAnalyticsJobName 

func (r *OutputEventHub) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*OutputEventHub) URN 

func (r *OutputEventHub) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type OutputEventHubArgs 

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

The set of arguments for constructing a OutputEventHub resource.

type OutputEventHubState 

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

Input properties used for looking up and filtering OutputEventHub resources.

type OutputServiceBusQueue 

type OutputServiceBusQueue struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Output to a ServiceBus Queue.

func GetOutputServiceBusQueue 

func GetOutputServiceBusQueue(ctx *pulumi.Context,
	name string, id pulumi.ID, state *OutputServiceBusQueueState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*OutputServiceBusQueue, error)

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

func (*OutputServiceBusQueue) ID 

func (r *OutputServiceBusQueue) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*OutputServiceBusQueue) Name 

func (r *OutputServiceBusQueue) Name() *pulumi.StringOutput

The name of the Stream Output. Changing this forces a new resource to be created.

func (*OutputServiceBusQueue) QueueName 

func (r *OutputServiceBusQueue) QueueName() *pulumi.StringOutput

The name of the Service Bus Queue.

func (*OutputServiceBusQueue) ResourceGroupName 

func (r *OutputServiceBusQueue) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*OutputServiceBusQueue) Serialization 

func (r *OutputServiceBusQueue) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*OutputServiceBusQueue) ServicebusNamespace 

func (r *OutputServiceBusQueue) ServicebusNamespace() *pulumi.StringOutput

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*OutputServiceBusQueue) SharedAccessPolicyKey 

func (r *OutputServiceBusQueue) SharedAccessPolicyKey() *pulumi.StringOutput

The shared access policy key for the specified shared access policy.

func (*OutputServiceBusQueue) SharedAccessPolicyName 

func (r *OutputServiceBusQueue) SharedAccessPolicyName() *pulumi.StringOutput

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*OutputServiceBusQueue) StreamAnalyticsJobName 

func (r *OutputServiceBusQueue) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*OutputServiceBusQueue) URN 

func (r *OutputServiceBusQueue) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type OutputServiceBusQueueArgs 

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

The set of arguments for constructing a OutputServiceBusQueue resource.

type OutputServiceBusQueueState 

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

Input properties used for looking up and filtering OutputServiceBusQueue resources.

type StreamInputBlob 

type StreamInputBlob struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Stream Input Blob.

func GetStreamInputBlob 

func GetStreamInputBlob(ctx *pulumi.Context,
	name string, id pulumi.ID, state *StreamInputBlobState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*StreamInputBlob, error)

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

func (*StreamInputBlob) DateFormat 

func (r *StreamInputBlob) DateFormat() *pulumi.StringOutput

The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.

func (*StreamInputBlob) ID 

func (r *StreamInputBlob) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*StreamInputBlob) Name 

func (r *StreamInputBlob) Name() *pulumi.StringOutput

The name of the Stream Input Blob. Changing this forces a new resource to be created.

func (*StreamInputBlob) PathPattern 

func (r *StreamInputBlob) PathPattern() *pulumi.StringOutput

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.

func (*StreamInputBlob) ResourceGroupName 

func (r *StreamInputBlob) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*StreamInputBlob) Serialization 

func (r *StreamInputBlob) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*StreamInputBlob) StorageAccountKey 

func (r *StreamInputBlob) StorageAccountKey() *pulumi.StringOutput

The Access Key which should be used to connect to this Storage Account.

func (*StreamInputBlob) StorageAccountName 

func (r *StreamInputBlob) StorageAccountName() *pulumi.StringOutput

The name of the Storage Account.

func (*StreamInputBlob) StorageContainerName 

func (r *StreamInputBlob) StorageContainerName() *pulumi.StringOutput

The name of the Container within the Storage Account.

func (*StreamInputBlob) StreamAnalyticsJobName 

func (r *StreamInputBlob) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*StreamInputBlob) TimeFormat 

func (r *StreamInputBlob) TimeFormat() *pulumi.StringOutput

The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.

func (*StreamInputBlob) URN 

func (r *StreamInputBlob) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type StreamInputBlobArgs 

type StreamInputBlobArgs struct {
	// The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.
	DateFormat interface{}
	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name interface{}
	// 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 interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey interface{}
	// The name of the Storage Account.
	StorageAccountName interface{}
	// The name of the Container within the Storage Account.
	StorageContainerName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
	// The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.
	TimeFormat interface{}
}

The set of arguments for constructing a StreamInputBlob resource.

type StreamInputBlobState 

type StreamInputBlobState struct {
	// The date format. Wherever `{date}` appears in `path_pattern`, the value of this property is used as the date format instead.
	DateFormat interface{}
	// The name of the Stream Input Blob. Changing this forces a new resource to be created.
	Name interface{}
	// 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 interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The Access Key which should be used to connect to this Storage Account.
	StorageAccountKey interface{}
	// The name of the Storage Account.
	StorageAccountName interface{}
	// The name of the Container within the Storage Account.
	StorageContainerName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
	// The time format. Wherever `{time}` appears in `path_pattern`, the value of this property is used as the time format instead.
	TimeFormat interface{}
}

Input properties used for looking up and filtering StreamInputBlob resources.

type StreamInputEventHub 

type StreamInputEventHub struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Stream Input EventHub.

func GetStreamInputEventHub 

func GetStreamInputEventHub(ctx *pulumi.Context,
	name string, id pulumi.ID, state *StreamInputEventHubState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*StreamInputEventHub, error)

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

func (*StreamInputEventHub) EventhubConsumerGroupName 

func (r *StreamInputEventHub) EventhubConsumerGroupName() *pulumi.StringOutput

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.

func (*StreamInputEventHub) EventhubName 

func (r *StreamInputEventHub) EventhubName() *pulumi.StringOutput

The name of the Event Hub.

func (*StreamInputEventHub) ID 

func (r *StreamInputEventHub) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*StreamInputEventHub) Name 

func (r *StreamInputEventHub) Name() *pulumi.StringOutput

The name of the Stream Input EventHub. Changing this forces a new resource to be created.

func (*StreamInputEventHub) ResourceGroupName 

func (r *StreamInputEventHub) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*StreamInputEventHub) Serialization 

func (r *StreamInputEventHub) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*StreamInputEventHub) ServicebusNamespace 

func (r *StreamInputEventHub) ServicebusNamespace() *pulumi.StringOutput

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*StreamInputEventHub) SharedAccessPolicyKey 

func (r *StreamInputEventHub) SharedAccessPolicyKey() *pulumi.StringOutput

The shared access policy key for the specified shared access policy.

func (*StreamInputEventHub) SharedAccessPolicyName 

func (r *StreamInputEventHub) SharedAccessPolicyName() *pulumi.StringOutput

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*StreamInputEventHub) StreamAnalyticsJobName 

func (r *StreamInputEventHub) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*StreamInputEventHub) URN 

func (r *StreamInputEventHub) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

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 interface{}
	// The name of the Event Hub.
	EventhubName interface{}
	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace interface{}
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey interface{}
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
}

The set of arguments for constructing a StreamInputEventHub resource.

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 interface{}
	// The name of the Event Hub.
	EventhubName interface{}
	// The name of the Stream Input EventHub. Changing this forces a new resource to be created.
	Name interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
	ServicebusNamespace interface{}
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey interface{}
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
}

Input properties used for looking up and filtering StreamInputEventHub resources.

type StreamInputIotHub 

type StreamInputIotHub struct {
	// contains filtered or unexported fields
}

Manages a Stream Analytics Stream Input IoTHub.

func GetStreamInputIotHub 

func GetStreamInputIotHub(ctx *pulumi.Context,
	name string, id pulumi.ID, state *StreamInputIotHubState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*StreamInputIotHub, error)

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

func (*StreamInputIotHub) Endpoint 

func (r *StreamInputIotHub) Endpoint() *pulumi.StringOutput

The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

func (*StreamInputIotHub) EventhubConsumerGroupName 

func (r *StreamInputIotHub) EventhubConsumerGroupName() *pulumi.StringOutput

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.

func (*StreamInputIotHub) ID 

func (r *StreamInputIotHub) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*StreamInputIotHub) IothubNamespace 

func (r *StreamInputIotHub) IothubNamespace() *pulumi.StringOutput

The name or the URI of the IoT Hub.

func (*StreamInputIotHub) Name 

func (r *StreamInputIotHub) Name() *pulumi.StringOutput

The name of the Stream Input IoTHub. Changing this forces a new resource to be created.

func (*StreamInputIotHub) ResourceGroupName 

func (r *StreamInputIotHub) ResourceGroupName() *pulumi.StringOutput

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

func (*StreamInputIotHub) Serialization 

func (r *StreamInputIotHub) Serialization() *pulumi.Output

A `serialization` block as defined below.

func (*StreamInputIotHub) SharedAccessPolicyKey 

func (r *StreamInputIotHub) SharedAccessPolicyKey() *pulumi.StringOutput

The shared access policy key for the specified shared access policy.

func (*StreamInputIotHub) SharedAccessPolicyName 

func (r *StreamInputIotHub) SharedAccessPolicyName() *pulumi.StringOutput

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

func (*StreamInputIotHub) StreamAnalyticsJobName 

func (r *StreamInputIotHub) StreamAnalyticsJobName() *pulumi.StringOutput

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

func (*StreamInputIotHub) URN 

func (r *StreamInputIotHub) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type StreamInputIotHubArgs 

type StreamInputIotHubArgs struct {
	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint interface{}
	// 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 interface{}
	// The name or the URI of the IoT Hub.
	IothubNamespace interface{}
	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey interface{}
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
}

The set of arguments for constructing a StreamInputIotHub resource.

type StreamInputIotHubState 

type StreamInputIotHubState struct {
	// The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
	Endpoint interface{}
	// 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 interface{}
	// The name or the URI of the IoT Hub.
	IothubNamespace interface{}
	// The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
	Name interface{}
	// The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
	ResourceGroupName interface{}
	// A `serialization` block as defined below.
	Serialization interface{}
	// The shared access policy key for the specified shared access policy.
	SharedAccessPolicyKey interface{}
	// The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
	SharedAccessPolicyName interface{}
	// The name of the Stream Analytics Job. Changing this forces a new resource to be created.
	StreamAnalyticsJobName interface{}
}

Input properties used for looking up and filtering StreamInputIotHub resources.

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.