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

Package-level declarations

Types

class Cluster : KotlinCustomResource

A Stream Analytics Cluster object Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01.

ClusterArgs

data class ClusterArgs(val clusterName: Output<String>? = null, val location: Output<String>? = null, val resourceGroupName: Output<String>? = null, val sku: Output<ClusterSkuArgs>? = null, val tags: Output<Map<String, String>>? = null) : ConvertibleToJava<ClusterArgs>

A Stream Analytics Cluster object Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01.

ClusterArgsBuilder

class ClusterArgsBuilder

Builder for ClusterArgs.

ClusterMapper

object ClusterMapper : ResourceMapper<Cluster>

ClusterResourceBuilder

class ClusterResourceBuilder

Builder for Cluster.

Function

class Function : KotlinCustomResource

A function object, containing all information associated with the named function. All functions are contained under a streaming job. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01. Other available API versions: 2021-10-01-preview. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native streamanalytics [ApiVersion]. See the ../../../version-guide/#accessing-any-api-version-via-local-packages for details.

FunctionArgs

data class FunctionArgs(val functionName: Output<String>? = null, val jobName: Output<String>? = null, val name: Output<String>? = null, val properties: Output<Either<AggregateFunctionPropertiesArgs, ScalarFunctionPropertiesArgs>>? = null, val resourceGroupName: Output<String>? = null) : ConvertibleToJava<FunctionArgs>

FunctionArgsBuilder

class FunctionArgsBuilder

Builder for FunctionArgs.

FunctionMapper

object FunctionMapper : ResourceMapper<Function>

FunctionResourceBuilder

class FunctionResourceBuilder

Builder for Function.

Input

class Input : KotlinCustomResource

An input object, containing all information associated with the named input. All inputs are contained under a streaming job. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01. Other available API versions: 2021-10-01-preview. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native streamanalytics [ApiVersion]. See the ../../../version-guide/#accessing-any-api-version-via-local-packages for details.

InputArgs

data class InputArgs(val inputName: Output<String>? = null, val jobName: Output<String>? = null, val name: Output<String>? = null, val properties: Output<Either<ReferenceInputPropertiesArgs, StreamInputPropertiesArgs>>? = null, val resourceGroupName: Output<String>? = null) : ConvertibleToJava<InputArgs>

InputArgsBuilder

class InputArgsBuilder

Builder for InputArgs.

InputMapper

object InputMapper : ResourceMapper<Input>

InputResourceBuilder

class InputResourceBuilder

Builder for Input.

Output

class Output : KotlinCustomResource

An output object, containing all information associated with the named output. All outputs are contained under a streaming job. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01. Other available API versions: 2021-10-01-preview. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native streamanalytics [ApiVersion]. See the ../../../version-guide/#accessing-any-api-version-via-local-packages for details.

OutputArgs

data class OutputArgs(val datasource: Output<Any>? = null, val jobName: Output<String>? = null, val name: Output<String>? = null, val outputName: Output<String>? = null, val resourceGroupName: Output<String>? = null, val serialization: Output<Any>? = null, val sizeWindow: Output<Int>? = null, val timeWindow: Output<String>? = null) : ConvertibleToJava<OutputArgs>

OutputArgsBuilder

class OutputArgsBuilder

Builder for OutputArgs.

OutputMapper

object OutputMapper : ResourceMapper<Output>

OutputResourceBuilder

class OutputResourceBuilder

Builder for Output.

PrivateEndpoint

class PrivateEndpoint : KotlinCustomResource

Complete information about the private endpoint. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01.

PrivateEndpointArgs

data class PrivateEndpointArgs(val clusterName: Output<String>? = null, val manualPrivateLinkServiceConnections: Output<List<PrivateLinkServiceConnectionArgs>>? = null, val privateEndpointName: Output<String>? = null, val resourceGroupName: Output<String>? = null) : ConvertibleToJava<PrivateEndpointArgs>

Complete information about the private endpoint. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01.

PrivateEndpointArgsBuilder

class PrivateEndpointArgsBuilder

Builder for PrivateEndpointArgs.

PrivateEndpointMapper

object PrivateEndpointMapper : ResourceMapper<PrivateEndpoint>

PrivateEndpointResourceBuilder

class PrivateEndpointResourceBuilder

Builder for PrivateEndpoint.

StreamanalyticsFunctions

object StreamanalyticsFunctions

StreamingJob

class StreamingJob : KotlinCustomResource

A streaming job object, containing all information associated with the named streaming job. Uses Azure REST API version 2020-03-01. In version 2.x of the Azure Native provider, it used API version 2020-03-01. Other available API versions: 2021-10-01-preview. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native streamanalytics [ApiVersion]. See the ../../../version-guide/#accessing-any-api-version-via-local-packages for details.

StreamingJobArgs

data class StreamingJobArgs(val cluster: Output<ClusterInfoArgs>? = null, val compatibilityLevel: Output<Either<String, CompatibilityLevel>>? = null, val contentStoragePolicy: Output<Either<String, ContentStoragePolicy>>? = null, val dataLocale: Output<String>? = null, val eventsLateArrivalMaxDelayInSeconds: Output<Int>? = null, val eventsOutOfOrderMaxDelayInSeconds: Output<Int>? = null, val eventsOutOfOrderPolicy: Output<Either<String, EventsOutOfOrderPolicy>>? = null, val functions: Output<List<FunctionArgs>>? = null, val identity: Output<IdentityArgs>? = null, val inputs: Output<List<InputArgs>>? = null, val jobName: Output<String>? = null, val jobStorageAccount: Output<JobStorageAccountArgs>? = null, val jobType: Output<Either<String, JobType>>? = null, val location: Output<String>? = null, val outputErrorPolicy: Output<Either<String, OutputErrorPolicy>>? = null, val outputStartMode: Output<Either<String, OutputStartMode>>? = null, val outputStartTime: Output<String>? = null, val outputs: Output<List<OutputArgs>>? = null, val resourceGroupName: Output<String>? = null, val sku: Output<SkuArgs>? = null, val tags: Output<Map<String, String>>? = null, val transformation: Output<TransformationArgs>? = null) : ConvertibleToJava<StreamingJobArgs>

StreamingJobArgsBuilder

class StreamingJobArgsBuilder

Builder for StreamingJobArgs.

StreamingJobMapper

object StreamingJobMapper : ResourceMapper<StreamingJob>

StreamingJobResourceBuilder

class StreamingJobResourceBuilder

Builder for StreamingJob.

Functions

cluster

fun cluster(name: String): Cluster

suspend fun cluster(name: String, block: suspend ClusterResourceBuilder.() -> Unit): Cluster

function

fun function(name: String): Function

suspend fun function(name: String, block: suspend FunctionResourceBuilder.() -> Unit): Function

input

fun input(name: String): Input

suspend fun input(name: String, block: suspend InputResourceBuilder.() -> Unit): Input

output

fun output(name: String): Output

suspend fun output(name: String, block: suspend OutputResourceBuilder.() -> Unit): Output

privateEndpoint

fun privateEndpoint(name: String): PrivateEndpoint

suspend fun privateEndpoint(name: String, block: suspend PrivateEndpointResourceBuilder.() -> Unit): PrivateEndpoint

streamingJob

fun streamingJob(name: String): StreamingJob

suspend fun streamingJob(name: String, block: suspend StreamingJobResourceBuilder.() -> Unit): StreamingJob