/
getJob.go
79 lines (74 loc) · 3.14 KB
/
getJob.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. ***
// *** Do not edit by hand unless you're certain you know what you are doing! ***
package streamanalytics
import (
"github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
// 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
// })
// }
// ```
func LookupJob(ctx *pulumi.Context, args *LookupJobArgs, opts ...pulumi.InvokeOption) (*LookupJobResult, error) {
var rv LookupJobResult
err := ctx.Invoke("azure:streamanalytics/getJob:getJob", args, &rv, opts...)
if err != nil {
return nil, err
}
return &rv, nil
}
// A collection of arguments for invoking getJob.
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 values returned by getJob.
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"`
}