diff --git a/common/config/rush/pnpm-lock.yaml b/common/config/rush/pnpm-lock.yaml index e38fc9667b68..c9f4be923a01 100644 --- a/common/config/rush/pnpm-lock.yaml +++ b/common/config/rush/pnpm-lock.yaml @@ -3832,7 +3832,7 @@ packages: dependencies: semver: 7.5.1 shelljs: 0.8.5 - typescript: 5.2.0-dev.20230607 + typescript: 5.2.0-dev.20230608 dev: false /ecdsa-sig-formatter/1.0.11: @@ -8413,6 +8413,12 @@ packages: hasBin: true dev: false + /typescript/4.8.4: + resolution: {integrity: sha512-QCh+85mCy+h0IGff8r5XWzOVSbBO+KfeYrMQh7NJ58QujwcE22u+NUSmUxqF+un70P9GXKxa2HCNiTTMJknyjQ==} + engines: {node: '>=4.2.0'} + hasBin: true + dev: false + /typescript/5.0.4: resolution: {integrity: sha512-cW9T5W9xY37cc+jfEnaUvX91foxtHkza3Nw3wkoF4sSlKn0MONdkdEndig/qPBWXNkmplh3NzayQzCiHM4/hqw==} engines: {node: '>=12.20'} @@ -8425,8 +8431,8 @@ packages: hasBin: true dev: false - /typescript/5.2.0-dev.20230607: - resolution: {integrity: sha512-7Lgk1sNuuYpMNvHuXIMczqhLbJ99RpX3VgokK+Ir4DgliycYNrNGM/daAO38fHkk8n3lg2rP/6U5I545xTJdKA==} + /typescript/5.2.0-dev.20230608: + resolution: {integrity: sha512-My8VOVNpHAZ693+NgsvD2JXgXg5eosPJcEDzPcme8tU1vs+C6G6liR15r3qd1qSSNjDghmCe014GjWspVBZ7ag==} engines: {node: '>=14.17'} hasBin: true dev: false @@ -12395,7 +12401,7 @@ packages: dev: false file:projects/arm-kusto.tgz: - resolution: {integrity: sha512-NHVaCXsY2x5l7bCKnOEK4NyBw76kF6EZc+CPJxLjY+AgNOWH7halakaeLBWW2JJCuSiSoeRIbRTx0XiQuaswuw==, tarball: file:projects/arm-kusto.tgz} + resolution: {integrity: sha512-es4Fg7bzExM4dkb4DeuBkwU8UGSK/cNn2JpP8qjUkTJdCPIDcjiIpd1UtSvPuJZjn3TCULGnn7oqz/seXePptQ==, tarball: file:projects/arm-kusto.tgz} name: '@rush-temp/arm-kusto' version: 0.0.0 dependencies: @@ -12409,14 +12415,14 @@ packages: '@types/node': 14.18.48 chai: 4.3.7 cross-env: 7.0.3 - dotenv: 8.6.0 - mkdirp: 1.0.4 + dotenv: 16.1.4 + mkdirp: 2.1.6 mocha: 7.2.0 rimraf: 3.0.2 rollup: 2.79.1 rollup-plugin-sourcemaps: 0.6.3_6vxqa4pl2c5hli7lcaemfsm5je tslib: 2.5.3 - typescript: 5.0.4 + typescript: 4.8.4 uglify-js: 3.17.4 transitivePeerDependencies: - supports-color @@ -19316,7 +19322,7 @@ packages: dev: false file:projects/storage-file-share.tgz: - resolution: {integrity: sha512-Ta2DL1i32tq8YzBuBOpmsMPn5ZwaEkk4UK/PIovIBFkm19A6Pb/TcIsJWYe2IDV6bmz9S4jLLFdRex0krtigYw==, tarball: file:projects/storage-file-share.tgz} + resolution: {integrity: sha512-P71uQ6hYBUOp8sAtiKzvb3oy1eskU0cjAcXH5W5MdCh12E5VENENL6BLv5YCHvt9VelKTdzXOtNw274eP80iAg==, tarball: file:projects/storage-file-share.tgz} name: '@rush-temp/storage-file-share' version: 0.0.0 dependencies: diff --git a/sdk/kusto/arm-kusto/CHANGELOG.md b/sdk/kusto/arm-kusto/CHANGELOG.md index 13761cd3b716..b7fafc62b6b0 100644 --- a/sdk/kusto/arm-kusto/CHANGELOG.md +++ b/sdk/kusto/arm-kusto/CHANGELOG.md @@ -1,15 +1,13 @@ # Release History + +## 8.0.0 (2023-06-08) + +**Breaking Changes** -## 7.3.1 (Unreleased) - -### Features Added - -### Breaking Changes - -### Bugs Fixed - -### Other Changes - + - Enum KnownLanguageExtensionImageName no longer has value Python3912 + - Enum KnownLanguageExtensionImageName no longer has value Python3912IncludeDeepLearning + + ## 7.3.0 (2023-02-07) **Features** diff --git a/sdk/kusto/arm-kusto/_meta.json b/sdk/kusto/arm-kusto/_meta.json index 2eef58f6e38f..a71b71ce9f7c 100644 --- a/sdk/kusto/arm-kusto/_meta.json +++ b/sdk/kusto/arm-kusto/_meta.json @@ -1,8 +1,8 @@ { - "commit": "41645a4769694a7d63a2514b45146ec369eeb273", + "commit": "4fc56878e24fa921b25e8e6a735b2e636cb7af64", "readme": "specification/azure-kusto/resource-manager/readme.md", - "autorest_command": "autorest --version=3.9.3 --typescript --modelerfour.lenient-model-deduplication --azure-arm --head-as-boolean=true --license-header=MICROSOFT_MIT_NO_VERSION --generate-test --typescript-sdks-folder=D:\\Git\\azure-sdk-for-js ..\\azure-rest-api-specs\\specification\\azure-kusto\\resource-manager\\readme.md --use=@autorest/typescript@6.0.0-rc.7 --generate-sample=true", + "autorest_command": "autorest --version=3.9.3 --typescript --modelerfour.lenient-model-deduplication --azure-arm --head-as-boolean=true --license-header=MICROSOFT_MIT_NO_VERSION --generate-test --typescript-sdks-folder=/mnt/vss/_work/1/s/azure-sdk-for-js ../azure-rest-api-specs/specification/azure-kusto/resource-manager/readme.md --use=@autorest/typescript@6.0.0-rc.10", "repository_url": "https://github.com/Azure/azure-rest-api-specs.git", - "release_tool": "@azure-tools/js-sdk-release-tools@2.6.1", - "use": "@autorest/typescript@6.0.0-rc.7" + "release_tool": "@azure-tools/js-sdk-release-tools@2.7.0", + "use": "@autorest/typescript@6.0.0-rc.10" } \ No newline at end of file diff --git a/sdk/kusto/arm-kusto/package.json b/sdk/kusto/arm-kusto/package.json index 34fa4e2e6dc7..f2eeb6877db7 100644 --- a/sdk/kusto/arm-kusto/package.json +++ b/sdk/kusto/arm-kusto/package.json @@ -3,15 +3,15 @@ "sdk-type": "mgmt", "author": "Microsoft Corporation", "description": "A generated SDK for KustoManagementClient.", - "version": "7.3.1", + "version": "8.0.0", "engines": { "node": ">=14.0.0" }, "dependencies": { - "@azure/core-lro": "^2.2.0", + "@azure/core-lro": "^2.5.0", "@azure/abort-controller": "^1.0.0", "@azure/core-paging": "^1.2.0", - "@azure/core-client": "^1.6.1", + "@azure/core-client": "^1.7.0", "@azure/core-auth": "^1.3.0", "@azure/core-rest-pipeline": "^1.8.0", "tslib": "^2.2.0" @@ -33,13 +33,13 @@ "@rollup/plugin-json": "^6.0.0", "@rollup/plugin-multi-entry": "^6.0.0", "@rollup/plugin-node-resolve": "^13.1.3", - "mkdirp": "^1.0.4", + "mkdirp": "^2.1.2", "rollup": "^2.66.1", "rollup-plugin-sourcemaps": "^0.6.3", - "typescript": "~5.0.0", + "typescript": "~4.8.0", "uglify-js": "^3.4.9", "rimraf": "^3.0.0", - "dotenv": "^8.2.0", + "dotenv": "^16.0.0", "@azure/identity": "^2.0.1", "@azure-tools/test-recorder": "^3.0.0", "@azure-tools/test-credential": "^1.0.0", @@ -111,13 +111,5 @@ ] }, "autoPublish": true, - "homepage": "https://github.com/Azure/azure-sdk-for-js/tree/main/sdk/kusto/arm-kusto", - "//sampleConfiguration": { - "productName": "", - "productSlugs": [ - "azure" - ], - "disableDocsMs": true, - "apiRefLink": "https://docs.microsoft.com/javascript/api/@azure/arm-kusto?view=azure-node-preview" - } -} + "homepage": "https://github.com/Azure/azure-sdk-for-js/tree/main/sdk/kusto/arm-kusto" +} \ No newline at end of file diff --git a/sdk/kusto/arm-kusto/review/arm-kusto.api.md b/sdk/kusto/arm-kusto/review/arm-kusto.api.md index 91218027e03d..0550edc83f6c 100644 --- a/sdk/kusto/arm-kusto/review/arm-kusto.api.md +++ b/sdk/kusto/arm-kusto/review/arm-kusto.api.md @@ -6,9 +6,9 @@ import * as coreAuth from '@azure/core-auth'; import * as coreClient from '@azure/core-client'; +import { OperationState } from '@azure/core-lro'; import { PagedAsyncIterableIterator } from '@azure/core-paging'; -import { PollerLike } from '@azure/core-lro'; -import { PollOperationState } from '@azure/core-lro'; +import { SimplePollerLike } from '@azure/core-lro'; // @public export interface AcceptedAudiences { @@ -35,9 +35,9 @@ export interface AttachedDatabaseConfigurationListResult { // @public export interface AttachedDatabaseConfigurations { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, parameters: AttachedDatabaseConfiguration, options?: AttachedDatabaseConfigurationsCreateOrUpdateOptionalParams): Promise, AttachedDatabaseConfigurationsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, parameters: AttachedDatabaseConfiguration, options?: AttachedDatabaseConfigurationsCreateOrUpdateOptionalParams): Promise, AttachedDatabaseConfigurationsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, parameters: AttachedDatabaseConfiguration, options?: AttachedDatabaseConfigurationsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsDeleteOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, resourceName: AttachedDatabaseConfigurationsCheckNameRequest, options?: AttachedDatabaseConfigurationsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsGetOptionalParams): Promise; @@ -222,9 +222,9 @@ export interface ClusterPrincipalAssignmentListResult { // @public export interface ClusterPrincipalAssignments { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, principalAssignmentName: string, parameters: ClusterPrincipalAssignment, options?: ClusterPrincipalAssignmentsCreateOrUpdateOptionalParams): Promise, ClusterPrincipalAssignmentsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, principalAssignmentName: string, parameters: ClusterPrincipalAssignment, options?: ClusterPrincipalAssignmentsCreateOrUpdateOptionalParams): Promise, ClusterPrincipalAssignmentsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, principalAssignmentName: string, parameters: ClusterPrincipalAssignment, options?: ClusterPrincipalAssignmentsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsDeleteOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, principalAssignmentName: ClusterPrincipalAssignmentCheckNameRequest, options?: ClusterPrincipalAssignmentsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsGetOptionalParams): Promise; @@ -272,23 +272,23 @@ export type ClusterPrincipalRole = string; // @public export interface Clusters { - beginAddLanguageExtensions(resourceGroupName: string, clusterName: string, languageExtensionsToAdd: LanguageExtensionsList, options?: ClustersAddLanguageExtensionsOptionalParams): Promise, void>>; + beginAddLanguageExtensions(resourceGroupName: string, clusterName: string, languageExtensionsToAdd: LanguageExtensionsList, options?: ClustersAddLanguageExtensionsOptionalParams): Promise, void>>; beginAddLanguageExtensionsAndWait(resourceGroupName: string, clusterName: string, languageExtensionsToAdd: LanguageExtensionsList, options?: ClustersAddLanguageExtensionsOptionalParams): Promise; - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, parameters: Cluster, options?: ClustersCreateOrUpdateOptionalParams): Promise, ClustersCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, parameters: Cluster, options?: ClustersCreateOrUpdateOptionalParams): Promise, ClustersCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, parameters: Cluster, options?: ClustersCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, options?: ClustersDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, options?: ClustersDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, options?: ClustersDeleteOptionalParams): Promise; - beginDetachFollowerDatabases(resourceGroupName: string, clusterName: string, followerDatabaseToRemove: FollowerDatabaseDefinition, options?: ClustersDetachFollowerDatabasesOptionalParams): Promise, void>>; + beginDetachFollowerDatabases(resourceGroupName: string, clusterName: string, followerDatabaseToRemove: FollowerDatabaseDefinition, options?: ClustersDetachFollowerDatabasesOptionalParams): Promise, void>>; beginDetachFollowerDatabasesAndWait(resourceGroupName: string, clusterName: string, followerDatabaseToRemove: FollowerDatabaseDefinition, options?: ClustersDetachFollowerDatabasesOptionalParams): Promise; - beginDiagnoseVirtualNetwork(resourceGroupName: string, clusterName: string, options?: ClustersDiagnoseVirtualNetworkOptionalParams): Promise, ClustersDiagnoseVirtualNetworkResponse>>; + beginDiagnoseVirtualNetwork(resourceGroupName: string, clusterName: string, options?: ClustersDiagnoseVirtualNetworkOptionalParams): Promise, ClustersDiagnoseVirtualNetworkResponse>>; beginDiagnoseVirtualNetworkAndWait(resourceGroupName: string, clusterName: string, options?: ClustersDiagnoseVirtualNetworkOptionalParams): Promise; - beginRemoveLanguageExtensions(resourceGroupName: string, clusterName: string, languageExtensionsToRemove: LanguageExtensionsList, options?: ClustersRemoveLanguageExtensionsOptionalParams): Promise, void>>; + beginRemoveLanguageExtensions(resourceGroupName: string, clusterName: string, languageExtensionsToRemove: LanguageExtensionsList, options?: ClustersRemoveLanguageExtensionsOptionalParams): Promise, void>>; beginRemoveLanguageExtensionsAndWait(resourceGroupName: string, clusterName: string, languageExtensionsToRemove: LanguageExtensionsList, options?: ClustersRemoveLanguageExtensionsOptionalParams): Promise; - beginStart(resourceGroupName: string, clusterName: string, options?: ClustersStartOptionalParams): Promise, void>>; + beginStart(resourceGroupName: string, clusterName: string, options?: ClustersStartOptionalParams): Promise, void>>; beginStartAndWait(resourceGroupName: string, clusterName: string, options?: ClustersStartOptionalParams): Promise; - beginStop(resourceGroupName: string, clusterName: string, options?: ClustersStopOptionalParams): Promise, void>>; + beginStop(resourceGroupName: string, clusterName: string, options?: ClustersStopOptionalParams): Promise, void>>; beginStopAndWait(resourceGroupName: string, clusterName: string, options?: ClustersStopOptionalParams): Promise; - beginUpdate(resourceGroupName: string, clusterName: string, parameters: ClusterUpdate, options?: ClustersUpdateOptionalParams): Promise, ClustersUpdateResponse>>; + beginUpdate(resourceGroupName: string, clusterName: string, parameters: ClusterUpdate, options?: ClustersUpdateOptionalParams): Promise, ClustersUpdateResponse>>; beginUpdateAndWait(resourceGroupName: string, clusterName: string, parameters: ClusterUpdate, options?: ClustersUpdateOptionalParams): Promise; checkNameAvailability(location: string, clusterName: ClusterCheckNameRequest, options?: ClustersCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, options?: ClustersGetOptionalParams): Promise; @@ -549,9 +549,9 @@ export interface DatabasePrincipalAssignmentListResult { // @public export interface DatabasePrincipalAssignments { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, parameters: DatabasePrincipalAssignment, options?: DatabasePrincipalAssignmentsCreateOrUpdateOptionalParams): Promise, DatabasePrincipalAssignmentsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, parameters: DatabasePrincipalAssignment, options?: DatabasePrincipalAssignmentsCreateOrUpdateOptionalParams): Promise, DatabasePrincipalAssignmentsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, parameters: DatabasePrincipalAssignment, options?: DatabasePrincipalAssignmentsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsDeleteOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: DatabasePrincipalAssignmentCheckNameRequest, options?: DatabasePrincipalAssignmentsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsGetOptionalParams): Promise; @@ -616,11 +616,11 @@ export type DatabaseRouting = string; // @public export interface Databases { addPrincipals(resourceGroupName: string, clusterName: string, databaseName: string, databasePrincipalsToAdd: DatabasePrincipalListRequest, options?: DatabasesAddPrincipalsOptionalParams): Promise; - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesCreateOrUpdateOptionalParams): Promise, DatabasesCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesCreateOrUpdateOptionalParams): Promise, DatabasesCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, options?: DatabasesDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, options?: DatabasesDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, databaseName: string, options?: DatabasesDeleteOptionalParams): Promise; - beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesUpdateOptionalParams): Promise, DatabasesUpdateResponse>>; + beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesUpdateOptionalParams): Promise, DatabasesUpdateResponse>>; beginUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DatabaseUnion, options?: DatabasesUpdateOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, resourceName: CheckNameRequest, options?: DatabasesCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, databaseName: string, options?: DatabasesGetOptionalParams): Promise; @@ -735,13 +735,13 @@ export interface DataConnectionListResult { // @public export interface DataConnections { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsCreateOrUpdateOptionalParams): Promise, DataConnectionsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsCreateOrUpdateOptionalParams): Promise, DataConnectionsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsCreateOrUpdateOptionalParams): Promise; - beginDataConnectionValidation(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DataConnectionValidation, options?: DataConnectionsDataConnectionValidationOptionalParams): Promise, DataConnectionsDataConnectionValidationResponse>>; + beginDataConnectionValidation(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DataConnectionValidation, options?: DataConnectionsDataConnectionValidationOptionalParams): Promise, DataConnectionsDataConnectionValidationResponse>>; beginDataConnectionValidationAndWait(resourceGroupName: string, clusterName: string, databaseName: string, parameters: DataConnectionValidation, options?: DataConnectionsDataConnectionValidationOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, options?: DataConnectionsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, options?: DataConnectionsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, options?: DataConnectionsDeleteOptionalParams): Promise; - beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsUpdateOptionalParams): Promise, DataConnectionsUpdateResponse>>; + beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsUpdateOptionalParams): Promise, DataConnectionsUpdateResponse>>; beginUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, parameters: DataConnectionUnion, options?: DataConnectionsUpdateOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: DataConnectionCheckNameRequest, options?: DataConnectionsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, databaseName: string, dataConnectionName: string, options?: DataConnectionsGetOptionalParams): Promise; @@ -1196,8 +1196,6 @@ export enum KnownKind { export enum KnownLanguageExtensionImageName { Python3108 = "Python3_10_8", Python365 = "Python3_6_5", - Python3912 = "Python3_9_12", - Python3912IncludeDeepLearning = "Python3_9_12IncludeDeepLearning", // (undocumented) R = "R" } @@ -1358,11 +1356,11 @@ export interface ManagedPrivateEndpointListResult { // @public export interface ManagedPrivateEndpoints { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsCreateOrUpdateOptionalParams): Promise, ManagedPrivateEndpointsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsCreateOrUpdateOptionalParams): Promise, ManagedPrivateEndpointsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsDeleteOptionalParams): Promise; - beginUpdate(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsUpdateOptionalParams): Promise, ManagedPrivateEndpointsUpdateResponse>>; + beginUpdate(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsUpdateOptionalParams): Promise, ManagedPrivateEndpointsUpdateResponse>>; beginUpdateAndWait(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsUpdateOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, resourceName: ManagedPrivateEndpointsCheckNameRequest, options?: ManagedPrivateEndpointsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsGetOptionalParams): Promise; @@ -1546,9 +1544,9 @@ export interface PrivateEndpointConnectionListResult { // @public export interface PrivateEndpointConnections { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, parameters: PrivateEndpointConnection, options?: PrivateEndpointConnectionsCreateOrUpdateOptionalParams): Promise, PrivateEndpointConnectionsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, parameters: PrivateEndpointConnection, options?: PrivateEndpointConnectionsCreateOrUpdateOptionalParams): Promise, PrivateEndpointConnectionsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, parameters: PrivateEndpointConnection, options?: PrivateEndpointConnectionsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsDeleteOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsGetOptionalParams): Promise; list(resourceGroupName: string, clusterName: string, options?: PrivateEndpointConnectionsListOptionalParams): PagedAsyncIterableIterator; @@ -1712,11 +1710,11 @@ export interface ScriptListResult { // @public export interface Scripts { - beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsCreateOrUpdateOptionalParams): Promise, ScriptsCreateOrUpdateResponse>>; + beginCreateOrUpdate(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsCreateOrUpdateOptionalParams): Promise, ScriptsCreateOrUpdateResponse>>; beginCreateOrUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsCreateOrUpdateOptionalParams): Promise; - beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, options?: ScriptsDeleteOptionalParams): Promise, void>>; + beginDelete(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, options?: ScriptsDeleteOptionalParams): Promise, void>>; beginDeleteAndWait(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, options?: ScriptsDeleteOptionalParams): Promise; - beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsUpdateOptionalParams): Promise, ScriptsUpdateResponse>>; + beginUpdate(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsUpdateOptionalParams): Promise, ScriptsUpdateResponse>>; beginUpdateAndWait(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, parameters: Script, options?: ScriptsUpdateOptionalParams): Promise; checkNameAvailability(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: ScriptCheckNameRequest, options?: ScriptsCheckNameAvailabilityOptionalParams): Promise; get(resourceGroupName: string, clusterName: string, databaseName: string, scriptName: string, options?: ScriptsGetOptionalParams): Promise; diff --git a/sdk/kusto/arm-kusto/src/kustoManagementClient.ts b/sdk/kusto/arm-kusto/src/kustoManagementClient.ts index dda21d6eef1f..f802cecab1b3 100644 --- a/sdk/kusto/arm-kusto/src/kustoManagementClient.ts +++ b/sdk/kusto/arm-kusto/src/kustoManagementClient.ts @@ -81,7 +81,7 @@ export class KustoManagementClient extends coreClient.ServiceClient { credential: credentials }; - const packageDetails = `azsdk-js-arm-kusto/7.3.1`; + const packageDetails = `azsdk-js-arm-kusto/8.0.0`; const userAgentPrefix = options.userAgentOptions && options.userAgentOptions.userAgentPrefix ? `${options.userAgentOptions.userAgentPrefix} ${packageDetails}` diff --git a/sdk/kusto/arm-kusto/src/lroImpl.ts b/sdk/kusto/arm-kusto/src/lroImpl.ts index 518d5f053b4e..dd803cd5e28c 100644 --- a/sdk/kusto/arm-kusto/src/lroImpl.ts +++ b/sdk/kusto/arm-kusto/src/lroImpl.ts @@ -6,29 +6,37 @@ * Changes may cause incorrect behavior and will be lost if the code is regenerated. */ +// Copyright (c) Microsoft Corporation. +// Licensed under the MIT license. + +import { AbortSignalLike } from "@azure/abort-controller"; import { LongRunningOperation, LroResponse } from "@azure/core-lro"; -export class LroImpl implements LongRunningOperation { - constructor( - private sendOperationFn: (args: any, spec: any) => Promise>, - private args: Record, - private spec: { - readonly requestBody?: unknown; - readonly path?: string; - readonly httpMethod: string; - } & Record, - public requestPath: string = spec.path!, - public requestMethod: string = spec.httpMethod - ) {} - public async sendInitialRequest(): Promise> { - return this.sendOperationFn(this.args, this.spec); - } - public async sendPollRequest(path: string): Promise> { - const { requestBody, ...restSpec } = this.spec; - return this.sendOperationFn(this.args, { - ...restSpec, - path, - httpMethod: "GET" - }); - } +export function createLroSpec(inputs: { + sendOperationFn: (args: any, spec: any) => Promise>; + args: Record; + spec: { + readonly requestBody?: unknown; + readonly path?: string; + readonly httpMethod: string; + } & Record; +}): LongRunningOperation { + const { args, spec, sendOperationFn } = inputs; + return { + requestMethod: spec.httpMethod, + requestPath: spec.path!, + sendInitialRequest: () => sendOperationFn(args, spec), + sendPollRequest: ( + path: string, + options?: { abortSignal?: AbortSignalLike } + ) => { + const { requestBody, ...restSpec } = spec; + return sendOperationFn(args, { + ...restSpec, + httpMethod: "GET", + path, + abortSignal: options?.abortSignal + }); + } + }; } diff --git a/sdk/kusto/arm-kusto/src/models/index.ts b/sdk/kusto/arm-kusto/src/models/index.ts index 509c9c3f06ec..8ca49974c032 100644 --- a/sdk/kusto/arm-kusto/src/models/index.ts +++ b/sdk/kusto/arm-kusto/src/models/index.ts @@ -1654,10 +1654,6 @@ export enum KnownLanguageExtensionImageName { R = "R", /** Python365 */ Python365 = "Python3_6_5", - /** Python3912 */ - Python3912 = "Python3_9_12", - /** Python3912IncludeDeepLearning */ - Python3912IncludeDeepLearning = "Python3_9_12IncludeDeepLearning", /** Python3108 */ Python3108 = "Python3_10_8" } @@ -1669,8 +1665,6 @@ export enum KnownLanguageExtensionImageName { * ### Known values supported by the service * **R** \ * **Python3_6_5** \ - * **Python3_9_12** \ - * **Python3_9_12IncludeDeepLearning** \ * **Python3_10_8** */ export type LanguageExtensionImageName = string; diff --git a/sdk/kusto/arm-kusto/src/operations/attachedDatabaseConfigurations.ts b/sdk/kusto/arm-kusto/src/operations/attachedDatabaseConfigurations.ts index 06ff8e9b2b1e..843582c2c2d1 100644 --- a/sdk/kusto/arm-kusto/src/operations/attachedDatabaseConfigurations.ts +++ b/sdk/kusto/arm-kusto/src/operations/attachedDatabaseConfigurations.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { AttachedDatabaseConfiguration, AttachedDatabaseConfigurationsListByClusterOptionalParams, @@ -179,8 +183,8 @@ export class AttachedDatabaseConfigurationsImpl parameters: AttachedDatabaseConfiguration, options?: AttachedDatabaseConfigurationsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, AttachedDatabaseConfigurationsCreateOrUpdateResponse > > { @@ -190,7 +194,7 @@ export class AttachedDatabaseConfigurationsImpl ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -223,19 +227,22 @@ export class AttachedDatabaseConfigurationsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, attachedDatabaseConfigurationName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + AttachedDatabaseConfigurationsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -279,14 +286,14 @@ export class AttachedDatabaseConfigurationsImpl clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -319,18 +326,18 @@ export class AttachedDatabaseConfigurationsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, attachedDatabaseConfigurationName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/clusterPrincipalAssignments.ts b/sdk/kusto/arm-kusto/src/operations/clusterPrincipalAssignments.ts index b9d7c89048ac..e17d4d0623f8 100644 --- a/sdk/kusto/arm-kusto/src/operations/clusterPrincipalAssignments.ts +++ b/sdk/kusto/arm-kusto/src/operations/clusterPrincipalAssignments.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { ClusterPrincipalAssignment, ClusterPrincipalAssignmentsListOptionalParams, @@ -153,8 +157,8 @@ export class ClusterPrincipalAssignmentsImpl parameters: ClusterPrincipalAssignment, options?: ClusterPrincipalAssignmentsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClusterPrincipalAssignmentsCreateOrUpdateResponse > > { @@ -164,7 +168,7 @@ export class ClusterPrincipalAssignmentsImpl ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -197,19 +201,22 @@ export class ClusterPrincipalAssignmentsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, principalAssignmentName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + ClusterPrincipalAssignmentsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -253,14 +260,14 @@ export class ClusterPrincipalAssignmentsImpl clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -293,13 +300,18 @@ export class ClusterPrincipalAssignmentsImpl }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, principalAssignmentName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + principalAssignmentName, + options + }, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/clusters.ts b/sdk/kusto/arm-kusto/src/operations/clusters.ts index 8ad364215799..0bc8caedf7e0 100644 --- a/sdk/kusto/arm-kusto/src/operations/clusters.ts +++ b/sdk/kusto/arm-kusto/src/operations/clusters.ts @@ -13,8 +13,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { FollowerDatabaseDefinition, ClustersListFollowerDatabasesOptionalParams, @@ -518,8 +522,8 @@ export class ClustersImpl implements Clusters { parameters: Cluster, options?: ClustersCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersCreateOrUpdateResponse > > { @@ -529,7 +533,7 @@ export class ClustersImpl implements Clusters { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -562,13 +566,16 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, parameters, options }, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + ClustersCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -610,8 +617,8 @@ export class ClustersImpl implements Clusters { parameters: ClusterUpdate, options?: ClustersUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersUpdateResponse > > { @@ -621,7 +628,7 @@ export class ClustersImpl implements Clusters { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -654,13 +661,16 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, parameters, options }, - updateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, parameters, options }, + spec: updateOperationSpec + }); + const poller = await createHttpPoller< + ClustersUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -699,14 +709,14 @@ export class ClustersImpl implements Clusters { resourceGroupName: string, clusterName: string, options?: ClustersDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -739,13 +749,13 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, options }, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -781,14 +791,14 @@ export class ClustersImpl implements Clusters { resourceGroupName: string, clusterName: string, options?: ClustersStopOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -821,13 +831,13 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, options }, - stopOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, options }, + spec: stopOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -863,14 +873,14 @@ export class ClustersImpl implements Clusters { resourceGroupName: string, clusterName: string, options?: ClustersStartOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -903,13 +913,13 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, options }, - startOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, options }, + spec: startOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -964,14 +974,14 @@ export class ClustersImpl implements Clusters { clusterName: string, followerDatabaseToRemove: FollowerDatabaseDefinition, options?: ClustersDetachFollowerDatabasesOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -1004,13 +1014,18 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, followerDatabaseToRemove, options }, - detachFollowerDatabasesOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + followerDatabaseToRemove, + options + }, + spec: detachFollowerDatabasesOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -1050,8 +1065,8 @@ export class ClustersImpl implements Clusters { clusterName: string, options?: ClustersDiagnoseVirtualNetworkOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersDiagnoseVirtualNetworkResponse > > { @@ -1061,7 +1076,7 @@ export class ClustersImpl implements Clusters { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -1094,15 +1109,18 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, options }, - diagnoseVirtualNetworkOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, options }, + spec: diagnoseVirtualNetworkOperationSpec + }); + const poller = await createHttpPoller< + ClustersDiagnoseVirtualNetworkResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, - lroResourceLocationConfig: "location" + resourceLocationConfig: "location" }); await poller.poll(); return poller; @@ -1242,14 +1260,14 @@ export class ClustersImpl implements Clusters { clusterName: string, languageExtensionsToAdd: LanguageExtensionsList, options?: ClustersAddLanguageExtensionsOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -1282,13 +1300,18 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, languageExtensionsToAdd, options }, - addLanguageExtensionsOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + languageExtensionsToAdd, + options + }, + spec: addLanguageExtensionsOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -1329,14 +1352,14 @@ export class ClustersImpl implements Clusters { clusterName: string, languageExtensionsToRemove: LanguageExtensionsList, options?: ClustersRemoveLanguageExtensionsOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -1369,13 +1392,18 @@ export class ClustersImpl implements Clusters { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, languageExtensionsToRemove, options }, - removeLanguageExtensionsOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + languageExtensionsToRemove, + options + }, + spec: removeLanguageExtensionsOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/dataConnections.ts b/sdk/kusto/arm-kusto/src/operations/dataConnections.ts index 3fce933ed658..e76834542742 100644 --- a/sdk/kusto/arm-kusto/src/operations/dataConnections.ts +++ b/sdk/kusto/arm-kusto/src/operations/dataConnections.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { DataConnectionUnion, DataConnectionsListByDatabaseOptionalParams, @@ -154,8 +158,8 @@ export class DataConnectionsImpl implements DataConnections { parameters: DataConnectionValidation, options?: DataConnectionsDataConnectionValidationOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsDataConnectionValidationResponse > > { @@ -165,7 +169,7 @@ export class DataConnectionsImpl implements DataConnections { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -198,15 +202,24 @@ export class DataConnectionsImpl implements DataConnections { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, databaseName, parameters, options }, - dataConnectionValidationOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + databaseName, + parameters, + options + }, + spec: dataConnectionValidationOperationSpec + }); + const poller = await createHttpPoller< + DataConnectionsDataConnectionValidationResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, - lroResourceLocationConfig: "location" + resourceLocationConfig: "location" }); await poller.poll(); return poller; @@ -308,8 +321,8 @@ export class DataConnectionsImpl implements DataConnections { parameters: DataConnectionUnion, options?: DataConnectionsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsCreateOrUpdateResponse > > { @@ -319,7 +332,7 @@ export class DataConnectionsImpl implements DataConnections { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -352,9 +365,9 @@ export class DataConnectionsImpl implements DataConnections { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, @@ -362,10 +375,13 @@ export class DataConnectionsImpl implements DataConnections { parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + DataConnectionsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -417,8 +433,8 @@ export class DataConnectionsImpl implements DataConnections { parameters: DataConnectionUnion, options?: DataConnectionsUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsUpdateResponse > > { @@ -428,7 +444,7 @@ export class DataConnectionsImpl implements DataConnections { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -461,9 +477,9 @@ export class DataConnectionsImpl implements DataConnections { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, @@ -471,10 +487,13 @@ export class DataConnectionsImpl implements DataConnections { parameters, options }, - updateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: updateOperationSpec + }); + const poller = await createHttpPoller< + DataConnectionsUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -523,14 +542,14 @@ export class DataConnectionsImpl implements DataConnections { databaseName: string, dataConnectionName: string, options?: DataConnectionsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -563,19 +582,19 @@ export class DataConnectionsImpl implements DataConnections { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, dataConnectionName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/databasePrincipalAssignments.ts b/sdk/kusto/arm-kusto/src/operations/databasePrincipalAssignments.ts index 0c6aea18d6af..77d18234c8cc 100644 --- a/sdk/kusto/arm-kusto/src/operations/databasePrincipalAssignments.ts +++ b/sdk/kusto/arm-kusto/src/operations/databasePrincipalAssignments.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { DatabasePrincipalAssignment, DatabasePrincipalAssignmentsListOptionalParams, @@ -187,8 +191,8 @@ export class DatabasePrincipalAssignmentsImpl parameters: DatabasePrincipalAssignment, options?: DatabasePrincipalAssignmentsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasePrincipalAssignmentsCreateOrUpdateResponse > > { @@ -198,7 +202,7 @@ export class DatabasePrincipalAssignmentsImpl ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -231,9 +235,9 @@ export class DatabasePrincipalAssignmentsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, @@ -241,10 +245,13 @@ export class DatabasePrincipalAssignmentsImpl parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + DatabasePrincipalAssignmentsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -293,14 +300,14 @@ export class DatabasePrincipalAssignmentsImpl databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -333,19 +340,19 @@ export class DatabasePrincipalAssignmentsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, principalAssignmentName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/databases.ts b/sdk/kusto/arm-kusto/src/operations/databases.ts index 6837340a9aea..80c5506deea0 100644 --- a/sdk/kusto/arm-kusto/src/operations/databases.ts +++ b/sdk/kusto/arm-kusto/src/operations/databases.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { DatabaseUnion, DatabasesListByClusterOptionalParams, @@ -257,8 +261,8 @@ export class DatabasesImpl implements Databases { parameters: DatabaseUnion, options?: DatabasesCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasesCreateOrUpdateResponse > > { @@ -268,7 +272,7 @@ export class DatabasesImpl implements Databases { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -301,13 +305,22 @@ export class DatabasesImpl implements Databases { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, databaseName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + databaseName, + parameters, + options + }, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + DatabasesCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -354,8 +367,8 @@ export class DatabasesImpl implements Databases { parameters: DatabaseUnion, options?: DatabasesUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasesUpdateResponse > > { @@ -365,7 +378,7 @@ export class DatabasesImpl implements Databases { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -398,13 +411,22 @@ export class DatabasesImpl implements Databases { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, databaseName, parameters, options }, - updateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + databaseName, + parameters, + options + }, + spec: updateOperationSpec + }); + const poller = await createHttpPoller< + DatabasesUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -448,14 +470,14 @@ export class DatabasesImpl implements Databases { clusterName: string, databaseName: string, options?: DatabasesDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -488,13 +510,13 @@ export class DatabasesImpl implements Databases { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, databaseName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, options }, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/managedPrivateEndpoints.ts b/sdk/kusto/arm-kusto/src/operations/managedPrivateEndpoints.ts index 94664631148b..ff662f7b0faa 100644 --- a/sdk/kusto/arm-kusto/src/operations/managedPrivateEndpoints.ts +++ b/sdk/kusto/arm-kusto/src/operations/managedPrivateEndpoints.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { ManagedPrivateEndpoint, ManagedPrivateEndpointsListOptionalParams, @@ -171,8 +175,8 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ManagedPrivateEndpointsCreateOrUpdateResponse > > { @@ -182,7 +186,7 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -215,19 +219,22 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, managedPrivateEndpointName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + ManagedPrivateEndpointsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -274,8 +281,8 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ManagedPrivateEndpointsUpdateResponse > > { @@ -285,7 +292,7 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -318,19 +325,22 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, managedPrivateEndpointName, parameters, options }, - updateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: updateOperationSpec + }); + const poller = await createHttpPoller< + ManagedPrivateEndpointsUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -374,14 +384,14 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -414,13 +424,18 @@ export class ManagedPrivateEndpointsImpl implements ManagedPrivateEndpoints { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, managedPrivateEndpointName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + managedPrivateEndpointName, + options + }, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/privateEndpointConnections.ts b/sdk/kusto/arm-kusto/src/operations/privateEndpointConnections.ts index 562c0f7cd2f5..c793789480a3 100644 --- a/sdk/kusto/arm-kusto/src/operations/privateEndpointConnections.ts +++ b/sdk/kusto/arm-kusto/src/operations/privateEndpointConnections.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { PrivateEndpointConnection, PrivateEndpointConnectionsListOptionalParams, @@ -153,8 +157,8 @@ export class PrivateEndpointConnectionsImpl parameters: PrivateEndpointConnection, options?: PrivateEndpointConnectionsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, PrivateEndpointConnectionsCreateOrUpdateResponse > > { @@ -164,7 +168,7 @@ export class PrivateEndpointConnectionsImpl ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -197,19 +201,22 @@ export class PrivateEndpointConnectionsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, privateEndpointConnectionName, parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + PrivateEndpointConnectionsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -253,14 +260,14 @@ export class PrivateEndpointConnectionsImpl clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -293,18 +300,18 @@ export class PrivateEndpointConnectionsImpl }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, privateEndpointConnectionName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); diff --git a/sdk/kusto/arm-kusto/src/operations/scripts.ts b/sdk/kusto/arm-kusto/src/operations/scripts.ts index a4fd20ebd39b..b8e2576c2aed 100644 --- a/sdk/kusto/arm-kusto/src/operations/scripts.ts +++ b/sdk/kusto/arm-kusto/src/operations/scripts.ts @@ -12,8 +12,12 @@ import * as coreClient from "@azure/core-client"; import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { KustoManagementClient } from "../kustoManagementClient"; -import { PollerLike, PollOperationState, LroEngine } from "@azure/core-lro"; -import { LroImpl } from "../lroImpl"; +import { + SimplePollerLike, + OperationState, + createHttpPoller +} from "@azure/core-lro"; +import { createLroSpec } from "../lroImpl"; import { Script, ScriptsListByDatabaseOptionalParams, @@ -174,8 +178,8 @@ export class ScriptsImpl implements Scripts { parameters: Script, options?: ScriptsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ScriptsCreateOrUpdateResponse > > { @@ -185,7 +189,7 @@ export class ScriptsImpl implements Scripts { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -218,9 +222,9 @@ export class ScriptsImpl implements Scripts { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, @@ -228,10 +232,13 @@ export class ScriptsImpl implements Scripts { parameters, options }, - createOrUpdateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: createOrUpdateOperationSpec + }); + const poller = await createHttpPoller< + ScriptsCreateOrUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -283,7 +290,10 @@ export class ScriptsImpl implements Scripts { parameters: Script, options?: ScriptsUpdateOptionalParams ): Promise< - PollerLike, ScriptsUpdateResponse> + SimplePollerLike< + OperationState, + ScriptsUpdateResponse + > > { const directSendOperation = async ( args: coreClient.OperationArguments, @@ -291,7 +301,7 @@ export class ScriptsImpl implements Scripts { ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -324,9 +334,9 @@ export class ScriptsImpl implements Scripts { }; }; - const lro = new LroImpl( - sendOperation, - { + const lro = createLroSpec({ + sendOperationFn, + args: { resourceGroupName, clusterName, databaseName, @@ -334,10 +344,13 @@ export class ScriptsImpl implements Scripts { parameters, options }, - updateOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + spec: updateOperationSpec + }); + const poller = await createHttpPoller< + ScriptsUpdateResponse, + OperationState + >(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -373,7 +386,7 @@ export class ScriptsImpl implements Scripts { } /** - * Deletes a Kusto principalAssignment. + * Deletes a Kusto database script. * @param resourceGroupName The name of the resource group containing the Kusto cluster. * @param clusterName The name of the Kusto cluster. * @param databaseName The name of the database in the Kusto cluster. @@ -386,14 +399,14 @@ export class ScriptsImpl implements Scripts { databaseName: string, scriptName: string, options?: ScriptsDeleteOptionalParams - ): Promise, void>> { + ): Promise, void>> { const directSendOperation = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ): Promise => { return this.client.sendOperationRequest(args, spec); }; - const sendOperation = async ( + const sendOperationFn = async ( args: coreClient.OperationArguments, spec: coreClient.OperationSpec ) => { @@ -426,13 +439,19 @@ export class ScriptsImpl implements Scripts { }; }; - const lro = new LroImpl( - sendOperation, - { resourceGroupName, clusterName, databaseName, scriptName, options }, - deleteOperationSpec - ); - const poller = new LroEngine(lro, { - resumeFrom: options?.resumeFrom, + const lro = createLroSpec({ + sendOperationFn, + args: { + resourceGroupName, + clusterName, + databaseName, + scriptName, + options + }, + spec: deleteOperationSpec + }); + const poller = await createHttpPoller>(lro, { + restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs }); await poller.poll(); @@ -440,7 +459,7 @@ export class ScriptsImpl implements Scripts { } /** - * Deletes a Kusto principalAssignment. + * Deletes a Kusto database script. * @param resourceGroupName The name of the resource group containing the Kusto cluster. * @param clusterName The name of the Kusto cluster. * @param databaseName The name of the database in the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/attachedDatabaseConfigurations.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/attachedDatabaseConfigurations.ts index 311e55588ce4..63208a5b41b8 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/attachedDatabaseConfigurations.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/attachedDatabaseConfigurations.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { AttachedDatabaseConfiguration, AttachedDatabaseConfigurationsListByClusterOptionalParams, @@ -76,8 +76,8 @@ export interface AttachedDatabaseConfigurations { parameters: AttachedDatabaseConfiguration, options?: AttachedDatabaseConfigurationsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, AttachedDatabaseConfigurationsCreateOrUpdateResponse > >; @@ -108,7 +108,7 @@ export interface AttachedDatabaseConfigurations { clusterName: string, attachedDatabaseConfigurationName: string, options?: AttachedDatabaseConfigurationsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes the attached database configuration with the given name. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/clusterPrincipalAssignments.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/clusterPrincipalAssignments.ts index 498e02c5ba29..15b739708e48 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/clusterPrincipalAssignments.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/clusterPrincipalAssignments.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { ClusterPrincipalAssignment, ClusterPrincipalAssignmentsListOptionalParams, @@ -76,8 +76,8 @@ export interface ClusterPrincipalAssignments { parameters: ClusterPrincipalAssignment, options?: ClusterPrincipalAssignmentsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClusterPrincipalAssignmentsCreateOrUpdateResponse > >; @@ -108,7 +108,7 @@ export interface ClusterPrincipalAssignments { clusterName: string, principalAssignmentName: string, options?: ClusterPrincipalAssignmentsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes a Kusto cluster principalAssignment. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/clusters.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/clusters.ts index 66a3ab787b6f..aabee655686c 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/clusters.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/clusters.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { FollowerDatabaseDefinition, ClustersListFollowerDatabasesOptionalParams, @@ -137,8 +137,8 @@ export interface Clusters { parameters: Cluster, options?: ClustersCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersCreateOrUpdateResponse > >; @@ -168,8 +168,8 @@ export interface Clusters { parameters: ClusterUpdate, options?: ClustersUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersUpdateResponse > >; @@ -196,7 +196,7 @@ export interface Clusters { resourceGroupName: string, clusterName: string, options?: ClustersDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes a Kusto cluster. * @param resourceGroupName The name of the resource group containing the Kusto cluster. @@ -218,7 +218,7 @@ export interface Clusters { resourceGroupName: string, clusterName: string, options?: ClustersStopOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Stops a Kusto cluster. * @param resourceGroupName The name of the resource group containing the Kusto cluster. @@ -240,7 +240,7 @@ export interface Clusters { resourceGroupName: string, clusterName: string, options?: ClustersStartOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Starts a Kusto cluster. * @param resourceGroupName The name of the resource group containing the Kusto cluster. @@ -264,7 +264,7 @@ export interface Clusters { clusterName: string, followerDatabaseToRemove: FollowerDatabaseDefinition, options?: ClustersDetachFollowerDatabasesOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Detaches all followers of a database owned by this cluster. * @param resourceGroupName The name of the resource group containing the Kusto cluster. @@ -289,8 +289,8 @@ export interface Clusters { clusterName: string, options?: ClustersDiagnoseVirtualNetworkOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ClustersDiagnoseVirtualNetworkResponse > >; @@ -328,7 +328,7 @@ export interface Clusters { clusterName: string, languageExtensionsToAdd: LanguageExtensionsList, options?: ClustersAddLanguageExtensionsOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Add a list of language extensions that can run within KQL queries. * @param resourceGroupName The name of the resource group containing the Kusto cluster. @@ -354,7 +354,7 @@ export interface Clusters { clusterName: string, languageExtensionsToRemove: LanguageExtensionsList, options?: ClustersRemoveLanguageExtensionsOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Remove a list of language extensions that can run within KQL queries. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/dataConnections.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/dataConnections.ts index 1242a6633f01..9a7c751d277c 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/dataConnections.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/dataConnections.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { DataConnectionUnion, DataConnectionsListByDatabaseOptionalParams, @@ -57,8 +57,8 @@ export interface DataConnections { parameters: DataConnectionValidation, options?: DataConnectionsDataConnectionValidationOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsDataConnectionValidationResponse > >; @@ -124,8 +124,8 @@ export interface DataConnections { parameters: DataConnectionUnion, options?: DataConnectionsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsCreateOrUpdateResponse > >; @@ -163,8 +163,8 @@ export interface DataConnections { parameters: DataConnectionUnion, options?: DataConnectionsUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DataConnectionsUpdateResponse > >; @@ -199,7 +199,7 @@ export interface DataConnections { databaseName: string, dataConnectionName: string, options?: DataConnectionsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes the data connection with the given name. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/databasePrincipalAssignments.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/databasePrincipalAssignments.ts index 8411f4998740..02860068d3d5 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/databasePrincipalAssignments.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/databasePrincipalAssignments.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { DatabasePrincipalAssignment, DatabasePrincipalAssignmentsListOptionalParams, @@ -84,8 +84,8 @@ export interface DatabasePrincipalAssignments { parameters: DatabasePrincipalAssignment, options?: DatabasePrincipalAssignmentsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasePrincipalAssignmentsCreateOrUpdateResponse > >; @@ -120,7 +120,7 @@ export interface DatabasePrincipalAssignments { databaseName: string, principalAssignmentName: string, options?: DatabasePrincipalAssignmentsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes a Kusto principalAssignment. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/databases.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/databases.ts index 526561869aea..607a449726f2 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/databases.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/databases.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { DatabaseUnion, DatabasesListByClusterOptionalParams, @@ -98,8 +98,8 @@ export interface Databases { parameters: DatabaseUnion, options?: DatabasesCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasesCreateOrUpdateResponse > >; @@ -133,8 +133,8 @@ export interface Databases { parameters: DatabaseUnion, options?: DatabasesUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, DatabasesUpdateResponse > >; @@ -165,7 +165,7 @@ export interface Databases { clusterName: string, databaseName: string, options?: DatabasesDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes the database with the given name. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/managedPrivateEndpoints.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/managedPrivateEndpoints.ts index f44095331587..65b335cb7c3f 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/managedPrivateEndpoints.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/managedPrivateEndpoints.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { ManagedPrivateEndpoint, ManagedPrivateEndpointsListOptionalParams, @@ -78,8 +78,8 @@ export interface ManagedPrivateEndpoints { parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ManagedPrivateEndpointsCreateOrUpdateResponse > >; @@ -113,8 +113,8 @@ export interface ManagedPrivateEndpoints { parameters: ManagedPrivateEndpoint, options?: ManagedPrivateEndpointsUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ManagedPrivateEndpointsUpdateResponse > >; @@ -145,7 +145,7 @@ export interface ManagedPrivateEndpoints { clusterName: string, managedPrivateEndpointName: string, options?: ManagedPrivateEndpointsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes a managed private endpoint. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/privateEndpointConnections.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/privateEndpointConnections.ts index 791294b684c7..587de7d202c2 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/privateEndpointConnections.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/privateEndpointConnections.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { PrivateEndpointConnection, PrivateEndpointConnectionsListOptionalParams, @@ -60,8 +60,8 @@ export interface PrivateEndpointConnections { parameters: PrivateEndpointConnection, options?: PrivateEndpointConnectionsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, PrivateEndpointConnectionsCreateOrUpdateResponse > >; @@ -92,7 +92,7 @@ export interface PrivateEndpointConnections { clusterName: string, privateEndpointConnectionName: string, options?: PrivateEndpointConnectionsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** * Deletes a private endpoint connection with a given name. * @param resourceGroupName The name of the resource group containing the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/src/operationsInterfaces/scripts.ts b/sdk/kusto/arm-kusto/src/operationsInterfaces/scripts.ts index 0fa2fe931975..091095b8154d 100644 --- a/sdk/kusto/arm-kusto/src/operationsInterfaces/scripts.ts +++ b/sdk/kusto/arm-kusto/src/operationsInterfaces/scripts.ts @@ -7,7 +7,7 @@ */ import { PagedAsyncIterableIterator } from "@azure/core-paging"; -import { PollerLike, PollOperationState } from "@azure/core-lro"; +import { SimplePollerLike, OperationState } from "@azure/core-lro"; import { Script, ScriptsListByDatabaseOptionalParams, @@ -71,8 +71,8 @@ export interface Scripts { parameters: Script, options?: ScriptsCreateOrUpdateOptionalParams ): Promise< - PollerLike< - PollOperationState, + SimplePollerLike< + OperationState, ScriptsCreateOrUpdateResponse > >; @@ -110,7 +110,10 @@ export interface Scripts { parameters: Script, options?: ScriptsUpdateOptionalParams ): Promise< - PollerLike, ScriptsUpdateResponse> + SimplePollerLike< + OperationState, + ScriptsUpdateResponse + > >; /** * Updates a database script. @@ -130,7 +133,7 @@ export interface Scripts { options?: ScriptsUpdateOptionalParams ): Promise; /** - * Deletes a Kusto principalAssignment. + * Deletes a Kusto database script. * @param resourceGroupName The name of the resource group containing the Kusto cluster. * @param clusterName The name of the Kusto cluster. * @param databaseName The name of the database in the Kusto cluster. @@ -143,9 +146,9 @@ export interface Scripts { databaseName: string, scriptName: string, options?: ScriptsDeleteOptionalParams - ): Promise, void>>; + ): Promise, void>>; /** - * Deletes a Kusto principalAssignment. + * Deletes a Kusto database script. * @param resourceGroupName The name of the resource group containing the Kusto cluster. * @param clusterName The name of the Kusto cluster. * @param databaseName The name of the database in the Kusto cluster. diff --git a/sdk/kusto/arm-kusto/test/sampleTest.ts b/sdk/kusto/arm-kusto/test/sampleTest.ts new file mode 100644 index 000000000000..25aeb3ebcc36 --- /dev/null +++ b/sdk/kusto/arm-kusto/test/sampleTest.ts @@ -0,0 +1,43 @@ +/* + * Copyright (c) Microsoft Corporation. + * Licensed under the MIT License. + * + * Code generated by Microsoft (R) AutoRest Code Generator. + * Changes may cause incorrect behavior and will be lost if the code is regenerated. + */ + +import { + Recorder, + RecorderStartOptions, + env +} from "@azure-tools/test-recorder"; +import { assert } from "chai"; +import { Context } from "mocha"; + +const replaceableVariables: Record = { + AZURE_CLIENT_ID: "azure_client_id", + AZURE_CLIENT_SECRET: "azure_client_secret", + AZURE_TENANT_ID: "88888888-8888-8888-8888-888888888888", + SUBSCRIPTION_ID: "azure_subscription_id" +}; + +const recorderOptions: RecorderStartOptions = { + envSetupForPlayback: replaceableVariables +}; + +describe("My test", () => { + let recorder: Recorder; + + beforeEach(async function(this: Context) { + recorder = new Recorder(this.currentTest); + await recorder.start(recorderOptions); + }); + + afterEach(async function() { + await recorder.stop(); + }); + + it("sample test", async function() { + console.log("Hi, I'm a test!"); + }); +}); diff --git a/sdk/kusto/arm-kusto/tsconfig.json b/sdk/kusto/arm-kusto/tsconfig.json index 8864a1f3f475..3e6ae96443f3 100644 --- a/sdk/kusto/arm-kusto/tsconfig.json +++ b/sdk/kusto/arm-kusto/tsconfig.json @@ -15,17 +15,11 @@ ], "declaration": true, "outDir": "./dist-esm", - "importHelpers": true, - "paths": { - "@azure/arm-kusto": [ - "./src/index" - ] - } + "importHelpers": true }, "include": [ "./src/**/*.ts", - "./test/**/*.ts", - "samples-dev/**/*.ts" + "./test/**/*.ts" ], "exclude": [ "node_modules"