Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

azure-arm-eventhub

Package Overview
Dependencies
Maintainers
1
Versions
11
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

azure-arm-eventhub - npm Package Compare versions

Comparing version 1.0.0-preview to 1.1.0-preview

lib/models/accessKeys.js

10

lib/eventHubManagementClient.d.ts

@@ -11,6 +11,7 @@ /*

import { ServiceClientOptions, RequestOptions, ServiceCallback, HttpOperationResponse, ServiceClientCredentials } from 'ms-rest';
import { ServiceClientCredentials } from 'ms-rest';
import { AzureServiceClient, AzureServiceClientOptions } from 'ms-rest-azure';
import * as operations from "./operations";
declare class EventHubManagementClient {
declare class EventHubManagementClient extends AzureServiceClient {
/**

@@ -36,4 +37,2 @@ * Initializes a new instance of the EventHubManagementClient class.

*
* @param {string} [options.apiVersion] - Client API Version.
*
* @param {string} [options.acceptLanguage] - Gets or sets the preferred language for the response.

@@ -46,3 +45,3 @@ *

*/
constructor(credentials: ServiceClientCredentials, subscriptionId: string, baseUri?: string, options?: ServiceClientOptions);
constructor(credentials: ServiceClientCredentials, subscriptionId: string, baseUri?: string, options?: AzureServiceClientOptions);

@@ -64,2 +63,3 @@ credentials: ServiceClientCredentials;

namespaces: operations.Namespaces;
disasterRecoveryConfigs: operations.DisasterRecoveryConfigs;
eventHubs: operations.EventHubs;

@@ -66,0 +66,0 @@ consumerGroups: operations.ConsumerGroups;

