pspulumiyaml.azurenative.streamanalytics.psm1
|
using module pspulumiyaml function Invoke-AzureNativeFunctionStreamanalyticsGetOutput { param ( [parameter(mandatory=$False,HelpMessage='The name of the output.)')] [string] $outputName, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["jobName"] = $jobName $arguments["outputName"] = $outputName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getOutput -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsGetInput { param ( [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the input.)')] [string] $inputName ) process { $arguments = @{} $arguments["inputName"] = $inputName $arguments["jobName"] = $jobName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getInput -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsListClusterStreamingJobs { param ( [parameter(mandatory=$False,HelpMessage='The name of the cluster.)')] [string] $clusterName, [parameter(mandatory=$False,HelpMessage='The name of the resource group. The name is case insensitive.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["clusterName"] = $clusterName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:listClusterStreamingJobs -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsGetStreamingJob { param ( [parameter(mandatory=$False,HelpMessage='The $expand OData query parameter. This is a comma-separated list of additional streaming job properties to include in the response, beyond the default set returned when this parameter is absent. The default set is all streaming job properties other than ''inputs'', ''transformation'', ''outputs'', and ''functions''.)')] [string] $expand, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["jobName"] = $jobName $arguments["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'expand') { $arguments["expand"] = $expand } $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getStreamingJob -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsGetCluster { param ( [parameter(mandatory=$False,HelpMessage='The name of the cluster.)')] [string] $clusterName, [parameter(mandatory=$False,HelpMessage='The name of the resource group. The name is case insensitive.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["clusterName"] = $clusterName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getCluster -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsGetPrivateEndpoint { param ( [parameter(mandatory=$False,HelpMessage='The name of the private endpoint.)')] [string] $privateEndpointName, [parameter(mandatory=$False,HelpMessage='The name of the cluster.)')] [string] $clusterName, [parameter(mandatory=$False,HelpMessage='The name of the resource group. The name is case insensitive.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["clusterName"] = $clusterName $arguments["privateEndpointName"] = $privateEndpointName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getPrivateEndpoint -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } function Invoke-AzureNativeFunctionStreamanalyticsGetFunction { param ( [parameter(mandatory=$False,HelpMessage='The name of the function.)')] [string] $functionName, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName ) process { $arguments = @{} $arguments["functionName"] = $functionName $arguments["jobName"] = $jobName $arguments["resourceGroupName"] = $resourceGroupName $functionObject = Invoke-PulumiFunction -Name azure-native:streamanalytics:getFunction -variableName $([guid]::NewGuid().Guid) -Arguments $arguments return $functionObject } } class JsonSerialization { [ArgumentCompletions('LineSeparated', 'Array')] [string] $format [ArgumentCompletions('UTF8')] [string] $encoding [string] $type } function New-AzureNativeTypeStreamanalyticsJsonSerialization { param ( [parameter(mandatory=$False,HelpMessage='This property only applies to JSON serialization of outputs only. It is not applicable to inputs. This property specifies the format of the JSON the output will be written in. The currently supported values are ''lineSeparated'' indicating the output will be formatted by having each JSON object separated by a new line and ''array'' indicating the output will be formatted as an array of JSON objects. Default value is ''lineSeparated'' if left null.)')] [string] [ValidateSet('LineSeparated', 'Array')] $format, [parameter(mandatory=$False,HelpMessage='Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.)')] [string] [ValidateSet('UTF8')] $encoding, [parameter(mandatory=$False,HelpMessage='Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests. Expected value is ''Json''.)')] [string] $type ) process { return $([JsonSerialization]$PSBoundParameters) } } class ServiceBusTopicOutputDataSource { [string] $type [string] $serviceBusNamespace [string[]] $propertyColumns [string] $sharedAccessPolicyKey [string] $sharedAccessPolicyName [string] $topicName } function New-AzureNativeTypeStreamanalyticsServiceBusTopicOutputDataSource { param ( [parameter(mandatory=$False,HelpMessage='Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests. Expected value is ''Microsoft.ServiceBus/Topic''.)')] [string] $type, [parameter(mandatory=$False,HelpMessage='The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.)')] [string] $serviceBusNamespace, [parameter(mandatory=$False,HelpMessage='A string array of the names of output columns to be attached to Service Bus messages as custom properties.)')] [string[]] $propertyColumns, [parameter(mandatory=$False,HelpMessage='The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.)')] [string] $sharedAccessPolicyKey, [parameter(mandatory=$False,HelpMessage='The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.)')] [string] $sharedAccessPolicyName, [parameter(mandatory=$False,HelpMessage='The name of the Service Bus Topic. Required on PUT (CreateOrReplace) requests.)')] [string] $topicName ) process { return $([ServiceBusTopicOutputDataSource]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsOutput { [Alias('azure_native_streamanalytics_output')] param ( [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName, [parameter(mandatory=$False,HelpMessage='The name of the output.)')] [string] $outputName, [parameter(mandatory=$False,HelpMessage='Resource name)')] [string] $name, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.)')] [JsonSerialization] $serialization, [parameter(mandatory=$False,HelpMessage='Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.)')] [ServiceBusTopicOutputDataSource] $datasource, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:Output") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["jobName"] = $jobName $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'outputName') { $resource.properties["outputName"] = $outputName } if($PSBoundParameters.Keys -icontains 'name') { $resource.properties["name"] = $name } if($PSBoundParameters.Keys -icontains 'serialization') { $resource.properties["serialization"] = $serialization } if($PSBoundParameters.Keys -icontains 'datasource') { $resource.properties["datasource"] = $datasource } $global:pulumiresources += $resource return $resource } } class ClusterSku { [int] $capacity [ArgumentCompletions('Default')] [string] $name } function New-AzureNativeTypeStreamanalyticsClusterSku { param ( [parameter(mandatory=$False,HelpMessage='Denotes the number of streaming units the cluster can support. Valid values for this property are multiples of 36 with a minimum value of 36 and maximum value of 216. Required on PUT (CreateOrUpdate) requests.)')] [int] $capacity, [parameter(mandatory=$False,HelpMessage='Specifies the SKU name of the cluster. Required on PUT (CreateOrUpdate) requests.)')] [string] [ValidateSet('Default')] $name ) process { return $([ClusterSku]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsCluster { [Alias('azure_native_streamanalytics_cluster')] param ( [parameter(mandatory=$False,HelpMessage='The geo-location where the resource lives)')] [string] $location, [parameter(mandatory=$False,HelpMessage='Resource tags.)')] [hashtable] $tags, [parameter(mandatory=$False,HelpMessage='The SKU of the cluster. This determines the size/capacity of the cluster. Required on PUT (CreateOrUpdate) requests.)')] [ClusterSku] $sku, [parameter(mandatory=$False,HelpMessage='The name of the cluster.)')] [string] $clusterName, [parameter(mandatory=$False,HelpMessage='The name of the resource group. The name is case insensitive.)')] [string] $resourceGroupName, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:Cluster") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'location') { $resource.properties["location"] = $location } if($PSBoundParameters.Keys -icontains 'tags') { $resource.properties["tags"] = $tags } if($PSBoundParameters.Keys -icontains 'sku') { $resource.properties["sku"] = $sku } if($PSBoundParameters.Keys -icontains 'clusterName') { $resource.properties["clusterName"] = $clusterName } $global:pulumiresources += $resource return $resource } } class PrivateLinkServiceConnection { [string[]] $groupIds [string] $privateLinkServiceId } function New-AzureNativeTypeStreamanalyticsPrivateLinkServiceConnection { param ( [parameter(mandatory=$False,HelpMessage='The ID(s) of the group(s) obtained from the remote resource that this private endpoint should connect to. Required on PUT (CreateOrUpdate) requests.)')] [string[]] $groupIds, [parameter(mandatory=$False,HelpMessage='The resource id of the private link service. Required on PUT (CreateOrUpdate) requests.)')] [string] $privateLinkServiceId ) process { return $([PrivateLinkServiceConnection]$PSBoundParameters) } } class PrivateEndpointProperties { [PrivateLinkServiceConnection[]] $manualPrivateLinkServiceConnections } function New-AzureNativeTypeStreamanalyticsPrivateEndpointProperties { param ( [parameter(mandatory=$False,HelpMessage='A list of connections to the remote resource. Immutable after it is set.)')] $manualPrivateLinkServiceConnections ) process { return $([PrivateEndpointProperties]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsPrivateEndpoint { [Alias('azure_native_streamanalytics_privateendpoint')] param ( [parameter(mandatory=$False,HelpMessage='The properties associated with a private endpoint.)')] [PrivateEndpointProperties] $properties, [parameter(mandatory=$False,HelpMessage='The name of the private endpoint.)')] [string] $privateEndpointName, [parameter(mandatory=$False,HelpMessage='The name of the cluster.)')] [string] $clusterName, [parameter(mandatory=$False,HelpMessage='The name of the resource group. The name is case insensitive.)')] [string] $resourceGroupName, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:PrivateEndpoint") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["clusterName"] = $clusterName $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'properties') { $resource.properties["properties"] = $properties } if($PSBoundParameters.Keys -icontains 'privateEndpointName') { $resource.properties["privateEndpointName"] = $privateEndpointName } $global:pulumiresources += $resource return $resource } } class StreamInputProperties { [string] $type [object] $datasource #todo add class here [object] $serialization #todo add class here } class IoTHubStreamInputDataSource { [string] $type [string] $consumerGroupName [string] $endpoint [string] $iotHubNamespace [string] $sharedAccessPolicyKey [string] $sharedAccessPolicyName } function New-AzureNativeTypeStreamanalyticsIoTHubStreamInputDataSource { param ( [parameter(mandatory=$False,HelpMessage='Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests. Expected value is ''Microsoft.Devices/IotHubs''.)')] [string] $type, [parameter(mandatory=$False,HelpMessage='The name of an IoT Hub Consumer Group that should be used to read events from the IoT Hub. If not specified, the input uses the Iot Hub''s default consumer group.)')] [string] $consumerGroupName, [parameter(mandatory=$False,HelpMessage='The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).)')] [string] $endpoint, [parameter(mandatory=$False,HelpMessage='The name or the URI of the IoT Hub. Required on PUT (CreateOrReplace) requests.)')] [string] $iotHubNamespace, [parameter(mandatory=$False,HelpMessage='The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.)')] [string] $sharedAccessPolicyKey, [parameter(mandatory=$False,HelpMessage='The shared access policy name for the IoT Hub. This policy must contain at least the Service connect permission. Required on PUT (CreateOrReplace) requests.)')] [string] $sharedAccessPolicyName ) process { return $([IoTHubStreamInputDataSource]$PSBoundParameters) } } function New-AzureNativeTypeStreamanalyticsStreamInputProperties { param ( [parameter(mandatory=$False,HelpMessage='Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests. Expected value is ''Stream''.)')] [string] $type, [parameter(mandatory=$False,HelpMessage='Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests.)')] [IoTHubStreamInputDataSource] $datasource, [parameter(mandatory=$False,HelpMessage='Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.)')] [JsonSerialization] $serialization ) process { return $([StreamInputProperties]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsInput { [Alias('azure_native_streamanalytics_input')] param ( [parameter(mandatory=$False,HelpMessage='The properties that are associated with an input. Required on PUT (CreateOrReplace) requests.)')] [StreamInputProperties] $properties, [parameter(mandatory=$False,HelpMessage='Resource name)')] [string] $name, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the input.)')] [string] $inputName, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:Input") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["jobName"] = $jobName $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'properties') { $resource.properties["properties"] = $properties } if($PSBoundParameters.Keys -icontains 'name') { $resource.properties["name"] = $name } if($PSBoundParameters.Keys -icontains 'inputName') { $resource.properties["inputName"] = $inputName } $global:pulumiresources += $resource return $resource } } class Sku { [ArgumentCompletions('Standard')] [string] $name } function New-AzureNativeTypeStreamanalyticsSku { param ( [parameter(mandatory=$False,HelpMessage='The name of the SKU. Required on PUT (CreateOrReplace) requests.)')] [string] [ValidateSet('Standard')] $name ) process { return $([Sku]$PSBoundParameters) } } class Transformation { [string] $query [string] $name [int] $streamingUnits } function New-AzureNativeTypeStreamanalyticsTransformation { param ( [parameter(mandatory=$False,HelpMessage='Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests.)')] [string] $query, [parameter(mandatory=$False,HelpMessage='Resource name)')] [string] $name, [parameter(mandatory=$False,HelpMessage='Specifies the number of streaming units that the streaming job uses.)')] [int] $streamingUnits ) process { return $([Transformation]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsStreamingJob { [Alias('azure_native_streamanalytics_streamingjob')] param ( [parameter(mandatory=$False,HelpMessage='A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.)')] $outputs, [parameter(mandatory=$False,HelpMessage='Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).)')] [string] [ValidateSet('Stop', 'Drop')] $outputErrorPolicy, [parameter(mandatory=$False,HelpMessage='The geo-location where the resource lives)')] [string] $location, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.)')] $inputs, [parameter(mandatory=$False,HelpMessage='Resource tags.)')] [hashtable] $tags, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName, [parameter(mandatory=$False,HelpMessage='This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time.)')] [string] [ValidateSet('JobStartTime', 'CustomTime', 'LastOutputEventTime')] $outputStartMode, [parameter(mandatory=$False,HelpMessage='A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.)')] $functions, [parameter(mandatory=$False,HelpMessage='Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.)')] [string] $outputStartTime, [parameter(mandatory=$False,HelpMessage='The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.)')] [int] $eventsOutOfOrderMaxDelayInSeconds, [parameter(mandatory=$False,HelpMessage='The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to ''en-US'' if none specified.)')] [string] $dataLocale, [parameter(mandatory=$False,HelpMessage='The maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.)')] [int] $eventsLateArrivalMaxDelayInSeconds, [parameter(mandatory=$False,HelpMessage='Controls certain runtime behaviors of the streaming job.)')] [string] [ValidateSet('1.0')] $compatibilityLevel, [parameter(mandatory=$False,HelpMessage='Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.)')] [Sku] $sku, [parameter(mandatory=$False,HelpMessage='Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.)')] [Transformation] $transformation, [parameter(mandatory=$False,HelpMessage='Indicates the policy to apply to events that arrive out of order in the input event stream.)')] [string] [ValidateSet('Adjust', 'Drop')] $eventsOutOfOrderPolicy, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:StreamingJob") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'outputs') { $resource.properties["outputs"] = $outputs } if($PSBoundParameters.Keys -icontains 'outputErrorPolicy') { $resource.properties["outputErrorPolicy"] = $outputErrorPolicy } if($PSBoundParameters.Keys -icontains 'location') { $resource.properties["location"] = $location } if($PSBoundParameters.Keys -icontains 'jobName') { $resource.properties["jobName"] = $jobName } if($PSBoundParameters.Keys -icontains 'inputs') { $resource.properties["inputs"] = $inputs } if($PSBoundParameters.Keys -icontains 'tags') { $resource.properties["tags"] = $tags } if($PSBoundParameters.Keys -icontains 'outputStartMode') { $resource.properties["outputStartMode"] = $outputStartMode } if($PSBoundParameters.Keys -icontains 'functions') { $resource.properties["functions"] = $functions } if($PSBoundParameters.Keys -icontains 'outputStartTime') { $resource.properties["outputStartTime"] = $outputStartTime } if($PSBoundParameters.Keys -icontains 'eventsOutOfOrderMaxDelayInSeconds') { $resource.properties["eventsOutOfOrderMaxDelayInSeconds"] = $eventsOutOfOrderMaxDelayInSeconds } if($PSBoundParameters.Keys -icontains 'dataLocale') { $resource.properties["dataLocale"] = $dataLocale } if($PSBoundParameters.Keys -icontains 'eventsLateArrivalMaxDelayInSeconds') { $resource.properties["eventsLateArrivalMaxDelayInSeconds"] = $eventsLateArrivalMaxDelayInSeconds } if($PSBoundParameters.Keys -icontains 'compatibilityLevel') { $resource.properties["compatibilityLevel"] = $compatibilityLevel } if($PSBoundParameters.Keys -icontains 'sku') { $resource.properties["sku"] = $sku } if($PSBoundParameters.Keys -icontains 'transformation') { $resource.properties["transformation"] = $transformation } if($PSBoundParameters.Keys -icontains 'eventsOutOfOrderPolicy') { $resource.properties["eventsOutOfOrderPolicy"] = $eventsOutOfOrderPolicy } $global:pulumiresources += $resource return $resource } } class FunctionInput { [string] $dataType [bool] $isConfigurationParameter } function New-AzureNativeTypeStreamanalyticsFunctionInput { param ( [parameter(mandatory=$False,HelpMessage='The (Azure Stream Analytics supported) data type of the function input parameter. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx)')] [string] $dataType, [parameter(mandatory=$False,HelpMessage='A flag indicating if the parameter is a configuration parameter. True if this input parameter is expected to be a constant. Default is false.)')] [bool] $isConfigurationParameter ) process { return $([FunctionInput]$PSBoundParameters) } } class FunctionOutput { [string] $dataType } function New-AzureNativeTypeStreamanalyticsFunctionOutput { param ( [parameter(mandatory=$False,HelpMessage='The (Azure Stream Analytics supported) data type of the function output. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx)')] [string] $dataType ) process { return $([FunctionOutput]$PSBoundParameters) } } class ScalarFunctionProperties { [FunctionInput[]] $inputs [string] $type [object] $binding #todo add class here [FunctionOutput] $output } class JavaScriptFunctionBinding { [string] $script [string] $type } function New-AzureNativeTypeStreamanalyticsJavaScriptFunctionBinding { param ( [parameter(mandatory=$False,HelpMessage='The JavaScript code containing a single function definition. For example: ''function (x, y) { return x + y; }'')')] [string] $script, [parameter(mandatory=$False,HelpMessage='Indicates the function binding type. Expected value is ''Microsoft.StreamAnalytics/JavascriptUdf''.)')] [string] $type ) process { return $([JavaScriptFunctionBinding]$PSBoundParameters) } } function New-AzureNativeTypeStreamanalyticsScalarFunctionProperties { param ( [parameter(mandatory=$False,HelpMessage='A list of inputs describing the parameters of the function.)')] $inputs, [parameter(mandatory=$False,HelpMessage='Indicates the type of function. Expected value is ''Scalar''.)')] [string] $type, [parameter(mandatory=$False,HelpMessage='The physical binding of the function. For example, in the Azure Machine Learning web service''s case, this describes the endpoint.)')] [JavaScriptFunctionBinding] $binding, [parameter(mandatory=$False,HelpMessage='The output of the function.)')] [FunctionOutput] $output ) process { return $([ScalarFunctionProperties]$PSBoundParameters) } } function New-AzureNativeStreamanalyticsFunction { [Alias('azure_native_streamanalytics_function')] param ( [parameter(mandatory=$False,HelpMessage='The properties that are associated with a function.)')] [ScalarFunctionProperties] $properties, [parameter(mandatory=$False,HelpMessage='The name of the function.)')] [string] $functionName, [parameter(mandatory=$False,HelpMessage='Resource name)')] [string] $name, [parameter(mandatory=$False,HelpMessage='The name of the streaming job.)')] [string] $jobName, [parameter(mandatory=$False,HelpMessage='The name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal.)')] [string] $resourceGroupName, [parameter(mandatory,HelpMessage='The reference to call when you want to make a dependency to another resource')] [string] $pulumiid, [parameter(mandatory,HelpMessage='Pass in the resources you make to make this resource dependant on')] [object] $DependsOn ) process { $resource = [pulumiresource]::new($pulumiid, "azure-native:streamanalytics:Function") foreach($Dependency in $DependsOn) { if($Dependency -is [pulumiresource]) { $resource.dependson += $Dependency.Reference() } else { $resource.dependson += $Dependency } } $resource.properties["jobName"] = $jobName $resource.properties["resourceGroupName"] = $resourceGroupName if($PSBoundParameters.Keys -icontains 'properties') { $resource.properties["properties"] = $properties } if($PSBoundParameters.Keys -icontains 'functionName') { $resource.properties["functionName"] = $functionName } if($PSBoundParameters.Keys -icontains 'name') { $resource.properties["name"] = $name } $global:pulumiresources += $resource return $resource } } |