-
Notifications
You must be signed in to change notification settings - Fork 4.5k
/
EventHubStreamInputDataSource.cs
59 lines (54 loc) · 4.68 KB
/
EventHubStreamInputDataSource.cs
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
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// <auto-generated/>
#nullable disable
namespace Azure.ResourceManager.StreamAnalytics.Models
{
/// <summary> Describes an Event Hub input data source that contains stream data. </summary>
public partial class EventHubStreamInputDataSource : StreamInputDataSource
{
/// <summary> Initializes a new instance of EventHubStreamInputDataSource. </summary>
public EventHubStreamInputDataSource()
{
StreamInputDataSourceType = "Microsoft.ServiceBus/EventHub";
}
/// <summary> Initializes a new instance of EventHubStreamInputDataSource. </summary>
/// <param name="streamInputDataSourceType"> Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests. </param>
/// <param name="serviceBusNamespace"> The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests. </param>
/// <param name="sharedAccessPolicyName"> The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests. </param>
/// <param name="sharedAccessPolicyKey"> The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests. </param>
/// <param name="authenticationMode"> Authentication Mode. </param>
/// <param name="eventHubName"> The name of the Event Hub. Required on PUT (CreateOrReplace) requests. </param>
/// <param name="partitionCount"> The partition count of the event hub data source. Range 1 - 256. </param>
/// <param name="consumerGroupName"> 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. If not specified, the input uses the Event Hub’s default consumer group. </param>
/// <param name="prefetchCount"> The number of messages that the message receiver can simultaneously request. </param>
internal EventHubStreamInputDataSource(string streamInputDataSourceType, string serviceBusNamespace, string sharedAccessPolicyName, string sharedAccessPolicyKey, StreamAnalyticsAuthenticationMode? authenticationMode, string eventHubName, int? partitionCount, string consumerGroupName, int? prefetchCount) : base(streamInputDataSourceType)
{
ServiceBusNamespace = serviceBusNamespace;
SharedAccessPolicyName = sharedAccessPolicyName;
SharedAccessPolicyKey = sharedAccessPolicyKey;
AuthenticationMode = authenticationMode;
EventHubName = eventHubName;
PartitionCount = partitionCount;
ConsumerGroupName = consumerGroupName;
PrefetchCount = prefetchCount;
StreamInputDataSourceType = streamInputDataSourceType ?? "Microsoft.ServiceBus/EventHub";
}
/// <summary> The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests. </summary>
public string ServiceBusNamespace { get; set; }
/// <summary> The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests. </summary>
public string SharedAccessPolicyName { get; set; }
/// <summary> The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests. </summary>
public string SharedAccessPolicyKey { get; set; }
/// <summary> Authentication Mode. </summary>
public StreamAnalyticsAuthenticationMode? AuthenticationMode { get; set; }
/// <summary> The name of the Event Hub. Required on PUT (CreateOrReplace) requests. </summary>
public string EventHubName { get; set; }
/// <summary> The partition count of the event hub data source. Range 1 - 256. </summary>
public int? PartitionCount { get; set; }
/// <summary> 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. If not specified, the input uses the Event Hub’s default consumer group. </summary>
public string ConsumerGroupName { get; set; }
/// <summary> The number of messages that the message receiver can simultaneously request. </summary>
public int? PrefetchCount { get; set; }
}
}