@@ -25,32 +25,18 @@ /*

/**
* @class
* Initializes a new instance of the EventHubManagementClient class.
* @constructor
*
* @param {credentials} credentials - Credentials needed for the client to connect to Azure.
*
* @param {string} subscriptionId - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call.
*
* @param {string} [baseUri] - The base URI of the service.
*
* @param {object} [options] - The parameter options
*
* @param {Array} [options.filters] - Filters to be added to the request pipeline
*
* @param {object} [options.requestOptions] - Options for the underlying request object
* {@link https://github.com/request/request#requestoptions-callback Options doc}
*
* @param {boolean} [options.noRetryPolicy] - If set to true, turn off default retry policy
*
* @param {string} [options.apiVersion] - Client API Version.
*
* @param {string} [options.acceptLanguage] - Gets or sets the preferred language for the response.
*
* @param {number} [options.longRunningOperationRetryTimeout] - Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30.
*
* @param {boolean} [options.generateClientRequestId] - When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true.
*
*/
/** Class representing a EventHubManagementClient. */
class EventHubManagementClient extends ServiceClient {
/**
* Create a EventHubManagementClient.
* @param {credentials} credentials - Credentials needed for the client to connect to Azure.
* @param {string} subscriptionId - Subscription credentials that uniquely identify a Microsoft Azure subscription. The subscription ID forms part of the URI for every service call.
* @param {string} [baseUri] - The base URI of the service.
* @param {object} [options] - The parameter options
* @param {Array} [options.filters] - Filters to be added to the request pipeline
* @param {object} [options.requestOptions] - Options for the underlying request object
* {@link https://github.com/request/request#requestoptions-callback Options doc}
* @param {boolean} [options.noRetryPolicy] - If set to true, turn off default retry policy
* @param {string} [options.acceptLanguage] - Gets or sets the preferred language for the response.
* @param {number} [options.longRunningOperationRetryTimeout] - Gets or sets the retry timeout in seconds for Long Running Operations. Default value is 30.
* @param {boolean} [options.generateClientRequestId] - When set to true a unique x-ms-client-request-id value is generated and included in each request. Default is true.
*/
constructor(credentials, subscriptionId, baseUri, options) {

@@ -68,3 +54,3 @@ if (credentials === null || credentials === undefined) {

this.apiVersion = '2015-08-01';
this.apiVersion = '2017-04-01';
this.acceptLanguage = 'en-US';

@@ -82,5 +68,2 @@ this.longRunningOperationRetryTimeout = 30;

this.addUserAgentInfo(`${packageInfo.name}/${packageInfo.version}`);
if(options.apiVersion !== null && options.apiVersion !== undefined) {
this.apiVersion = options.apiVersion;
}
if(options.acceptLanguage !== null && options.acceptLanguage !== undefined) {

@@ -97,2 +80,3 @@ this.acceptLanguage = options.acceptLanguage;

this.namespaces = new operations.Namespaces(this);
this.disasterRecoveryConfigs = new operations.DisasterRecoveryConfigs(this);
this.eventHubs = new operations.EventHubs(this);

@@ -99,0 +83,0 @@ this.consumerGroups = new operations.ConsumerGroups(this);

@@ -14,19 +14,16 @@ /*

/**
* @class
* Initializes a new instance of the CheckNameAvailabilityResult class.
* @constructor
* Description of a Check Name availability request properties.
* The Result of the CheckNameAvailability operation
*
* @member {boolean} [nameAvailable] Value indicating namespace is
* availability, true if the namespace is available; otherwise, false.
*
* @member {string} [reason] The reason for unavailability of a namespace.
* Possible values include: 'None', 'InvalidName', 'SubscriptionIsDisabled',
* 'NameInUse', 'NameInLockdown', 'TooManyNamespaceInCurrentSubscription'
*
* @member {string} [message] The detailed info regarding the reason associated
* with the namespace.
*
*/
class CheckNameAvailabilityResult {
/**
* Create a CheckNameAvailabilityResult.
* @member {string} [message] The detailed info regarding the reason
* associated with the Namespace.
* @member {boolean} [nameAvailable] Value indicating Namespace is
* availability, true if the Namespace is available; otherwise, false.
* @member {string} [reason] The reason for unavailability of a Namespace.
* Possible values include: 'None', 'InvalidName', 'SubscriptionIsDisabled',
* 'NameInUse', 'NameInLockdown', 'TooManyNamespaceInCurrentSubscription'
*/
constructor() {

@@ -49,2 +46,10 @@ }

modelProperties: {
message: {
required: false,
readOnly: true,
serializedName: 'message',
type: {
name: 'String'
}
},
nameAvailable: {

@@ -64,10 +69,2 @@ required: false,

}
},
message: {
required: false,
readOnly: true,
serializedName: 'message',
type: {
name: 'String'
}
}

@@ -74,0 +71,0 @@ }

@@ -16,20 +16,16 @@ /*

/**
* @class
* Initializes a new instance of the ConsumerGroup class.
* @constructor
* Description of the consumer group resource.
* Single item in List or Get Consumer group operation
*
* @member {date} [createdAt] Exact time the message was created.
*
* @member {string} [eventHubPath] The path of the Event Hub.
*
* @member {date} [updatedAt] The exact time the message was updated.
*
* @member {string} [userMetadata] Usermetadata is a placeholder to store
* user-defined string data with maximum length 1024. e.g. it can be used to
* store descriptive data, such as list of teams and their contact information
* also user-defined configuration settings can be stored.
*
* @extends models['Resource']
*/
class ConsumerGroup extends models['Resource'] {
/**
* Create a ConsumerGroup.
* @member {date} [createdAt] Exact time the message was created.
* @member {date} [updatedAt] The exact time the message was updated.
* @member {string} [userMetadata] Usermetadata is a placeholder to store
* user-defined string data with maximum length 1024. e.g. it can be used to
* store descriptive data, such as list of teams and their contact
* information also user-defined configuration settings can be stored.
*/
constructor() {

@@ -85,10 +81,2 @@ super();

},
eventHubPath: {
required: false,
readOnly: true,
serializedName: 'properties.eventHubPath',
type: {
name: 'String'
}
},
updatedAt: {

@@ -95,0 +83,0 @@ required: false,

@@ -14,12 +14,10 @@ /*

/**
* @class
* Initializes a new instance of the ConsumerGroupListResult class.
* @constructor
* The response to the List Consumer Group operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Consumer Group
*
* The result to the List Consumer Group operation.
*/
class ConsumerGroupListResult extends Array {
/**
* Create a ConsumerGroupListResult.
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Consumer Group
*/
constructor() {

@@ -26,0 +24,0 @@ super();

@@ -14,15 +14,13 @@ /*

/**
* @class
* Initializes a new instance of the ErrorResponse class.
* @constructor
* Error reponse indicates EventHub service is not able to process the incoming
* request. The reason is provided in the error message.
*
* @member {string} [code] Error code.
*
* @member {string} [message] Error message indicating why the operation
* failed.
*
*/
class ErrorResponse {
/**
* Create a ErrorResponse.
* @member {string} [code] Error code.
* @member {string} [message] Error message indicating why the operation
* failed.
*/
constructor() {

@@ -29,0 +27,0 @@ }

@@ -14,12 +14,10 @@ /*

/**
* @class
* Initializes a new instance of the EventHubListResult class.
* @constructor
* The response of the List Event Hubs operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Event Hubs.
*
* The result of the List EventHubs operation.
*/
class EventHubListResult extends Array {
/**
* Create a EventHubListResult.
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of EventHubs.
*/
constructor() {

@@ -50,6 +48,6 @@ super();

required: false,
serializedName: 'EventHubModelElementType',
serializedName: 'EventhubElementType',
type: {
name: 'Composite',
className: 'EventHubModel'
className: 'Eventhub'
}

@@ -56,0 +54,0 @@ }

@@ -13,2 +13,3 @@ /*

import { CloudError } from 'ms-rest-azure';
import * as moment from 'moment';

@@ -21,42 +22,14 @@ export { BaseResource } from 'ms-rest-azure';

* @class
* Initializes a new instance of the OperationDisplay class.
* Initializes a new instance of the Resource class.
* @constructor
* The object that represents the operation.
* The Resource definition
*
* @member {string} [provider] Service provider: Microsoft.EventHub
*
* @member {string} [resource] Resource on which the operation is performed:
* Invoice, etc.
*
* @member {string} [operation] Operation type: Read, write, delete, etc.
*
* @member {string} [id] Resource Id
* @member {string} [name] Resource name
* @member {string} [type] Resource type
*/
export interface OperationDisplay {
readonly provider?: string;
readonly resource?: string;
readonly operation?: string;
}
/**
* @class
* Initializes a new instance of the Operation class.
* @constructor
* A EventHub REST API operation
*
* @member {string} [name] Operation name: {provider}/{resource}/{operation}
*
* @member {object} [display] The object that represents the operation.
*
* @member {string} [display.provider] Service provider: Microsoft.EventHub
*
* @member {string} [display.resource] Resource on which the operation is
* performed: Invoice, etc.
*
* @member {string} [display.operation] Operation type: Read, write, delete,
* etc.
*
*/
export interface Operation {
export interface Resource extends BaseResource {
readonly id?: string;
readonly name?: string;
display?: OperationDisplay;
readonly type?: string;
}

@@ -66,21 +39,2 @@

* @class
* Initializes a new instance of the OperationListResult class.
* @constructor
* Result of the request to list EventHub operations. It contains a list of
* operations and a URL link to get the next set of results.
*
* @member {array} [value] List of EventHub operations supported by the
* Microsoft.EventHub resource provider.
*
* @member {string} [nextLink] URL to get the next set of operation list
* results if there are any.
*
*/
export interface OperationListResult {
readonly value?: Operation[];
readonly nextLink?: string;
}
/**
* @class
* Initializes a new instance of the TrackedResource class.

@@ -90,9 +44,7 @@ * @constructor

*
* @member {string} location Resource location
*
* @member {string} [location] Resource location
* @member {object} [tags] Resource tags
*
*/
export interface TrackedResource extends BaseResource {
location: string;
export interface TrackedResource extends Resource {
location?: string;
tags?: { [propertyName: string]: string };

@@ -103,37 +55,16 @@ }

* @class
* Initializes a new instance of the Resource class.
* @constructor
* The Resource definition
*
* @member {string} [id] Resource Id
*
* @member {string} [name] Resource name
*
* @member {string} [type] Resource type
*
*/
export interface Resource extends BaseResource {
readonly id?: string;
readonly name?: string;
readonly type?: string;
}
/**
* @class
* Initializes a new instance of the Sku class.
* @constructor
* SKU of the namespace.
* SKU parameters supplied to the create namespace operation
*
* @member {string} [name] Name of this SKU. Possible values include: 'Basic',
* @member {string} name Name of this SKU. Possible values include: 'Basic',
* 'Standard'
*
* @member {string} tier The billing tier of this particular SKU. Possible
* values include: 'Basic', 'Standard', 'Premium'
*
* @member {number} [capacity] The EventHubs throughput units.
*
* @member {string} [tier] The billing tier of this particular SKU. Possible
* values include: 'Basic', 'Standard'
* @member {number} [capacity] The Event Hubs throughput units, vaule should be
* 0 to 20 throughput units.
*/
export interface Sku {
name?: string;
tier: string;
name: string;
tier?: string;
capacity?: number;

@@ -144,27 +75,26 @@ }

* @class
* Initializes a new instance of the Namespace class.
* Initializes a new instance of the EHNamespace class.
* @constructor
* Description of a namespace resource.
* Single Namespace item in List or Get Operation
*
* @member {object} [sku]
*
* @member {object} [sku] Properties of sku resource
* @member {string} [sku.name] Name of this SKU. Possible values include:
* 'Basic', 'Standard'
*
* @member {string} [sku.tier] The billing tier of this particular SKU.
* Possible values include: 'Basic', 'Standard', 'Premium'
*
* @member {number} [sku.capacity] The EventHubs throughput units.
*
* @member {string} [provisioningState] Provisioning state of the namespace.
*
* @member {date} [createdAt] The time the namespace was created.
*
* @member {date} [updatedAt] The time the namespace was updated.
*
* Possible values include: 'Basic', 'Standard'
* @member {number} [sku.capacity] The Event Hubs throughput units, vaule
* should be 0 to 20 throughput units.
* @member {string} [provisioningState] Provisioning state of the Namespace.
* @member {date} [createdAt] The time the Namespace was created.
* @member {date} [updatedAt] The time the Namespace was updated.
* @member {string} [serviceBusEndpoint] Endpoint you can use to perform
* Service Bus operations.
*
* @member {string} [metricId] Identifier for Azure Insights metrics.
* @member {boolean} [isAutoInflateEnabled] Value that indicates whether
* AutoInflate is enabled for eventhub namespace.
* @member {number} [maximumThroughputUnits] Upper limit of throughput units
* when AutoInflate is enabled, vaule should be within 0 to 20 throughput
* units. ( '0' if AutoInflateEnabled = true)
*/
export interface Namespace extends TrackedResource {
export interface EHNamespace extends TrackedResource {
sku?: Sku;

@@ -175,2 +105,5 @@ readonly provisioningState?: string;

readonly serviceBusEndpoint?: string;
readonly metricId?: string;
isAutoInflateEnabled?: boolean;
maximumThroughputUnits?: number;
}

@@ -180,15 +113,10 @@

* @class
* Initializes a new instance of the NamespaceListResult class.
* Initializes a new instance of the AuthorizationRule class.
* @constructor
* The response of the List Namespace operation.
* Single item in a List or Get AuthorizationRule operation
*
* @member {array} [value] Result of the List Namespace operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of namespaces.
*
* @member {array} [rights] The rights associated with the rule.
*/
export interface NamespaceListResult {
value?: Namespace[];
nextLink?: string;
export interface AuthorizationRule extends Resource {
rights?: string[];
}

@@ -198,11 +126,28 @@

* @class
* Initializes a new instance of the SharedAccessAuthorizationRule class.
* Initializes a new instance of the AccessKeys class.
* @constructor
* Description of a namespace authorization rule.
* Namespace/EventHub Connection String
*
* @member {array} rights The rights associated with the rule.
*
* @member {string} [primaryConnectionString] Primary connection string of the
* created namespace AuthorizationRule.
* @member {string} [secondaryConnectionString] Secondary connection string of
* the created namespace AuthorizationRule.
* @member {string} [aliasPrimaryConnectionString] Primary connection string of
* the alias if GEO DR is enabled
* @member {string} [aliasSecondaryConnectionString] Secondary connection
* string of the alias if GEO DR is enabled
* @member {string} [primaryKey] A base64-encoded 256-bit primary key for
* signing and validating the SAS token.
* @member {string} [secondaryKey] A base64-encoded 256-bit primary key for
* signing and validating the SAS token.
* @member {string} [keyName] A string that describes the AuthorizationRule.
*/
export interface SharedAccessAuthorizationRule extends Resource {
rights: string[];
export interface AccessKeys {
readonly primaryConnectionString?: string;
readonly secondaryConnectionString?: string;
readonly aliasPrimaryConnectionString?: string;
readonly aliasSecondaryConnectionString?: string;
readonly primaryKey?: string;
readonly secondaryKey?: string;
readonly keyName?: string;
}

@@ -212,15 +157,15 @@

* @class
* Initializes a new instance of the SharedAccessAuthorizationRuleListResult class.
* Initializes a new instance of the RegenerateAccessKeyParameters class.
* @constructor
* The response from the List Namespace operation.
* Parameters supplied to the Regenerate Authorization Rule operation,
* specifies which key neeeds to be reset.
*
* @member {array} [value] Result of the List Authorization Rules operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains an incomplete list of Authorization Rules
*
* @member {string} keyType The access key to regenerate. Possible values
* include: 'PrimaryKey', 'SecondaryKey'
* @member {string} [key] Optional, if the key value provided, is set for
* KeyType or autogenerated Key value set for keyType
*/
export interface SharedAccessAuthorizationRuleListResult {
value?: SharedAccessAuthorizationRule[];
nextLink?: string;
export interface RegenerateAccessKeyParameters {
keyType: string;
key?: string;
}

@@ -230,27 +175,21 @@

* @class
* Initializes a new instance of the ResourceListKeys class.
* Initializes a new instance of the Destination class.
* @constructor
* Namespace/EventHub Connection String
* Capture storage details for capture description
*
* @member {string} [primaryConnectionString] Primary connection string of the
* created namespace authorization rule.
*
* @member {string} [secondaryConnectionString] Secondary connection string of
* the created namespace authorization rule.
*
* @member {string} [primaryKey] A base64-encoded 256-bit primary key for
* signing and validating the SAS token.
*
* @member {string} [secondaryKey] A base64-encoded 256-bit secondary key for
* signing and validating the SAS token.
*
* @member {string} [keyName] A string that describes the authorization rule.
*
* @member {string} [name] Name for capture destination
* @member {string} [storageAccountResourceId] Resource id of the storage
* account to be used to create the blobs
* @member {string} [blobContainer] Blob container Name
* @member {string} [archiveNameFormat] Blob naming convention for archive,
* e.g.
* {Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}.
* Here all the parameters (Namespace,EventHub .. etc) are mandatory
* irrespective of order
*/
export interface ResourceListKeys {
readonly primaryConnectionString?: string;
readonly secondaryConnectionString?: string;
readonly primaryKey?: string;
readonly secondaryKey?: string;
readonly keyName?: string;
export interface Destination {
name?: string;
storageAccountResourceId?: string;
blobContainer?: string;
archiveNameFormat?: string;
}

@@ -260,12 +199,35 @@

* @class
* Initializes a new instance of the RegenerateKeysParameters class.
* Initializes a new instance of the CaptureDescription class.
* @constructor
* Parameters supplied to the Regenerate Authorization Rule operation.
* Properties to configure capture description for eventhub
*
* @member {string} [policykey] Key that needs to be regenerated. Possible
* values include: 'PrimaryKey', 'SecondaryKey'
*
* @member {boolean} [enabled] A value that indicates whether capture
* description is enabled.
* @member {string} [encoding] Enumerates the possible values for the encoding
* format of capture description. Possible values include: 'Avro',
* 'AvroDeflate'
* @member {number} [intervalInSeconds] The time window allows you to set the
* frequency with which the capture to Azure Blobs will happen, value should
* between 60 to 900 seconds
* @member {number} [sizeLimitInBytes] The size window defines the amount of
* data built up in your Event Hub before an capture operation, value should be
* between 10485760 to 524288000 bytes
* @member {object} [destination] Properties of Destination where capture will
* be stored. (Storage Account, Blob Names)
* @member {string} [destination.name] Name for capture destination
* @member {string} [destination.storageAccountResourceId] Resource id of the
* storage account to be used to create the blobs
* @member {string} [destination.blobContainer] Blob container Name
* @member {string} [destination.archiveNameFormat] Blob naming convention for
* archive, e.g.
* {Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}.
* Here all the parameters (Namespace,EventHub .. etc) are mandatory
* irrespective of order
*/
export interface RegenerateKeysParameters {
policykey?: string;
export interface CaptureDescription {
enabled?: boolean;
encoding?: string;
intervalInSeconds?: number;
sizeLimitInBytes?: number;
destination?: Destination;
}

@@ -275,16 +237,13 @@

* @class
* Initializes a new instance of the EventHubModel class.
* Initializes a new instance of the Eventhub class.
* @constructor
* Description of the Event Hub resource.
* Single item in List or Get Event Hub operation
*
* @member {array} [partitionIds] Current number of shards on the Event Hub.
* @member {date} [createdAt] Exact time the Event Hub was created.
*
* @member {date} [updatedAt] The exact time the message was updated.
* @member {number} [messageRetentionInDays] Number of days to retain the
* events for this Event Hub.
*
* events for this Event Hub, value should be 1 to 7 days
* @member {number} [partitionCount] Number of partitions created for the Event
* Hub.
*
* @member {array} [partitionIds] Current number of shards on the Event Hub.
*
* Hub, allowed values are from 1 to 32 partitions.
* @member {string} [status] Enumerates the possible values for the status of

@@ -294,13 +253,36 @@ * the Event Hub. Possible values include: 'Active', 'Disabled', 'Restoring',

* 'Unknown'
*
* @member {date} [updatedAt] The exact time the message was updated.
*
* @member {object} [captureDescription] Properties of capture description
* @member {boolean} [captureDescription.enabled] A value that indicates
* whether capture description is enabled.
* @member {string} [captureDescription.encoding] Enumerates the possible
* values for the encoding format of capture description. Possible values
* include: 'Avro', 'AvroDeflate'
* @member {number} [captureDescription.intervalInSeconds] The time window
* allows you to set the frequency with which the capture to Azure Blobs will
* happen, value should between 60 to 900 seconds
* @member {number} [captureDescription.sizeLimitInBytes] The size window
* defines the amount of data built up in your Event Hub before an capture
* operation, value should be between 10485760 to 524288000 bytes
* @member {object} [captureDescription.destination] Properties of Destination
* where capture will be stored. (Storage Account, Blob Names)
* @member {string} [captureDescription.destination.name] Name for capture
* destination
* @member {string} [captureDescription.destination.storageAccountResourceId]
* Resource id of the storage account to be used to create the blobs
* @member {string} [captureDescription.destination.blobContainer] Blob
* container Name
* @member {string} [captureDescription.destination.archiveNameFormat] Blob
* naming convention for archive, e.g.
* {Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}.
* Here all the parameters (Namespace,EventHub .. etc) are mandatory
* irrespective of order
*/
export interface EventHubModel extends Resource {
export interface Eventhub extends Resource {
readonly partitionIds?: string[];
readonly createdAt?: Date;
readonly updatedAt?: Date;
messageRetentionInDays?: number;
partitionCount?: number;
readonly partitionIds?: string[];
readonly status?: string;
readonly updatedAt?: Date;
status?: string;
captureDescription?: CaptureDescription;
}

@@ -310,29 +292,8 @@

* @class
* Initializes a new instance of the EventHubListResult class.
* @constructor
* The response of the List Event Hubs operation.
*
* @member {array} [value] Result of the List Event Hubs operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Event Hubs.
*
*/
export interface EventHubListResult {
value?: EventHubModel[];
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the ConsumerGroup class.
* @constructor
* Description of the consumer group resource.
* Single item in List or Get Consumer group operation
*
* @member {date} [createdAt] Exact time the message was created.
*
* @member {string} [eventHubPath] The path of the Event Hub.
*
* @member {date} [updatedAt] The exact time the message was updated.
*
* @member {string} [userMetadata] Usermetadata is a placeholder to store

@@ -342,7 +303,5 @@ * user-defined string data with maximum length 1024. e.g. it can be used to

* also user-defined configuration settings can be stored.
*
*/
export interface ConsumerGroup extends Resource {
readonly createdAt?: Date;
readonly eventHubPath?: string;
readonly updatedAt?: Date;

@@ -354,27 +313,9 @@ userMetadata?: string;

* @class
* Initializes a new instance of the ConsumerGroupListResult class.
* Initializes a new instance of the CheckNameAvailabilityParameter class.
* @constructor
* The response to the List Consumer Group operation.
* Parameter supplied to check Namespace name availability operation
*
* @member {array} [value] Result of the List Consumer Group operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Consumer Group
*
* @member {string} name Name to check the namespace name availability
*/
export interface ConsumerGroupListResult {
value?: ConsumerGroup[];
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the CheckNameAvailability class.
* @constructor
* Description of a Check Name availability request properties.
*
* @member {string} name The Name to check the namespce name availability
*
*/
export interface CheckNameAvailability {
export interface CheckNameAvailabilityParameter {
name: string;

@@ -387,19 +328,16 @@ }

* @constructor
* Description of a Check Name availability request properties.
* The Result of the CheckNameAvailability operation
*
* @member {boolean} [nameAvailable] Value indicating namespace is
* availability, true if the namespace is available; otherwise, false.
*
* @member {string} [reason] The reason for unavailability of a namespace.
* @member {string} [message] The detailed info regarding the reason associated
* with the Namespace.
* @member {boolean} [nameAvailable] Value indicating Namespace is
* availability, true if the Namespace is available; otherwise, false.
* @member {string} [reason] The reason for unavailability of a Namespace.
* Possible values include: 'None', 'InvalidName', 'SubscriptionIsDisabled',
* 'NameInUse', 'NameInLockdown', 'TooManyNamespaceInCurrentSubscription'
*
* @member {string} [message] The detailed info regarding the reason associated
* with the namespace.
*
*/
export interface CheckNameAvailabilityResult {
readonly message?: string;
nameAvailable?: boolean;
reason?: string;
readonly message?: string;
}

@@ -409,22 +347,34 @@

* @class
* Initializes a new instance of the NamespaceUpdateParameter class.
* Initializes a new instance of the OperationDisplay class.
* @constructor
* Parameters supplied to the Patch Namespace operation.
* The object that represents the operation.
*
* @member {object} [tags] Resource tags
* @member {string} [provider] Service provider: Microsoft.EventHub
* @member {string} [resource] Resource on which the operation is performed:
* Invoice, etc.
* @member {string} [operation] Operation type: Read, write, delete, etc.
*/
export interface OperationDisplay {
readonly provider?: string;
readonly resource?: string;
readonly operation?: string;
}
/**
* @class
* Initializes a new instance of the Operation class.
* @constructor
* A Event Hub REST API operation
*
* @member {object} [sku] The sku of the created namespace
*
* @member {string} [sku.name] Name of this SKU. Possible values include:
* 'Basic', 'Standard'
*
* @member {string} [sku.tier] The billing tier of this particular SKU.
* Possible values include: 'Basic', 'Standard', 'Premium'
*
* @member {number} [sku.capacity] The EventHubs throughput units.
*
* @member {string} [name] Operation name: {provider}/{resource}/{operation}
* @member {object} [display] The object that represents the operation.
* @member {string} [display.provider] Service provider: Microsoft.EventHub
* @member {string} [display.resource] Resource on which the operation is
* performed: Invoice, etc.
* @member {string} [display.operation] Operation type: Read, write, delete,
* etc.
*/
export interface NamespaceUpdateParameter {
tags?: { [propertyName: string]: string };
sku?: Sku;
export interface Operation {
readonly name?: string;
display?: OperationDisplay;
}

@@ -440,6 +390,4 @@

* @member {string} [code] Error code.
*
* @member {string} [message] Error message indicating why the operation
* failed.
*
*/

@@ -453,16 +401,34 @@ export interface ErrorResponse {

* @class
* Initializes a new instance of the ArmDisasterRecovery class.
* @constructor
* Single item in List or Get Alias(Disaster Recovery configuration) operation
*
* @member {string} [provisioningState] Provisioning state of the
* Alias(Disaster Recovery configuration) - possible values 'Accepted' or
* 'Succeeded' or 'Failed'. Possible values include: 'Accepted', 'Succeeded',
* 'Failed'
* @member {string} [partnerNamespace] Primary/Secondary eventhub namespace
* name, which is part of GEO DR pairning
* @member {string} [role] role of namespace in GEO DR - possible values
* 'Primary' or 'PrimaryNotReplicating' or 'Secondary'. Possible values
* include: 'Primary', 'PrimaryNotReplicating', 'Secondary'
*/
export interface ArmDisasterRecovery extends Resource {
readonly provisioningState?: string;
partnerNamespace?: string;
readonly role?: string;
}
/**
* @class
* Initializes a new instance of the OperationListResult class.
* @constructor
* Result of the request to list EventHub operations. It contains a list of
* Result of the request to list Event Hub operations. It contains a list of
* operations and a URL link to get the next set of results.
*
* @member {array} [value] List of EventHub operations supported by the
* Microsoft.EventHub resource provider.
*
* @member {string} [nextLink] URL to get the next set of operation list
* results if there are any.
*
*/
export interface OperationListResult {
readonly value?: Operation[];
export interface OperationListResult extends Array<Operation> {
readonly nextLink?: string;

@@ -473,14 +439,10 @@ }

* @class
* Initializes a new instance of the NamespaceListResult class.
* Initializes a new instance of the EHNamespaceListResult class.
* @constructor
* The response of the List Namespace operation.
* The response of the List Namespace operation
*
* @member {array} [value] Result of the List Namespace operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of namespaces.
*
*/
export interface NamespaceListResult {
value?: Namespace[];
export interface EHNamespaceListResult extends Array<EHNamespace> {
nextLink?: string;

@@ -491,14 +453,10 @@ }

* @class
* Initializes a new instance of the SharedAccessAuthorizationRuleListResult class.
* Initializes a new instance of the AuthorizationRuleListResult class.
* @constructor
* The response from the List Namespace operation.
* The response from the List namespace operation.
*
* @member {array} [value] Result of the List Authorization Rules operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains an incomplete list of Authorization Rules
*
*/
export interface SharedAccessAuthorizationRuleListResult {
value?: SharedAccessAuthorizationRule[];
export interface AuthorizationRuleListResult extends Array<AuthorizationRule> {
nextLink?: string;

@@ -509,47 +467,10 @@ }

* @class
* Initializes a new instance of the EventHubListResult class.
* Initializes a new instance of the ArmDisasterRecoveryListResult class.
* @constructor
* The response of the List Event Hubs operation.
* The result of the List Alias(Disaster Recovery configuration) operation.
*
* @member {array} [value] Result of the List Event Hubs operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Event Hubs.
*
* Value contains incomplete list of Alias(Disaster Recovery configuration)
*/
export interface EventHubListResult {
value?: EventHubModel[];
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the ConsumerGroupListResult class.
* @constructor
* The response to the List Consumer Group operation.
*
* @member {array} [value] Result of the List Consumer Group operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Consumer Group
*
*/
export interface ConsumerGroupListResult {
value?: ConsumerGroup[];
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the OperationListResult class.
* @constructor
* Result of the request to list EventHub operations. It contains a list of
* operations and a URL link to get the next set of results.
*
* @member {string} [nextLink] URL to get the next set of operation list
* results if there are any.
*
*/
export interface OperationListResult extends Array<Operation> {
export interface ArmDisasterRecoveryListResult extends Array<ArmDisasterRecovery> {
readonly nextLink?: string;

@@ -560,39 +481,10 @@ }

* @class
* Initializes a new instance of the NamespaceListResult class.
* @constructor
* The response of the List Namespace operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of namespaces.
*
*/
export interface NamespaceListResult extends Array<Namespace> {
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the SharedAccessAuthorizationRuleListResult class.
* @constructor
* The response from the List Namespace operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains an incomplete list of Authorization Rules
*
*/
export interface SharedAccessAuthorizationRuleListResult extends Array<SharedAccessAuthorizationRule> {
nextLink?: string;
}
/**
* @class
* Initializes a new instance of the EventHubListResult class.
* @constructor
* The response of the List Event Hubs operation.
* The result of the List EventHubs operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Event Hubs.
*
* Value contains incomplete list of EventHubs.
*/
export interface EventHubListResult extends Array<EventHubModel> {
export interface EventHubListResult extends Array<Eventhub> {
nextLink?: string;

@@ -605,7 +497,6 @@ }

* @constructor
* The response to the List Consumer Group operation.
* The result to the List Consumer Group operation.
*
* @member {string} [nextLink] Link to the next set of results. Not empty if
* Value contains incomplete list of Consumer Group
*
*/

@@ -612,0 +503,0 @@ export interface ConsumerGroupListResult extends Array<ConsumerGroup> {

@@ -21,26 +21,24 @@ /*

exports.CloudError = msRestAzure.CloudError;
exports.OperationDisplay = require('./operationDisplay');
exports.Operation = require('./operation');
exports.OperationListResult = require('./operationListResult');
exports.Resource = require('./resource');
exports.TrackedResource = require('./trackedResource');
exports.Resource = require('./resource');
exports.Sku = require('./sku');
exports.Namespace = require('./namespace');
exports.NamespaceListResult = require('./namespaceListResult');
exports.SharedAccessAuthorizationRule = require('./sharedAccessAuthorizationRule');
exports.SharedAccessAuthorizationRuleListResult = require('./sharedAccessAuthorizationRuleListResult');
exports.ResourceListKeys = require('./resourceListKeys');
exports.RegenerateKeysParameters = require('./regenerateKeysParameters');
exports.EventHubModel = require('./eventHubModel');
exports.EventHubListResult = require('./eventHubListResult');
exports.EHNamespace = require('./eHNamespace');
exports.AuthorizationRule = require('./authorizationRule');
exports.AccessKeys = require('./accessKeys');
exports.RegenerateAccessKeyParameters = require('./regenerateAccessKeyParameters');
exports.Destination = require('./destination');
exports.CaptureDescription = require('./captureDescription');
exports.Eventhub = require('./eventhub');
exports.ConsumerGroup = require('./consumerGroup');
exports.ConsumerGroupListResult = require('./consumerGroupListResult');
exports.CheckNameAvailability = require('./checkNameAvailability');
exports.CheckNameAvailabilityParameter = require('./checkNameAvailabilityParameter');
exports.CheckNameAvailabilityResult = require('./checkNameAvailabilityResult');
exports.NamespaceUpdateParameter = require('./namespaceUpdateParameter');
exports.OperationDisplay = require('./operationDisplay');
exports.Operation = require('./operation');
exports.ErrorResponse = require('./errorResponse');
exports.ArmDisasterRecovery = require('./armDisasterRecovery');
exports.OperationListResult = require('./operationListResult');
exports.NamespaceListResult = require('./namespaceListResult');
exports.SharedAccessAuthorizationRuleListResult = require('./sharedAccessAuthorizationRuleListResult');
exports.EHNamespaceListResult = require('./eHNamespaceListResult');
exports.AuthorizationRuleListResult = require('./authorizationRuleListResult');
exports.ArmDisasterRecoveryListResult = require('./armDisasterRecoveryListResult');
exports.EventHubListResult = require('./eventHubListResult');
exports.ConsumerGroupListResult = require('./consumerGroupListResult');

@@ -16,21 +16,16 @@ /*

/**
* @class
* Initializes a new instance of the Operation class.
* @constructor
* A EventHub REST API operation
* A Event Hub REST API operation
*
* @member {string} [name] Operation name: {provider}/{resource}/{operation}
*
* @member {object} [display] The object that represents the operation.
*
* @member {string} [display.provider] Service provider: Microsoft.EventHub
*
* @member {string} [display.resource] Resource on which the operation is
* performed: Invoice, etc.
*
* @member {string} [display.operation] Operation type: Read, write, delete,
* etc.
*
*/
class Operation {
/**
* Create a Operation.
* @member {string} [name] Operation name: {provider}/{resource}/{operation}
* @member {object} [display] The object that represents the operation.
* @member {string} [display.provider] Service provider: Microsoft.EventHub
* @member {string} [display.resource] Resource on which the operation is
* performed: Invoice, etc.
* @member {string} [display.operation] Operation type: Read, write, delete,
* etc.
*/
constructor() {

@@ -37,0 +32,0 @@ }

@@ -14,16 +14,13 @@ /*

/**
* @class
* Initializes a new instance of the OperationDisplay class.
* @constructor
* The object that represents the operation.
*
* @member {string} [provider] Service provider: Microsoft.EventHub
*
* @member {string} [resource] Resource on which the operation is performed:
* Invoice, etc.
*
* @member {string} [operation] Operation type: Read, write, delete, etc.
*
*/
class OperationDisplay {
/**
* Create a OperationDisplay.
* @member {string} [provider] Service provider: Microsoft.EventHub
* @member {string} [resource] Resource on which the operation is performed:
* Invoice, etc.
* @member {string} [operation] Operation type: Read, write, delete, etc.
*/
constructor() {

@@ -30,0 +27,0 @@ }

@@ -14,13 +14,11 @@ /*

/**
* @class
* Initializes a new instance of the OperationListResult class.
* @constructor
* Result of the request to list EventHub operations. It contains a list of
* Result of the request to list Event Hub operations. It contains a list of
* operations and a URL link to get the next set of results.
*
* @member {string} [nextLink] URL to get the next set of operation list
* results if there are any.
*
*/
class OperationListResult extends Array {
/**
* Create a OperationListResult.
* @member {string} [nextLink] URL to get the next set of operation list
* results if there are any.
*/
constructor() {

@@ -27,0 +25,0 @@ super();

@@ -16,15 +16,13 @@ /*

/**
* @class
* Initializes a new instance of the Resource class.
* @constructor
* The Resource definition
*
* @member {string} [id] Resource Id
*
* @member {string} [name] Resource name
*
* @member {string} [type] Resource type
*
* @extends models['BaseResource']
*/
class Resource extends models['BaseResource'] {
/**
* Create a Resource.
* @member {string} [id] Resource Id
* @member {string} [name] Resource name
* @member {string} [type] Resource type
*/
constructor() {

@@ -31,0 +29,0 @@ super();

@@ -14,17 +14,15 @@ /*

/**
* @class
* Initializes a new instance of the Sku class.
* @constructor
* SKU of the namespace.
* SKU parameters supplied to the create namespace operation
*
* @member {string} [name] Name of this SKU. Possible values include: 'Basic',
* 'Standard'
*
* @member {string} tier The billing tier of this particular SKU. Possible
* values include: 'Basic', 'Standard', 'Premium'
*
* @member {number} [capacity] The EventHubs throughput units.
*
*/
class Sku {
/**
* Create a Sku.
* @member {string} name Name of this SKU. Possible values include: 'Basic',
* 'Standard'
* @member {string} [tier] The billing tier of this particular SKU. Possible
* values include: 'Basic', 'Standard'
* @member {number} [capacity] The Event Hubs throughput units, vaule should
* be 0 to 20 throughput units.
*/
constructor() {

@@ -48,3 +46,3 @@ }

name: {
required: false,
required: true,
serializedName: 'name',

@@ -56,3 +54,3 @@ type: {

tier: {
required: true,
required: false,
serializedName: 'tier',

@@ -66,2 +64,6 @@ type: {

serializedName: 'capacity',
constraints: {
InclusiveMaximum: 20,
InclusiveMinimum: 0
},
type: {

@@ -68,0 +70,0 @@ name: 'Number'

@@ -16,13 +16,12 @@ /*

/**
* @class
* Initializes a new instance of the TrackedResource class.
* @constructor
* Definition of Resource
*
* @member {string} location Resource location
*
* @member {object} [tags] Resource tags
*
* @extends models['Resource']
*/
class TrackedResource extends models['BaseResource'] {
class TrackedResource extends models['Resource'] {
/**
* Create a TrackedResource.
* @member {string} [location] Resource location
* @member {object} [tags] Resource tags
*/
constructor() {

@@ -46,4 +45,28 @@ super();

modelProperties: {
id: {
required: false,
readOnly: true,
serializedName: 'id',
type: {
name: 'String'
}
},
name: {
required: false,
readOnly: true,
serializedName: 'name',
type: {
name: 'String'
}
},
type: {
required: false,
readOnly: true,
serializedName: 'type',
type: {
name: 'String'
}
},
location: {
required: true,
required: false,
serializedName: 'location',

@@ -50,0 +73,0 @@ type: {

@@ -19,15 +19,15 @@ /*

* Creates or updates an Event Hubs consumer group as a nested resource within
* a namespace.
* a Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*
* @param {string} consumerGroupName The consumer group name
*
* @param {object} parameters Parameters supplied to create a consumer group
* resource.
* @param {object} parameters Parameters supplied to create or update a
* consumer group resource.
*

@@ -99,6 +99,2 @@ * @param {string} [parameters.userMetadata] Usermetadata is a placeholder to

if (eventHubName !== null && eventHubName !== undefined) {
if (eventHubName.length > 50)
{
throw new Error('"eventHubName" should satisfy the constraint - "MaxLength": 50');
}
if (eventHubName.length < 1)

@@ -155,5 +151,6 @@ {

httpRequest.method = 'PUT';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -172,3 +169,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
// Serialize Request

@@ -205,8 +201,9 @@ let requestContent = null;

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -249,8 +246,8 @@ }

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -318,6 +315,2 @@ * @param {string} consumerGroupName The consumer group name

if (eventHubName !== null && eventHubName !== undefined) {
if (eventHubName.length > 50)
{
throw new Error('"eventHubName" should satisfy the constraint - "MaxLength": 50');
}
if (eventHubName.length < 1)

@@ -371,5 +364,6 @@ {

httpRequest.method = 'DELETE';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -388,3 +382,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -407,8 +400,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -434,8 +428,8 @@ }

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -504,6 +498,2 @@ * @param {string} consumerGroupName The consumer group name

if (eventHubName !== null && eventHubName !== undefined) {
if (eventHubName.length > 50)
{
throw new Error('"eventHubName" should satisfy the constraint - "MaxLength": 50');
}
if (eventHubName.length < 1)

@@ -557,5 +547,6 @@ {

httpRequest.method = 'GET';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -574,3 +565,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -593,8 +583,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -635,11 +626,11 @@ }

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -707,6 +698,2 @@ * @param {object} [options] Optional Parameters.

if (eventHubName !== null && eventHubName !== undefined) {
if (eventHubName.length > 50)
{
throw new Error('"eventHubName" should satisfy the constraint - "MaxLength": 50');
}
if (eventHubName.length < 1)

@@ -746,5 +733,6 @@ {

httpRequest.method = 'GET';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -763,3 +751,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -782,8 +769,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -824,4 +812,4 @@ }

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*

@@ -879,5 +867,6 @@ * @param {string} nextPageLink The NextLink from the previous successful call

httpRequest.method = 'GET';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -896,3 +885,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -915,8 +903,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -956,13 +945,8 @@ }

/**
* @class
* ConsumerGroups
* __NOTE__: An instance of this class is automatically created for an
* instance of the EventHubManagementClient.
* Initializes a new instance of the ConsumerGroups class.
* @constructor
*
* @param {EventHubManagementClient} client Reference to the service client.
*/
/** Class representing a ConsumerGroups. */
class ConsumerGroups {
/**
* Create a ConsumerGroups.
* @param {EventHubManagementClient} client Reference to the service client.
*/
constructor(client) {

@@ -979,15 +963,15 @@ this.client = client;

* Creates or updates an Event Hubs consumer group as a nested resource within
* a namespace.
* a Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*
* @param {string} consumerGroupName The consumer group name
*
* @param {object} parameters Parameters supplied to create a consumer group
* resource.
* @param {object} parameters Parameters supplied to create or update a
* consumer group resource.
*

@@ -1026,15 +1010,15 @@ * @param {string} [parameters.userMetadata] Usermetadata is a placeholder to

* Creates or updates an Event Hubs consumer group as a nested resource within
* a namespace.
* a Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*
* @param {string} consumerGroupName The consumer group name
*
* @param {object} parameters Parameters supplied to create a consumer group
* resource.
* @param {object} parameters Parameters supplied to create or update a
* consumer group resource.
*

@@ -1096,8 +1080,8 @@ * @param {string} [parameters.userMetadata] Usermetadata is a placeholder to

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1134,8 +1118,8 @@ * @param {string} consumerGroupName The consumer group name

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1193,8 +1177,8 @@ * @param {string} consumerGroupName The consumer group name

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1231,8 +1215,8 @@ * @param {string} consumerGroupName The consumer group name

*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1289,11 +1273,11 @@ * @param {string} consumerGroupName The consumer group name

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1326,11 +1310,11 @@ * @param {object} [options] Optional Parameters.

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*
* @param {string} resourceGroupName Name of the Resource group within the
* Azure subscription.
* @param {string} resourceGroupName Name of the resource group within the
* azure subscription.
*
* @param {string} namespaceName The namespace name
* @param {string} namespaceName The Namespace name
*
* @param {string} eventHubName The eventhub name
* @param {string} eventHubName The Event Hub name
*

@@ -1386,4 +1370,4 @@ * @param {object} [options] Optional Parameters.

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*

@@ -1419,4 +1403,4 @@ * @param {string} nextPageLink The NextLink from the previous successful call

/**
* Gets all the consumer groups in a eventhub. An empty feed is returned if no
* consumer group exists in the eventhub.
* Gets all the consumer groups in a Namespace. An empty feed is returned if no
* consumer group exists in the Namespace.
*

@@ -1423,0 +1407,0 @@ * @param {string} nextPageLink The NextLink from the previous successful call

@@ -19,3 +19,4 @@ /*

exports.Namespaces = require('./namespaces');
exports.DisasterRecoveryConfigs = require('./disasterRecoveryConfigs');
exports.EventHubs = require('./eventHubs');
exports.ConsumerGroups = require('./consumerGroups');

@@ -18,3 +18,3 @@ /*

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -73,5 +73,6 @@ * @param {object} [options] Optional Parameters.

httpRequest.method = 'GET';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -90,3 +91,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -109,8 +109,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -151,3 +152,3 @@ }

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -204,5 +205,6 @@ * @param {string} nextPageLink The NextLink from the previous successful call

httpRequest.method = 'GET';
httpRequest.url = requestUrl;
httpRequest.headers = {};
httpRequest.url = requestUrl;
// Set Headers
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
if (this.client.generateClientRequestId) {

@@ -221,3 +223,2 @@ httpRequest.headers['x-ms-client-request-id'] = msRestAzure.generateUuid();

}
httpRequest.headers['Content-Type'] = 'application/json; charset=utf-8';
httpRequest.body = null;

@@ -240,8 +241,9 @@ // Send Request

if (parsedErrorResponse) {
if (parsedErrorResponse.error) parsedErrorResponse = parsedErrorResponse.error;
if (parsedErrorResponse.code) error.code = parsedErrorResponse.code;
if (parsedErrorResponse.message) error.message = parsedErrorResponse.message;
let internalError = null;
if (parsedErrorResponse.error) internalError = parsedErrorResponse.error;
error.code = internalError ? internalError.code : parsedErrorResponse.code;
error.message = internalError ? internalError.message : parsedErrorResponse.message;
}
if (parsedErrorResponse !== null && parsedErrorResponse !== undefined) {
let resultMapper = new client.models['CloudError']().mapper();
let resultMapper = new client.models['ErrorResponse']().mapper();
error.body = client.deserialize(resultMapper, parsedErrorResponse, 'error.body');

@@ -281,13 +283,8 @@ }

/**
* @class
* Operations
* __NOTE__: An instance of this class is automatically created for an
* instance of the EventHubManagementClient.
* Initializes a new instance of the Operations class.
* @constructor
*
* @param {EventHubManagementClient} client Reference to the service client.
*/
/** Class representing a Operations. */
class Operations {
/**
* Create a Operations.
* @param {EventHubManagementClient} client Reference to the service client.
*/
constructor(client) {

@@ -300,3 +297,3 @@ this.client = client;

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -329,3 +326,3 @@ * @param {object} [options] Optional Parameters.

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -380,3 +377,3 @@ * @param {object} [options] Optional Parameters.

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -412,3 +409,3 @@ * @param {string} nextPageLink The NextLink from the previous successful call

/**
* Lists all of the available event hub REST API operations.
* Lists all of the available Event Hub REST API operations.
*

@@ -415,0 +412,0 @@ * @param {string} nextPageLink The NextLink from the previous successful call

@@ -8,3 +8,3 @@ {

],
"version": "1.0.0-preview",
"version": "1.1.0-preview",
"description": "Microsoft EventHub Management Client Library for node",

@@ -23,4 +23,4 @@ "tags": [

"dependencies": {
"ms-rest-azure": "^2.0.0",
"ms-rest": "^2.0.0"
"ms-rest-azure": "^2.3.3",
"ms-rest": "^2.2.2"
},

@@ -27,0 +27,0 @@ "homepage": "http://github.com/Azure/azure-sdk-for-node",

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc