From 95199903b1500c907cf269c8a4a7c66dfc056924 Mon Sep 17 00:00:00 2001 From: Azure SDK Bot <53356347+azure-sdk@users.noreply.github.com> Date: Thu, 21 Sep 2023 01:02:41 -0700 Subject: [PATCH] [Release] sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/1.0.0 (#21483) * [Release] sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/1.0.0 generation from spec commit: 80c21c17b4a7aa57f637ee594f7cfd653255a7e0 * update changelog --------- Co-authored-by: ReleaseHelper Co-authored-by: Alancere <804873052@qq.com> --- .../armcosmosforpostgresql/CHANGELOG.md | 5 + .../armcosmosforpostgresql/autorest.md | 6 +- .../armcosmosforpostgresql/client_factory.go | 23 +- .../armcosmosforpostgresql/clusters_client.go | 131 ++++-- .../clusters_client_example_test.go | 409 +++++++++++++++--- .../configurations_client.go | 72 +-- .../configurations_client_example_test.go | 14 +- .../armcosmosforpostgresql/constants.go | 5 +- .../firewallrules_client.go | 45 +- .../firewallrules_client_example_test.go | 8 +- .../armcosmosforpostgresql/go.mod | 4 +- .../armcosmosforpostgresql/go.sum | 4 +- .../armcosmosforpostgresql/models.go | 214 +-------- .../armcosmosforpostgresql/models_serde.go | 3 +- .../operations_client.go | 3 +- .../operations_client_example_test.go | 2 +- .../armcosmosforpostgresql/options.go | 214 +++++++++ .../privateendpointconnections_client.go | 45 +- ...endpointconnections_client_example_test.go | 8 +- .../privatelinkresources_client.go | 14 +- ...rivatelinkresources_client_example_test.go | 4 +- .../armcosmosforpostgresql/response_types.go | 30 +- .../armcosmosforpostgresql/roles_client.go | 45 +- .../roles_client_example_test.go | 8 +- .../armcosmosforpostgresql/servers_client.go | 14 +- .../servers_client_example_test.go | 4 +- .../armcosmosforpostgresql/time_rfc3339.go | 3 +- 27 files changed, 872 insertions(+), 465 deletions(-) create mode 100644 sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/options.go diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/CHANGELOG.md b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/CHANGELOG.md index c667e9a49946..7bf9697b9a4a 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/CHANGELOG.md +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/CHANGELOG.md @@ -1,5 +1,10 @@ # Release History +## 1.0.0 (2023-09-22) +### Other Changes + +- Release stable version. + ## 0.1.0 (2023-06-23) The package of `github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql` is using our [next generation design principles](https://azure.github.io/azure-sdk/general_introduction.html). diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/autorest.md b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/autorest.md index 287f406a9a88..7fc7f2ee55ac 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/autorest.md +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/autorest.md @@ -5,9 +5,9 @@ ``` yaml azure-arm: true require: -- https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/readme.md -- https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/readme.go.md +- https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/readme.md +- https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/readme.go.md license-header: MICROSOFT_MIT_NO_VERSION -module-version: 0.1.0 +module-version: 1.0.0 tag: package-2022-11-08 ``` \ No newline at end of file diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/client_factory.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/client_factory.go index 4009535a3902..e3c894e2ae12 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/client_factory.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/client_factory.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -43,11 +42,6 @@ func (c *ClientFactory) NewClustersClient() *ClustersClient { return subClient } -func (c *ClientFactory) NewServersClient() *ServersClient { - subClient, _ := NewServersClient(c.subscriptionID, c.credential, c.options) - return subClient -} - func (c *ClientFactory) NewConfigurationsClient() *ConfigurationsClient { subClient, _ := NewConfigurationsClient(c.subscriptionID, c.credential, c.options) return subClient @@ -58,11 +52,6 @@ func (c *ClientFactory) NewFirewallRulesClient() *FirewallRulesClient { return subClient } -func (c *ClientFactory) NewRolesClient() *RolesClient { - subClient, _ := NewRolesClient(c.subscriptionID, c.credential, c.options) - return subClient -} - func (c *ClientFactory) NewOperationsClient() *OperationsClient { subClient, _ := NewOperationsClient(c.credential, c.options) return subClient @@ -77,3 +66,13 @@ func (c *ClientFactory) NewPrivateLinkResourcesClient() *PrivateLinkResourcesCli subClient, _ := NewPrivateLinkResourcesClient(c.subscriptionID, c.credential, c.options) return subClient } + +func (c *ClientFactory) NewRolesClient() *RolesClient { + subClient, _ := NewRolesClient(c.subscriptionID, c.credential, c.options) + return subClient +} + +func (c *ClientFactory) NewServersClient() *ServersClient { + subClient, _ := NewServersClient(c.subscriptionID, c.credential, c.options) + return subClient +} diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client.go index a97853d2abda..355b7bc337fa 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -54,18 +53,21 @@ func NewClustersClient(subscriptionID string, credential azcore.TokenCredential, // - options - ClustersClientCheckNameAvailabilityOptions contains the optional parameters for the ClustersClient.CheckNameAvailability // method. func (client *ClustersClient) CheckNameAvailability(ctx context.Context, nameAvailabilityRequest NameAvailabilityRequest, options *ClustersClientCheckNameAvailabilityOptions) (ClustersClientCheckNameAvailabilityResponse, error) { + var err error req, err := client.checkNameAvailabilityCreateRequest(ctx, nameAvailabilityRequest, options) if err != nil { return ClustersClientCheckNameAvailabilityResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ClustersClientCheckNameAvailabilityResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ClustersClientCheckNameAvailabilityResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ClustersClientCheckNameAvailabilityResponse{}, err } - return client.checkNameAvailabilityHandleResponse(resp) + resp, err := client.checkNameAvailabilityHandleResponse(httpResp) + return resp, err } // checkNameAvailabilityCreateRequest creates the CheckNameAvailability request. @@ -80,7 +82,10 @@ func (client *ClustersClient) checkNameAvailabilityCreateRequest(ctx context.Con reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, nameAvailabilityRequest) + if err := runtime.MarshalAsJSON(req, nameAvailabilityRequest); err != nil { + return nil, err + } + return req, nil } // checkNameAvailabilityHandleResponse handles the CheckNameAvailability response. @@ -106,9 +111,10 @@ func (client *ClustersClient) BeginCreate(ctx context.Context, resourceGroupName if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientCreateResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientCreateResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientCreateResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -119,18 +125,20 @@ func (client *ClustersClient) BeginCreate(ctx context.Context, resourceGroupName // // Generated from API version 2022-11-08 func (client *ClustersClient) create(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, options *ClustersClientBeginCreateOptions) (*http.Response, error) { + var err error req, err := client.createCreateRequest(ctx, resourceGroupName, clusterName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // createCreateRequest creates the Create request. @@ -153,7 +161,10 @@ func (client *ClustersClient) createCreateRequest(ctx context.Context, resourceG reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } // BeginDelete - Deletes a cluster together with servers in it. @@ -169,9 +180,10 @@ func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientDeleteResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientDeleteResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientDeleteResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -182,18 +194,20 @@ func (client *ClustersClient) BeginDelete(ctx context.Context, resourceGroupName // // Generated from API version 2022-11-08 func (client *ClustersClient) deleteOperation(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginDeleteOptions) (*http.Response, error) { + var err error req, err := client.deleteCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusAccepted, http.StatusNoContent) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusAccepted, http.StatusNoContent) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // deleteCreateRequest creates the Delete request. @@ -228,18 +242,21 @@ func (client *ClustersClient) deleteCreateRequest(ctx context.Context, resourceG // - clusterName - The name of the cluster. // - options - ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method. func (client *ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientGetOptions) (ClustersClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return ClustersClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ClustersClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ClustersClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ClustersClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. @@ -406,9 +423,10 @@ func (client *ClustersClient) BeginPromoteReadReplica(ctx context.Context, resou if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientPromoteReadReplicaResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientPromoteReadReplicaResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientPromoteReadReplicaResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -419,18 +437,20 @@ func (client *ClustersClient) BeginPromoteReadReplica(ctx context.Context, resou // // Generated from API version 2022-11-08 func (client *ClustersClient) promoteReadReplica(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginPromoteReadReplicaOptions) (*http.Response, error) { + var err error req, err := client.promoteReadReplicaCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusAccepted) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusAccepted) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // promoteReadReplicaCreateRequest creates the PromoteReadReplica request. @@ -469,9 +489,10 @@ func (client *ClustersClient) BeginRestart(ctx context.Context, resourceGroupNam if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientRestartResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientRestartResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientRestartResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -482,18 +503,20 @@ func (client *ClustersClient) BeginRestart(ctx context.Context, resourceGroupNam // // Generated from API version 2022-11-08 func (client *ClustersClient) restart(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginRestartOptions) (*http.Response, error) { + var err error req, err := client.restartCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusAccepted) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusAccepted) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // restartCreateRequest creates the Restart request. @@ -532,9 +555,10 @@ func (client *ClustersClient) BeginStart(ctx context.Context, resourceGroupName if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientStartResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientStartResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientStartResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -545,18 +569,20 @@ func (client *ClustersClient) BeginStart(ctx context.Context, resourceGroupName // // Generated from API version 2022-11-08 func (client *ClustersClient) start(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginStartOptions) (*http.Response, error) { + var err error req, err := client.startCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusAccepted) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusAccepted) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // startCreateRequest creates the Start request. @@ -595,9 +621,10 @@ func (client *ClustersClient) BeginStop(ctx context.Context, resourceGroupName s if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientStopResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientStopResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientStopResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -608,18 +635,20 @@ func (client *ClustersClient) BeginStop(ctx context.Context, resourceGroupName s // // Generated from API version 2022-11-08 func (client *ClustersClient) stop(ctx context.Context, resourceGroupName string, clusterName string, options *ClustersClientBeginStopOptions) (*http.Response, error) { + var err error req, err := client.stopCreateRequest(ctx, resourceGroupName, clusterName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusAccepted) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusAccepted) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // stopCreateRequest creates the Stop request. @@ -659,9 +688,10 @@ func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientUpdateResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ClustersClientUpdateResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ClustersClientUpdateResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -672,18 +702,20 @@ func (client *ClustersClient) BeginUpdate(ctx context.Context, resourceGroupName // // Generated from API version 2022-11-08 func (client *ClustersClient) update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterForUpdate, options *ClustersClientBeginUpdateOptions) (*http.Response, error) { + var err error req, err := client.updateCreateRequest(ctx, resourceGroupName, clusterName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusAccepted) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusAccepted) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // updateCreateRequest creates the Update request. @@ -706,5 +738,8 @@ func (client *ClustersClient) updateCreateRequest(ctx context.Context, resourceG reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client_example_test.go index 34c8d15a4640..fa4348ec4673 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/clusters_client_example_test.go @@ -20,7 +20,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterList.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterList.json func ExampleClustersClient_NewListPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -165,7 +165,7 @@ func ExampleClustersClient_NewListPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterListByResourceGroup.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterListByResourceGroup.json func ExampleClustersClient_NewListByResourceGroupPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -318,8 +318,8 @@ func ExampleClustersClient_NewListByResourceGroupPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreate.json -func ExampleClustersClient_BeginCreate_createANewCluster() { +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreatePITR.json +func ExampleClustersClient_BeginCreate_createANewClusterAsAPointInTimeRestore() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) @@ -331,23 +331,10 @@ func ExampleClustersClient_BeginCreate_createANewCluster() { } poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster", armcosmosforpostgresql.Cluster{ Location: to.Ptr("westus"), - Tags: map[string]*string{}, Properties: &armcosmosforpostgresql.ClusterProperties{ - AdministratorLoginPassword: to.Ptr("password"), - CitusVersion: to.Ptr("11.1"), - CoordinatorEnablePublicIPAccess: to.Ptr(true), - CoordinatorServerEdition: to.Ptr("GeneralPurpose"), - CoordinatorStorageQuotaInMb: to.Ptr[int32](524288), - CoordinatorVCores: to.Ptr[int32](4), - EnableHa: to.Ptr(true), - EnableShardsOnCoordinator: to.Ptr(false), - NodeCount: to.Ptr[int32](3), - NodeEnablePublicIPAccess: to.Ptr(false), - NodeServerEdition: to.Ptr("MemoryOptimized"), - NodeStorageQuotaInMb: to.Ptr[int32](524288), - NodeVCores: to.Ptr[int32](8), - PostgresqlVersion: to.Ptr("15"), - PreferredPrimaryZone: to.Ptr("1"), + PointInTimeUTC: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-12-14T00:00:37.467Z"); return t }()), + SourceLocation: to.Ptr("westus"), + SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/source-cluster"), }, }, nil) if err != nil { @@ -365,16 +352,14 @@ func ExampleClustersClient_BeginCreate_createANewCluster() { // Type: to.Ptr("Microsoft.DBforPostgreSQL/serverGroupsv2"), // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster"), // SystemData: &armcosmosforpostgresql.SystemData{ - // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-01T17:18:19.1234567Z"); return t}()), + // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2020-01-01T17:18:19.1234567Z"); return t}()), // CreatedBy: to.Ptr("user1"), // CreatedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), - // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-02T17:18:19.1234567Z"); return t}()), + // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2020-01-02T17:18:19.1234567Z"); return t}()), // LastModifiedBy: to.Ptr("user2"), // LastModifiedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), // }, // Location: to.Ptr("westus"), - // Tags: map[string]*string{ - // }, // Properties: &armcosmosforpostgresql.ClusterProperties{ // AdministratorLogin: to.Ptr("citus"), // CitusVersion: to.Ptr("11.1"), @@ -390,7 +375,7 @@ func ExampleClustersClient_BeginCreate_createANewCluster() { // StartHour: to.Ptr[int32](0), // StartMinute: to.Ptr[int32](0), // }, - // NodeCount: to.Ptr[int32](3), + // NodeCount: to.Ptr[int32](1), // NodeEnablePublicIPAccess: to.Ptr(false), // NodeServerEdition: to.Ptr("MemoryOptimized"), // NodeStorageQuotaInMb: to.Ptr[int32](524288), @@ -410,22 +395,15 @@ func ExampleClustersClient_BeginCreate_createANewCluster() { // { // Name: to.Ptr("testcluster-w0"), // FullyQualifiedDomainName: to.Ptr("w0.testcluster.postgres.database.azure.com"), - // }, - // { - // Name: to.Ptr("testcluster-w2"), - // FullyQualifiedDomainName: to.Ptr("w0.testcluster.postgres.database.azure.com"), - // }, - // { - // Name: to.Ptr("testcluster-w3"), - // FullyQualifiedDomainName: to.Ptr("w0.testcluster.postgres.database.azure.com"), // }}, + // SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/source-cluster"), // State: to.Ptr("Provisioning"), // }, // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreatePITR.json -func ExampleClustersClient_BeginCreate_createANewClusterAsAPointInTimeRestore() { +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateReadReplica.json +func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) @@ -438,9 +416,8 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAPointInTimeRestore() poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster", armcosmosforpostgresql.Cluster{ Location: to.Ptr("westus"), Properties: &armcosmosforpostgresql.ClusterProperties{ - PointInTimeUTC: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-12-14T00:00:37.467Z"); return t }()), SourceLocation: to.Ptr("westus"), - SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/source-cluster"), + SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/sourcecluster"), }, }, nil) if err != nil { @@ -502,14 +479,14 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAPointInTimeRestore() // Name: to.Ptr("testcluster-w0"), // FullyQualifiedDomainName: to.Ptr("w0.testcluster.postgres.database.azure.com"), // }}, - // SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/source-cluster"), + // SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/sourcecluster"), // State: to.Ptr("Provisioning"), // }, // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateReadReplica.json -func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateMultiNode.json +func ExampleClustersClient_BeginCreate_createANewMultiNodeCluster() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) @@ -519,11 +496,25 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { if err != nil { log.Fatalf("failed to create client: %v", err) } - poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster", armcosmosforpostgresql.Cluster{ + poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster-multinode", armcosmosforpostgresql.Cluster{ Location: to.Ptr("westus"), + Tags: map[string]*string{}, Properties: &armcosmosforpostgresql.ClusterProperties{ - SourceLocation: to.Ptr("westus"), - SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/sourcecluster"), + AdministratorLoginPassword: to.Ptr("password"), + CitusVersion: to.Ptr("11.1"), + CoordinatorEnablePublicIPAccess: to.Ptr(true), + CoordinatorServerEdition: to.Ptr("GeneralPurpose"), + CoordinatorStorageQuotaInMb: to.Ptr[int32](524288), + CoordinatorVCores: to.Ptr[int32](4), + EnableHa: to.Ptr(true), + EnableShardsOnCoordinator: to.Ptr(false), + NodeCount: to.Ptr[int32](3), + NodeEnablePublicIPAccess: to.Ptr(false), + NodeServerEdition: to.Ptr("MemoryOptimized"), + NodeStorageQuotaInMb: to.Ptr[int32](524288), + NodeVCores: to.Ptr[int32](8), + PostgresqlVersion: to.Ptr("15"), + PreferredPrimaryZone: to.Ptr("1"), }, }, nil) if err != nil { @@ -537,18 +528,20 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { _ = res // If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes. // res.Cluster = armcosmosforpostgresql.Cluster{ - // Name: to.Ptr("testcluster"), + // Name: to.Ptr("testcluster-multinode"), // Type: to.Ptr("Microsoft.DBforPostgreSQL/serverGroupsv2"), - // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster"), + // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster-multinode"), // SystemData: &armcosmosforpostgresql.SystemData{ - // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2020-01-01T17:18:19.1234567Z"); return t}()), + // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-01T17:18:19.1234567Z"); return t}()), // CreatedBy: to.Ptr("user1"), // CreatedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), - // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2020-01-02T17:18:19.1234567Z"); return t}()), + // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-02T17:18:19.1234567Z"); return t}()), // LastModifiedBy: to.Ptr("user2"), // LastModifiedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), // }, // Location: to.Ptr("westus"), + // Tags: map[string]*string{ + // }, // Properties: &armcosmosforpostgresql.ClusterProperties{ // AdministratorLogin: to.Ptr("citus"), // CitusVersion: to.Ptr("11.1"), @@ -564,7 +557,7 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { // StartHour: to.Ptr[int32](0), // StartMinute: to.Ptr[int32](0), // }, - // NodeCount: to.Ptr[int32](1), + // NodeCount: to.Ptr[int32](3), // NodeEnablePublicIPAccess: to.Ptr(false), // NodeServerEdition: to.Ptr("MemoryOptimized"), // NodeStorageQuotaInMb: to.Ptr[int32](524288), @@ -578,20 +571,306 @@ func ExampleClustersClient_BeginCreate_createANewClusterAsAReadReplica() { // }, // ServerNames: []*armcosmosforpostgresql.ServerNameItem{ // { - // Name: to.Ptr("testcluster-c"), - // FullyQualifiedDomainName: to.Ptr("c.testcluster.postgres.database.azure.com"), + // Name: to.Ptr("testcluster-multinode-c"), + // FullyQualifiedDomainName: to.Ptr("c.testcluster-multinode.postgres.database.azure.com"), // }, // { - // Name: to.Ptr("testcluster-w0"), - // FullyQualifiedDomainName: to.Ptr("w0.testcluster.postgres.database.azure.com"), + // Name: to.Ptr("testcluster-multinode-w0"), + // FullyQualifiedDomainName: to.Ptr("w0.testcluster-multinode.postgres.database.azure.com"), + // }, + // { + // Name: to.Ptr("testcluster-multinode-w2"), + // FullyQualifiedDomainName: to.Ptr("w0.testcluster-multinode.postgres.database.azure.com"), + // }, + // { + // Name: to.Ptr("testcluster-multinode-w3"), + // FullyQualifiedDomainName: to.Ptr("w0.testcluster-multinode.postgres.database.azure.com"), + // }}, + // State: to.Ptr("Provisioning"), + // }, + // } +} + +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateBurstablev1.json +func ExampleClustersClient_BeginCreate_createANewSingleNodeBurstable1VCoreCluster() { + cred, err := azidentity.NewDefaultAzureCredential(nil) + if err != nil { + log.Fatalf("failed to obtain a credential: %v", err) + } + ctx := context.Background() + clientFactory, err := armcosmosforpostgresql.NewClientFactory("", cred, nil) + if err != nil { + log.Fatalf("failed to create client: %v", err) + } + poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster-burstablev1", armcosmosforpostgresql.Cluster{ + Location: to.Ptr("westus"), + Tags: map[string]*string{ + "owner": to.Ptr("JohnDoe"), + }, + Properties: &armcosmosforpostgresql.ClusterProperties{ + AdministratorLoginPassword: to.Ptr("password"), + CitusVersion: to.Ptr("11.3"), + CoordinatorEnablePublicIPAccess: to.Ptr(true), + CoordinatorServerEdition: to.Ptr("BurstableMemoryOptimized"), + CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + CoordinatorVCores: to.Ptr[int32](1), + EnableHa: to.Ptr(false), + EnableShardsOnCoordinator: to.Ptr(true), + NodeCount: to.Ptr[int32](0), + PostgresqlVersion: to.Ptr("15"), + PreferredPrimaryZone: to.Ptr("1"), + }, + }, nil) + if err != nil { + log.Fatalf("failed to finish the request: %v", err) + } + res, err := poller.PollUntilDone(ctx, nil) + if err != nil { + log.Fatalf("failed to pull the result: %v", err) + } + // You could use response here. We use blank identifier for just demo purposes. + _ = res + // If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes. + // res.Cluster = armcosmosforpostgresql.Cluster{ + // Name: to.Ptr("testcluster-burstablev1"), + // Type: to.Ptr("Microsoft.DBforPostgreSQL/serverGroupsv2"), + // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster-burstablev1"), + // SystemData: &armcosmosforpostgresql.SystemData{ + // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-01T17:18:19.1234567Z"); return t}()), + // CreatedBy: to.Ptr("user1"), + // CreatedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-02T17:18:19.1234567Z"); return t}()), + // LastModifiedBy: to.Ptr("user2"), + // LastModifiedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // }, + // Location: to.Ptr("westus"), + // Tags: map[string]*string{ + // "owner": to.Ptr("JohnDoe"), + // }, + // Properties: &armcosmosforpostgresql.ClusterProperties{ + // AdministratorLogin: to.Ptr("citus"), + // CitusVersion: to.Ptr("11.3"), + // CoordinatorEnablePublicIPAccess: to.Ptr(true), + // CoordinatorServerEdition: to.Ptr("BurstableMemoryOptimized"), + // CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + // CoordinatorVCores: to.Ptr[int32](1), + // EnableHa: to.Ptr(false), + // EnableShardsOnCoordinator: to.Ptr(true), + // MaintenanceWindow: &armcosmosforpostgresql.MaintenanceWindow{ + // CustomWindow: to.Ptr("Disabled"), + // DayOfWeek: to.Ptr[int32](0), + // StartHour: to.Ptr[int32](0), + // StartMinute: to.Ptr[int32](0), + // }, + // NodeCount: to.Ptr[int32](0), + // NodeEnablePublicIPAccess: to.Ptr(false), + // NodeServerEdition: to.Ptr("MemoryOptimized"), + // NodeStorageQuotaInMb: to.Ptr[int32](131072), + // NodeVCores: to.Ptr[int32](2), + // PostgresqlVersion: to.Ptr("15"), + // PreferredPrimaryZone: to.Ptr("1"), + // PrivateEndpointConnections: []*armcosmosforpostgresql.SimplePrivateEndpointConnection{ + // }, + // ProvisioningState: to.Ptr("Succeeded"), + // ReadReplicas: []*string{ + // }, + // ServerNames: []*armcosmosforpostgresql.ServerNameItem{ + // { + // Name: to.Ptr("testcluster-burstablev1-c"), + // FullyQualifiedDomainName: to.Ptr("c.testcluster-burstablev1.postgres.database.azure.com"), + // }}, + // State: to.Ptr("Provisioning"), + // }, + // } +} + +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateBurstablev2.json +func ExampleClustersClient_BeginCreate_createANewSingleNodeBurstable2VCoresCluster() { + cred, err := azidentity.NewDefaultAzureCredential(nil) + if err != nil { + log.Fatalf("failed to obtain a credential: %v", err) + } + ctx := context.Background() + clientFactory, err := armcosmosforpostgresql.NewClientFactory("", cred, nil) + if err != nil { + log.Fatalf("failed to create client: %v", err) + } + poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster-burstablev2", armcosmosforpostgresql.Cluster{ + Location: to.Ptr("westus"), + Tags: map[string]*string{ + "owner": to.Ptr("JohnDoe"), + }, + Properties: &armcosmosforpostgresql.ClusterProperties{ + AdministratorLoginPassword: to.Ptr("password"), + CitusVersion: to.Ptr("11.3"), + CoordinatorEnablePublicIPAccess: to.Ptr(true), + CoordinatorServerEdition: to.Ptr("BurstableGeneralPurpose"), + CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + CoordinatorVCores: to.Ptr[int32](2), + EnableHa: to.Ptr(false), + EnableShardsOnCoordinator: to.Ptr(true), + NodeCount: to.Ptr[int32](0), + PostgresqlVersion: to.Ptr("15"), + PreferredPrimaryZone: to.Ptr("1"), + }, + }, nil) + if err != nil { + log.Fatalf("failed to finish the request: %v", err) + } + res, err := poller.PollUntilDone(ctx, nil) + if err != nil { + log.Fatalf("failed to pull the result: %v", err) + } + // You could use response here. We use blank identifier for just demo purposes. + _ = res + // If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes. + // res.Cluster = armcosmosforpostgresql.Cluster{ + // Name: to.Ptr("testcluster-burstablev2"), + // Type: to.Ptr("Microsoft.DBforPostgreSQL/serverGroupsv2"), + // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster-burstablev2"), + // SystemData: &armcosmosforpostgresql.SystemData{ + // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-01T17:18:19.1234567Z"); return t}()), + // CreatedBy: to.Ptr("user1"), + // CreatedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-02T17:18:19.1234567Z"); return t}()), + // LastModifiedBy: to.Ptr("user2"), + // LastModifiedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // }, + // Location: to.Ptr("westus"), + // Tags: map[string]*string{ + // "owner": to.Ptr("JohnDoe"), + // }, + // Properties: &armcosmosforpostgresql.ClusterProperties{ + // AdministratorLogin: to.Ptr("citus"), + // CitusVersion: to.Ptr("11.3"), + // CoordinatorEnablePublicIPAccess: to.Ptr(true), + // CoordinatorServerEdition: to.Ptr("BurstableGeneralPurpose"), + // CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + // CoordinatorVCores: to.Ptr[int32](2), + // EnableHa: to.Ptr(false), + // EnableShardsOnCoordinator: to.Ptr(true), + // MaintenanceWindow: &armcosmosforpostgresql.MaintenanceWindow{ + // CustomWindow: to.Ptr("Disabled"), + // DayOfWeek: to.Ptr[int32](0), + // StartHour: to.Ptr[int32](0), + // StartMinute: to.Ptr[int32](0), + // }, + // NodeCount: to.Ptr[int32](0), + // NodeEnablePublicIPAccess: to.Ptr(false), + // NodeServerEdition: to.Ptr("MemoryOptimized"), + // NodeStorageQuotaInMb: to.Ptr[int32](131072), + // NodeVCores: to.Ptr[int32](2), + // PostgresqlVersion: to.Ptr("15"), + // PreferredPrimaryZone: to.Ptr("1"), + // PrivateEndpointConnections: []*armcosmosforpostgresql.SimplePrivateEndpointConnection{ + // }, + // ProvisioningState: to.Ptr("Succeeded"), + // ReadReplicas: []*string{ + // }, + // ServerNames: []*armcosmosforpostgresql.ServerNameItem{ + // { + // Name: to.Ptr("testcluster-burstablev2-c"), + // FullyQualifiedDomainName: to.Ptr("c.testcluster-burstablev2.postgres.database.azure.com"), + // }}, + // State: to.Ptr("Provisioning"), + // }, + // } +} + +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterCreateSingleNode.json +func ExampleClustersClient_BeginCreate_createANewSingleNodeCluster() { + cred, err := azidentity.NewDefaultAzureCredential(nil) + if err != nil { + log.Fatalf("failed to obtain a credential: %v", err) + } + ctx := context.Background() + clientFactory, err := armcosmosforpostgresql.NewClientFactory("", cred, nil) + if err != nil { + log.Fatalf("failed to create client: %v", err) + } + poller, err := clientFactory.NewClustersClient().BeginCreate(ctx, "TestGroup", "testcluster-singlenode", armcosmosforpostgresql.Cluster{ + Location: to.Ptr("westus"), + Tags: map[string]*string{ + "owner": to.Ptr("JohnDoe"), + }, + Properties: &armcosmosforpostgresql.ClusterProperties{ + AdministratorLoginPassword: to.Ptr("password"), + CitusVersion: to.Ptr("11.3"), + CoordinatorEnablePublicIPAccess: to.Ptr(true), + CoordinatorServerEdition: to.Ptr("GeneralPurpose"), + CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + CoordinatorVCores: to.Ptr[int32](8), + EnableHa: to.Ptr(true), + EnableShardsOnCoordinator: to.Ptr(true), + NodeCount: to.Ptr[int32](0), + PostgresqlVersion: to.Ptr("15"), + PreferredPrimaryZone: to.Ptr("1"), + }, + }, nil) + if err != nil { + log.Fatalf("failed to finish the request: %v", err) + } + res, err := poller.PollUntilDone(ctx, nil) + if err != nil { + log.Fatalf("failed to pull the result: %v", err) + } + // You could use response here. We use blank identifier for just demo purposes. + _ = res + // If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes. + // res.Cluster = armcosmosforpostgresql.Cluster{ + // Name: to.Ptr("testcluster-singlenode"), + // Type: to.Ptr("Microsoft.DBforPostgreSQL/serverGroupsv2"), + // ID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/testcluster-singlenode"), + // SystemData: &armcosmosforpostgresql.SystemData{ + // CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-01T17:18:19.1234567Z"); return t}()), + // CreatedBy: to.Ptr("user1"), + // CreatedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-01-02T17:18:19.1234567Z"); return t}()), + // LastModifiedBy: to.Ptr("user2"), + // LastModifiedByType: to.Ptr(armcosmosforpostgresql.CreatedByTypeUser), + // }, + // Location: to.Ptr("westus"), + // Tags: map[string]*string{ + // "owner": to.Ptr("JohnDoe"), + // }, + // Properties: &armcosmosforpostgresql.ClusterProperties{ + // AdministratorLogin: to.Ptr("citus"), + // CitusVersion: to.Ptr("11.3"), + // CoordinatorEnablePublicIPAccess: to.Ptr(true), + // CoordinatorServerEdition: to.Ptr("GeneralPurpose"), + // CoordinatorStorageQuotaInMb: to.Ptr[int32](131072), + // CoordinatorVCores: to.Ptr[int32](8), + // EnableHa: to.Ptr(true), + // EnableShardsOnCoordinator: to.Ptr(true), + // MaintenanceWindow: &armcosmosforpostgresql.MaintenanceWindow{ + // CustomWindow: to.Ptr("Disabled"), + // DayOfWeek: to.Ptr[int32](0), + // StartHour: to.Ptr[int32](0), + // StartMinute: to.Ptr[int32](0), + // }, + // NodeCount: to.Ptr[int32](0), + // NodeEnablePublicIPAccess: to.Ptr(false), + // NodeServerEdition: to.Ptr("MemoryOptimized"), + // NodeStorageQuotaInMb: to.Ptr[int32](131072), + // NodeVCores: to.Ptr[int32](8), + // PostgresqlVersion: to.Ptr("15"), + // PreferredPrimaryZone: to.Ptr("1"), + // PrivateEndpointConnections: []*armcosmosforpostgresql.SimplePrivateEndpointConnection{ + // }, + // ProvisioningState: to.Ptr("Succeeded"), + // ReadReplicas: []*string{ + // }, + // ServerNames: []*armcosmosforpostgresql.ServerNameItem{ + // { + // Name: to.Ptr("testcluster-singlenode-c"), + // FullyQualifiedDomainName: to.Ptr("c.testcluster-singlenode.postgres.database.azure.com"), // }}, - // SourceResourceID: to.Ptr("/subscriptions/ffffffff-ffff-ffff-ffff-ffffffffffff/resourceGroups/TestResourceGroup/providers/Microsoft.DBforPostgreSQL/serverGroupsv2/sourcecluster"), // State: to.Ptr("Provisioning"), // }, // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterGet.json func ExampleClustersClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -674,7 +953,7 @@ func ExampleClustersClient_Get() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterDelete.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterDelete.json func ExampleClustersClient_BeginDelete() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -695,7 +974,7 @@ func ExampleClustersClient_BeginDelete() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterScaleCompute.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterScaleCompute.json func ExampleClustersClient_BeginUpdate_scaleComputeUpOrDown() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -784,7 +1063,7 @@ func ExampleClustersClient_BeginUpdate_scaleComputeUpOrDown() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterAddNode.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterAddNode.json func ExampleClustersClient_BeginUpdate_scaleOutAddNewWorkerNodes() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -867,7 +1146,7 @@ func ExampleClustersClient_BeginUpdate_scaleOutAddNewWorkerNodes() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterScaleStorage.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterScaleStorage.json func ExampleClustersClient_BeginUpdate_scaleUpStorage() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -956,7 +1235,7 @@ func ExampleClustersClient_BeginUpdate_scaleUpStorage() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterUpdate.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterUpdate.json func ExampleClustersClient_BeginUpdate_updateMultipleConfigurationSettingsOfTheCluster() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1058,7 +1337,7 @@ func ExampleClustersClient_BeginUpdate_updateMultipleConfigurationSettingsOfTheC // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterUpdateMaintenanceWindow.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterUpdateMaintenanceWindow.json func ExampleClustersClient_BeginUpdate_updateOrDefineMaintenanceWindow() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1148,7 +1427,7 @@ func ExampleClustersClient_BeginUpdate_updateOrDefineMaintenanceWindow() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterRestart.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterRestart.json func ExampleClustersClient_BeginRestart() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1169,7 +1448,7 @@ func ExampleClustersClient_BeginRestart() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterStart.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterStart.json func ExampleClustersClient_BeginStart() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1190,7 +1469,7 @@ func ExampleClustersClient_BeginStart() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterStop.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterStop.json func ExampleClustersClient_BeginStop() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1211,7 +1490,7 @@ func ExampleClustersClient_BeginStop() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterPromoteReadReplica.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ClusterPromoteReadReplica.json func ExampleClustersClient_BeginPromoteReadReplica() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -1232,7 +1511,7 @@ func ExampleClustersClient_BeginPromoteReadReplica() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/CheckNameAvailability.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/CheckNameAvailability.json func ExampleClustersClient_CheckNameAvailability() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client.go index 3fec92a7da02..2a251022a07e 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -53,18 +52,21 @@ func NewConfigurationsClient(subscriptionID string, credential azcore.TokenCrede // - configurationName - The name of the cluster configuration. // - options - ConfigurationsClientGetOptions contains the optional parameters for the ConfigurationsClient.Get method. func (client *ConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, options *ConfigurationsClientGetOptions) (ConfigurationsClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, configurationName, options) if err != nil { return ConfigurationsClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ConfigurationsClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ConfigurationsClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ConfigurationsClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. @@ -113,18 +115,21 @@ func (client *ConfigurationsClient) getHandleResponse(resp *http.Response) (Conf // - options - ConfigurationsClientGetCoordinatorOptions contains the optional parameters for the ConfigurationsClient.GetCoordinator // method. func (client *ConfigurationsClient) GetCoordinator(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, options *ConfigurationsClientGetCoordinatorOptions) (ConfigurationsClientGetCoordinatorResponse, error) { + var err error req, err := client.getCoordinatorCreateRequest(ctx, resourceGroupName, clusterName, configurationName, options) if err != nil { return ConfigurationsClientGetCoordinatorResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ConfigurationsClientGetCoordinatorResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ConfigurationsClientGetCoordinatorResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ConfigurationsClientGetCoordinatorResponse{}, err } - return client.getCoordinatorHandleResponse(resp) + resp, err := client.getCoordinatorHandleResponse(httpResp) + return resp, err } // getCoordinatorCreateRequest creates the GetCoordinator request. @@ -172,18 +177,21 @@ func (client *ConfigurationsClient) getCoordinatorHandleResponse(resp *http.Resp // - configurationName - The name of the cluster configuration. // - options - ConfigurationsClientGetNodeOptions contains the optional parameters for the ConfigurationsClient.GetNode method. func (client *ConfigurationsClient) GetNode(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, options *ConfigurationsClientGetNodeOptions) (ConfigurationsClientGetNodeResponse, error) { + var err error req, err := client.getNodeCreateRequest(ctx, resourceGroupName, clusterName, configurationName, options) if err != nil { return ConfigurationsClientGetNodeResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ConfigurationsClientGetNodeResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ConfigurationsClientGetNodeResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ConfigurationsClientGetNodeResponse{}, err } - return client.getNodeHandleResponse(resp) + resp, err := client.getNodeHandleResponse(httpResp) + return resp, err } // getNodeCreateRequest creates the GetNode request. @@ -377,9 +385,10 @@ func (client *ConfigurationsClient) BeginUpdateOnCoordinator(ctx context.Context if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ConfigurationsClientUpdateOnCoordinatorResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ConfigurationsClientUpdateOnCoordinatorResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ConfigurationsClientUpdateOnCoordinatorResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -390,18 +399,20 @@ func (client *ConfigurationsClient) BeginUpdateOnCoordinator(ctx context.Context // // Generated from API version 2022-11-08 func (client *ConfigurationsClient) updateOnCoordinator(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters ServerConfiguration, options *ConfigurationsClientBeginUpdateOnCoordinatorOptions) (*http.Response, error) { + var err error req, err := client.updateOnCoordinatorCreateRequest(ctx, resourceGroupName, clusterName, configurationName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // updateOnCoordinatorCreateRequest creates the UpdateOnCoordinator request. @@ -428,7 +439,10 @@ func (client *ConfigurationsClient) updateOnCoordinatorCreateRequest(ctx context reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } // BeginUpdateOnNode - Updates configuration of worker nodes in a cluster @@ -447,9 +461,10 @@ func (client *ConfigurationsClient) BeginUpdateOnNode(ctx context.Context, resou if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ConfigurationsClientUpdateOnNodeResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[ConfigurationsClientUpdateOnNodeResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[ConfigurationsClientUpdateOnNodeResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -460,18 +475,20 @@ func (client *ConfigurationsClient) BeginUpdateOnNode(ctx context.Context, resou // // Generated from API version 2022-11-08 func (client *ConfigurationsClient) updateOnNode(ctx context.Context, resourceGroupName string, clusterName string, configurationName string, parameters ServerConfiguration, options *ConfigurationsClientBeginUpdateOnNodeOptions) (*http.Response, error) { + var err error req, err := client.updateOnNodeCreateRequest(ctx, resourceGroupName, clusterName, configurationName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // updateOnNodeCreateRequest creates the UpdateOnNode request. @@ -498,5 +515,8 @@ func (client *ConfigurationsClient) updateOnNodeCreateRequest(ctx context.Contex reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client_example_test.go index 59dcb7a95e6c..fdac5b7d00c0 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/configurations_client_example_test.go @@ -18,7 +18,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationListByServer.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationListByServer.json func ExampleConfigurationsClient_NewListByServerPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -112,7 +112,7 @@ func ExampleConfigurationsClient_NewListByServerPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationListByCluster.json func ExampleConfigurationsClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -268,7 +268,7 @@ func ExampleConfigurationsClient_NewListByClusterPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGet.json func ExampleConfigurationsClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -319,7 +319,7 @@ func ExampleConfigurationsClient_Get() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGetCoordinator.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGetCoordinator.json func ExampleConfigurationsClient_GetCoordinator() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -355,7 +355,7 @@ func ExampleConfigurationsClient_GetCoordinator() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationUpdateCoordinator.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationUpdateCoordinator.json func ExampleConfigurationsClient_BeginUpdateOnCoordinator() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -406,7 +406,7 @@ func ExampleConfigurationsClient_BeginUpdateOnCoordinator() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGetNode.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationGetNode.json func ExampleConfigurationsClient_GetNode() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -442,7 +442,7 @@ func ExampleConfigurationsClient_GetNode() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationUpdateNode.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ConfigurationUpdateNode.json func ExampleConfigurationsClient_BeginUpdateOnNode() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/constants.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/constants.go index 6063c1b1a9f1..17c3a689e5fe 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/constants.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/constants.go @@ -3,15 +3,14 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql const ( moduleName = "armcosmosforpostgresql" - moduleVersion = "v0.1.0" + moduleVersion = "v1.0.0" ) // ConfigurationDataType - Data type of the configuration. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client.go index a8dea1765ae0..335b987874f8 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -60,9 +59,10 @@ func (client *FirewallRulesClient) BeginCreateOrUpdate(ctx context.Context, reso if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[FirewallRulesClientCreateOrUpdateResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[FirewallRulesClientCreateOrUpdateResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[FirewallRulesClientCreateOrUpdateResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -73,18 +73,20 @@ func (client *FirewallRulesClient) BeginCreateOrUpdate(ctx context.Context, reso // // Generated from API version 2022-11-08 func (client *FirewallRulesClient) createOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, firewallRuleName string, parameters FirewallRule, options *FirewallRulesClientBeginCreateOrUpdateOptions) (*http.Response, error) { + var err error req, err := client.createOrUpdateCreateRequest(ctx, resourceGroupName, clusterName, firewallRuleName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // createOrUpdateCreateRequest creates the CreateOrUpdate request. @@ -111,7 +113,10 @@ func (client *FirewallRulesClient) createOrUpdateCreateRequest(ctx context.Conte reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } // BeginDelete - Deletes a cluster firewall rule. @@ -129,9 +134,10 @@ func (client *FirewallRulesClient) BeginDelete(ctx context.Context, resourceGrou if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[FirewallRulesClientDeleteResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[FirewallRulesClientDeleteResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[FirewallRulesClientDeleteResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -142,18 +148,20 @@ func (client *FirewallRulesClient) BeginDelete(ctx context.Context, resourceGrou // // Generated from API version 2022-11-08 func (client *FirewallRulesClient) deleteOperation(ctx context.Context, resourceGroupName string, clusterName string, firewallRuleName string, options *FirewallRulesClientBeginDeleteOptions) (*http.Response, error) { + var err error req, err := client.deleteCreateRequest(ctx, resourceGroupName, clusterName, firewallRuleName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusAccepted, http.StatusNoContent) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusAccepted, http.StatusNoContent) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // deleteCreateRequest creates the Delete request. @@ -192,18 +200,21 @@ func (client *FirewallRulesClient) deleteCreateRequest(ctx context.Context, reso // - firewallRuleName - The name of the cluster firewall rule. // - options - FirewallRulesClientGetOptions contains the optional parameters for the FirewallRulesClient.Get method. func (client *FirewallRulesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, firewallRuleName string, options *FirewallRulesClientGetOptions) (FirewallRulesClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, firewallRuleName, options) if err != nil { return FirewallRulesClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return FirewallRulesClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return FirewallRulesClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return FirewallRulesClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client_example_test.go index 2ea49b21a4d9..9f1876b978c8 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/firewallrules_client_example_test.go @@ -18,7 +18,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleCreate.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleCreate.json func ExampleFirewallRulesClient_BeginCreateOrUpdate() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -65,7 +65,7 @@ func ExampleFirewallRulesClient_BeginCreateOrUpdate() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleDelete.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleDelete.json func ExampleFirewallRulesClient_BeginDelete() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -86,7 +86,7 @@ func ExampleFirewallRulesClient_BeginDelete() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleGet.json func ExampleFirewallRulesClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -124,7 +124,7 @@ func ExampleFirewallRulesClient_Get() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/FirewallRuleListByCluster.json func ExampleFirewallRulesClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.mod b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.mod index 7312ab1d4376..bf915b42ce52 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.mod +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.mod @@ -3,15 +3,15 @@ module github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql go 1.18 require ( - github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.0 + github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.1 github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.3.0 github.com/Azure/azure-sdk-for-go/sdk/internal v1.3.0 github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/internal v1.1.2 + github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resources/armresources v1.0.0 github.com/stretchr/testify v1.7.0 ) require ( - github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resources/armresources v1.0.0 // indirect github.com/AzureAD/microsoft-authentication-library-for-go v1.0.0 // indirect github.com/davecgh/go-spew v1.1.1 // indirect github.com/dnaeon/go-vcr v1.2.0 // indirect diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.sum b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.sum index 688a9b2402b0..ba98c1434a33 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.sum +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/go.sum @@ -1,5 +1,5 @@ -github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.0 h1:8kDqDngH+DmVBiCtIjCFTGa7MBnsIOkF9IccInFEbjk= -github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.0/go.mod h1:bjGvMhVMb+EEm3VRNQawDMUyMMjo+S5ewNjflkep/0Q= +github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.1 h1:SEy2xmstIphdPwNBUi7uhvjyjhVKISfwjfOJmuy7kg4= +github.com/Azure/azure-sdk-for-go/sdk/azcore v1.6.1/go.mod h1:bjGvMhVMb+EEm3VRNQawDMUyMMjo+S5ewNjflkep/0Q= github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.3.0 h1:vcYCAze6p19qBW7MhZybIsqD8sMV8js0NyQM8JDnVtg= github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.3.0/go.mod h1:OQeznEEkTZ9OrhHJoDD8ZDq51FHgXjqtP9z6bEwBq9U= github.com/Azure/azure-sdk-for-go/sdk/internal v1.3.0 h1:sXr+ck84g/ZlZUOZiNELInmMgOsuGwdjjVkEIde0OtY= diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models.go index 42f0aadcf72c..c64e00ff2776 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -87,7 +86,8 @@ type ClusterProperties struct { // If high availability (HA) is enabled or not for the cluster. EnableHa *bool - // If shards on coordinator is enabled or not for the cluster. + // If distributed tables are placed on coordinator or not. Should be set to 'true' on single node clusters. Requires shard + // rebalancing after value is changed. EnableShardsOnCoordinator *bool // Maintenance window of a cluster. @@ -172,7 +172,8 @@ type ClusterPropertiesForUpdate struct { // If high availability (HA) is enabled or not for the cluster. EnableHa *bool - // If shards on coordinator is enabled or not for the cluster. + // If distributed tables are placed on coordinator or not. Should be set to 'true' on single node clusters. Requires shard + // rebalancing after value is changed. EnableShardsOnCoordinator *bool // Maintenance window of a cluster. @@ -271,71 +272,6 @@ type ClusterServerProperties struct { State *string } -// ClustersClientBeginCreateOptions contains the optional parameters for the ClustersClient.BeginCreate method. -type ClustersClientBeginCreateOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method. -type ClustersClientBeginDeleteOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginPromoteReadReplicaOptions contains the optional parameters for the ClustersClient.BeginPromoteReadReplica -// method. -type ClustersClientBeginPromoteReadReplicaOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginRestartOptions contains the optional parameters for the ClustersClient.BeginRestart method. -type ClustersClientBeginRestartOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginStartOptions contains the optional parameters for the ClustersClient.BeginStart method. -type ClustersClientBeginStartOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginStopOptions contains the optional parameters for the ClustersClient.BeginStop method. -type ClustersClientBeginStopOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientBeginUpdateOptions contains the optional parameters for the ClustersClient.BeginUpdate method. -type ClustersClientBeginUpdateOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ClustersClientCheckNameAvailabilityOptions contains the optional parameters for the ClustersClient.CheckNameAvailability -// method. -type ClustersClientCheckNameAvailabilityOptions struct { - // placeholder for future optional parameters -} - -// ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method. -type ClustersClientGetOptions struct { - // placeholder for future optional parameters -} - -// ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.NewListByResourceGroupPager -// method. -type ClustersClientListByResourceGroupOptions struct { - // placeholder for future optional parameters -} - -// ClustersClientListOptions contains the optional parameters for the ClustersClient.NewListPager method. -type ClustersClientListOptions struct { - // placeholder for future optional parameters -} - // Configuration - Represents configuration details for coordinator and node. type Configuration struct { // The properties of configuration. @@ -375,48 +311,6 @@ type ConfigurationProperties struct { ProvisioningState *ProvisioningState } -// ConfigurationsClientBeginUpdateOnCoordinatorOptions contains the optional parameters for the ConfigurationsClient.BeginUpdateOnCoordinator -// method. -type ConfigurationsClientBeginUpdateOnCoordinatorOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ConfigurationsClientBeginUpdateOnNodeOptions contains the optional parameters for the ConfigurationsClient.BeginUpdateOnNode -// method. -type ConfigurationsClientBeginUpdateOnNodeOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// ConfigurationsClientGetCoordinatorOptions contains the optional parameters for the ConfigurationsClient.GetCoordinator -// method. -type ConfigurationsClientGetCoordinatorOptions struct { - // placeholder for future optional parameters -} - -// ConfigurationsClientGetNodeOptions contains the optional parameters for the ConfigurationsClient.GetNode method. -type ConfigurationsClientGetNodeOptions struct { - // placeholder for future optional parameters -} - -// ConfigurationsClientGetOptions contains the optional parameters for the ConfigurationsClient.Get method. -type ConfigurationsClientGetOptions struct { - // placeholder for future optional parameters -} - -// ConfigurationsClientListByClusterOptions contains the optional parameters for the ConfigurationsClient.NewListByClusterPager -// method. -type ConfigurationsClientListByClusterOptions struct { - // placeholder for future optional parameters -} - -// ConfigurationsClientListByServerOptions contains the optional parameters for the ConfigurationsClient.NewListByServerPager -// method. -type ConfigurationsClientListByServerOptions struct { - // placeholder for future optional parameters -} - // FirewallRule - Represents a cluster firewall rule. type FirewallRule struct { // REQUIRED; The properties of a firewall rule. @@ -453,30 +347,6 @@ type FirewallRuleProperties struct { ProvisioningState *ProvisioningState } -// FirewallRulesClientBeginCreateOrUpdateOptions contains the optional parameters for the FirewallRulesClient.BeginCreateOrUpdate -// method. -type FirewallRulesClientBeginCreateOrUpdateOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// FirewallRulesClientBeginDeleteOptions contains the optional parameters for the FirewallRulesClient.BeginDelete method. -type FirewallRulesClientBeginDeleteOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// FirewallRulesClientGetOptions contains the optional parameters for the FirewallRulesClient.Get method. -type FirewallRulesClientGetOptions struct { - // placeholder for future optional parameters -} - -// FirewallRulesClientListByClusterOptions contains the optional parameters for the FirewallRulesClient.NewListByClusterPager -// method. -type FirewallRulesClientListByClusterOptions struct { - // placeholder for future optional parameters -} - // MaintenanceWindow - Schedule settings for regular cluster updates. type MaintenanceWindow struct { // Indicates whether custom maintenance window is enabled or not. @@ -559,11 +429,6 @@ type OperationListResult struct { NextLink *string } -// OperationsClientListOptions contains the optional parameters for the OperationsClient.NewListPager method. -type OperationsClientListOptions struct { - // placeholder for future optional parameters -} - // PrivateEndpoint - The private endpoint resource. type PrivateEndpoint struct { // READ-ONLY; The ARM identifier for private endpoint. @@ -621,32 +486,6 @@ type PrivateEndpointConnectionSimpleProperties struct { PrivateLinkServiceConnectionState *PrivateLinkServiceConnectionState } -// PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginCreateOrUpdate -// method. -type PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete -// method. -type PrivateEndpointConnectionsClientBeginDeleteOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get -// method. -type PrivateEndpointConnectionsClientGetOptions struct { - // placeholder for future optional parameters -} - -// PrivateEndpointConnectionsClientListByClusterOptions contains the optional parameters for the PrivateEndpointConnectionsClient.NewListByClusterPager -// method. -type PrivateEndpointConnectionsClientListByClusterOptions struct { - // placeholder for future optional parameters -} - // PrivateEndpointProperty - Property to represent resource id of the private endpoint. type PrivateEndpointProperty struct { // Resource id of the private endpoint. @@ -689,17 +528,6 @@ type PrivateLinkResourceProperties struct { RequiredMembers []*string } -// PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method. -type PrivateLinkResourcesClientGetOptions struct { - // placeholder for future optional parameters -} - -// PrivateLinkResourcesClientListByClusterOptions contains the optional parameters for the PrivateLinkResourcesClient.NewListByClusterPager -// method. -type PrivateLinkResourcesClientListByClusterOptions struct { - // placeholder for future optional parameters -} - // PrivateLinkServiceConnectionState - A collection of information about the state of the connection between service consumer // and provider. type PrivateLinkServiceConnectionState struct { @@ -746,28 +574,6 @@ type RoleProperties struct { ProvisioningState *ProvisioningState } -// RolesClientBeginCreateOptions contains the optional parameters for the RolesClient.BeginCreate method. -type RolesClientBeginCreateOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// RolesClientBeginDeleteOptions contains the optional parameters for the RolesClient.BeginDelete method. -type RolesClientBeginDeleteOptions struct { - // Resumes the LRO from the provided token. - ResumeToken string -} - -// RolesClientGetOptions contains the optional parameters for the RolesClient.Get method. -type RolesClientGetOptions struct { - // placeholder for future optional parameters -} - -// RolesClientListByClusterOptions contains the optional parameters for the RolesClient.NewListByClusterPager method. -type RolesClientListByClusterOptions struct { - // placeholder for future optional parameters -} - // ServerConfiguration - Represents a configuration. type ServerConfiguration struct { // The properties of a configuration. @@ -846,16 +652,6 @@ type ServerRoleGroupConfiguration struct { Source *string } -// ServersClientGetOptions contains the optional parameters for the ServersClient.Get method. -type ServersClientGetOptions struct { - // placeholder for future optional parameters -} - -// ServersClientListByClusterOptions contains the optional parameters for the ServersClient.NewListByClusterPager method. -type ServersClientListByClusterOptions struct { - // placeholder for future optional parameters -} - // SimplePrivateEndpointConnection - A private endpoint connection. type SimplePrivateEndpointConnection struct { // Properties of the private endpoint connection. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models_serde.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models_serde.go index de2ef96ea2f5..9d4c110f4c06 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models_serde.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/models_serde.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client.go index 3161a7d02e20..e54714f05b42 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client_example_test.go index dc8173b551be..b59b6e86df46 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/operations_client_example_test.go @@ -17,7 +17,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/OperationList.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/OperationList.json func ExampleOperationsClient_NewListPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/options.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/options.go new file mode 100644 index 000000000000..a840cdb8dee8 --- /dev/null +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/options.go @@ -0,0 +1,214 @@ +//go:build go1.18 +// +build go1.18 + +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for license information. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +package armcosmosforpostgresql + +// ClustersClientBeginCreateOptions contains the optional parameters for the ClustersClient.BeginCreate method. +type ClustersClientBeginCreateOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginDeleteOptions contains the optional parameters for the ClustersClient.BeginDelete method. +type ClustersClientBeginDeleteOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginPromoteReadReplicaOptions contains the optional parameters for the ClustersClient.BeginPromoteReadReplica +// method. +type ClustersClientBeginPromoteReadReplicaOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginRestartOptions contains the optional parameters for the ClustersClient.BeginRestart method. +type ClustersClientBeginRestartOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginStartOptions contains the optional parameters for the ClustersClient.BeginStart method. +type ClustersClientBeginStartOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginStopOptions contains the optional parameters for the ClustersClient.BeginStop method. +type ClustersClientBeginStopOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientBeginUpdateOptions contains the optional parameters for the ClustersClient.BeginUpdate method. +type ClustersClientBeginUpdateOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ClustersClientCheckNameAvailabilityOptions contains the optional parameters for the ClustersClient.CheckNameAvailability +// method. +type ClustersClientCheckNameAvailabilityOptions struct { + // placeholder for future optional parameters +} + +// ClustersClientGetOptions contains the optional parameters for the ClustersClient.Get method. +type ClustersClientGetOptions struct { + // placeholder for future optional parameters +} + +// ClustersClientListByResourceGroupOptions contains the optional parameters for the ClustersClient.NewListByResourceGroupPager +// method. +type ClustersClientListByResourceGroupOptions struct { + // placeholder for future optional parameters +} + +// ClustersClientListOptions contains the optional parameters for the ClustersClient.NewListPager method. +type ClustersClientListOptions struct { + // placeholder for future optional parameters +} + +// ConfigurationsClientBeginUpdateOnCoordinatorOptions contains the optional parameters for the ConfigurationsClient.BeginUpdateOnCoordinator +// method. +type ConfigurationsClientBeginUpdateOnCoordinatorOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ConfigurationsClientBeginUpdateOnNodeOptions contains the optional parameters for the ConfigurationsClient.BeginUpdateOnNode +// method. +type ConfigurationsClientBeginUpdateOnNodeOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// ConfigurationsClientGetCoordinatorOptions contains the optional parameters for the ConfigurationsClient.GetCoordinator +// method. +type ConfigurationsClientGetCoordinatorOptions struct { + // placeholder for future optional parameters +} + +// ConfigurationsClientGetNodeOptions contains the optional parameters for the ConfigurationsClient.GetNode method. +type ConfigurationsClientGetNodeOptions struct { + // placeholder for future optional parameters +} + +// ConfigurationsClientGetOptions contains the optional parameters for the ConfigurationsClient.Get method. +type ConfigurationsClientGetOptions struct { + // placeholder for future optional parameters +} + +// ConfigurationsClientListByClusterOptions contains the optional parameters for the ConfigurationsClient.NewListByClusterPager +// method. +type ConfigurationsClientListByClusterOptions struct { + // placeholder for future optional parameters +} + +// ConfigurationsClientListByServerOptions contains the optional parameters for the ConfigurationsClient.NewListByServerPager +// method. +type ConfigurationsClientListByServerOptions struct { + // placeholder for future optional parameters +} + +// FirewallRulesClientBeginCreateOrUpdateOptions contains the optional parameters for the FirewallRulesClient.BeginCreateOrUpdate +// method. +type FirewallRulesClientBeginCreateOrUpdateOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// FirewallRulesClientBeginDeleteOptions contains the optional parameters for the FirewallRulesClient.BeginDelete method. +type FirewallRulesClientBeginDeleteOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// FirewallRulesClientGetOptions contains the optional parameters for the FirewallRulesClient.Get method. +type FirewallRulesClientGetOptions struct { + // placeholder for future optional parameters +} + +// FirewallRulesClientListByClusterOptions contains the optional parameters for the FirewallRulesClient.NewListByClusterPager +// method. +type FirewallRulesClientListByClusterOptions struct { + // placeholder for future optional parameters +} + +// OperationsClientListOptions contains the optional parameters for the OperationsClient.NewListPager method. +type OperationsClientListOptions struct { + // placeholder for future optional parameters +} + +// PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginCreateOrUpdate +// method. +type PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// PrivateEndpointConnectionsClientBeginDeleteOptions contains the optional parameters for the PrivateEndpointConnectionsClient.BeginDelete +// method. +type PrivateEndpointConnectionsClientBeginDeleteOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get +// method. +type PrivateEndpointConnectionsClientGetOptions struct { + // placeholder for future optional parameters +} + +// PrivateEndpointConnectionsClientListByClusterOptions contains the optional parameters for the PrivateEndpointConnectionsClient.NewListByClusterPager +// method. +type PrivateEndpointConnectionsClientListByClusterOptions struct { + // placeholder for future optional parameters +} + +// PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get method. +type PrivateLinkResourcesClientGetOptions struct { + // placeholder for future optional parameters +} + +// PrivateLinkResourcesClientListByClusterOptions contains the optional parameters for the PrivateLinkResourcesClient.NewListByClusterPager +// method. +type PrivateLinkResourcesClientListByClusterOptions struct { + // placeholder for future optional parameters +} + +// RolesClientBeginCreateOptions contains the optional parameters for the RolesClient.BeginCreate method. +type RolesClientBeginCreateOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// RolesClientBeginDeleteOptions contains the optional parameters for the RolesClient.BeginDelete method. +type RolesClientBeginDeleteOptions struct { + // Resumes the LRO from the provided token. + ResumeToken string +} + +// RolesClientGetOptions contains the optional parameters for the RolesClient.Get method. +type RolesClientGetOptions struct { + // placeholder for future optional parameters +} + +// RolesClientListByClusterOptions contains the optional parameters for the RolesClient.NewListByClusterPager method. +type RolesClientListByClusterOptions struct { + // placeholder for future optional parameters +} + +// ServersClientGetOptions contains the optional parameters for the ServersClient.Get method. +type ServersClientGetOptions struct { + // placeholder for future optional parameters +} + +// ServersClientListByClusterOptions contains the optional parameters for the ServersClient.NewListByClusterPager method. +type ServersClientListByClusterOptions struct { + // placeholder for future optional parameters +} diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client.go index d90a8181ae57..b5a5847d50de 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -60,9 +59,10 @@ func (client *PrivateEndpointConnectionsClient) BeginCreateOrUpdate(ctx context. if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[PrivateEndpointConnectionsClientCreateOrUpdateResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[PrivateEndpointConnectionsClientCreateOrUpdateResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[PrivateEndpointConnectionsClientCreateOrUpdateResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -73,18 +73,20 @@ func (client *PrivateEndpointConnectionsClient) BeginCreateOrUpdate(ctx context. // // Generated from API version 2022-11-08 func (client *PrivateEndpointConnectionsClient) createOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection, options *PrivateEndpointConnectionsClientBeginCreateOrUpdateOptions) (*http.Response, error) { + var err error req, err := client.createOrUpdateCreateRequest(ctx, resourceGroupName, clusterName, privateEndpointConnectionName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // createOrUpdateCreateRequest creates the CreateOrUpdate request. @@ -111,7 +113,10 @@ func (client *PrivateEndpointConnectionsClient) createOrUpdateCreateRequest(ctx reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } // BeginDelete - Deletes a private endpoint connection with a given name. @@ -129,9 +134,10 @@ func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[PrivateEndpointConnectionsClientDeleteResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[PrivateEndpointConnectionsClientDeleteResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[PrivateEndpointConnectionsClientDeleteResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -142,18 +148,20 @@ func (client *PrivateEndpointConnectionsClient) BeginDelete(ctx context.Context, // // Generated from API version 2022-11-08 func (client *PrivateEndpointConnectionsClient) deleteOperation(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientBeginDeleteOptions) (*http.Response, error) { + var err error req, err := client.deleteCreateRequest(ctx, resourceGroupName, clusterName, privateEndpointConnectionName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusAccepted, http.StatusNoContent) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusAccepted, http.StatusNoContent) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // deleteCreateRequest creates the Delete request. @@ -193,18 +201,21 @@ func (client *PrivateEndpointConnectionsClient) deleteCreateRequest(ctx context. // - options - PrivateEndpointConnectionsClientGetOptions contains the optional parameters for the PrivateEndpointConnectionsClient.Get // method. func (client *PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, options *PrivateEndpointConnectionsClientGetOptions) (PrivateEndpointConnectionsClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, privateEndpointConnectionName, options) if err != nil { return PrivateEndpointConnectionsClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return PrivateEndpointConnectionsClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return PrivateEndpointConnectionsClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return PrivateEndpointConnectionsClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client_example_test.go index 69823c317d00..bd7271cf2b78 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privateendpointconnections_client_example_test.go @@ -18,7 +18,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsListByCluster.json func ExamplePrivateEndpointConnectionsClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -98,7 +98,7 @@ func ExamplePrivateEndpointConnectionsClient_NewListByClusterPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsGet.json func ExamplePrivateEndpointConnectionsClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -144,7 +144,7 @@ func ExamplePrivateEndpointConnectionsClient_Get() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionCreateOrUpdate.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionCreateOrUpdate.json func ExamplePrivateEndpointConnectionsClient_BeginCreateOrUpdate() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -191,7 +191,7 @@ func ExamplePrivateEndpointConnectionsClient_BeginCreateOrUpdate() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsDelete.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateEndpointConnectionsDelete.json func ExamplePrivateEndpointConnectionsClient_BeginDelete() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client.go index b0e16d719469..f72ae4baa4a6 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -54,18 +53,21 @@ func NewPrivateLinkResourcesClient(subscriptionID string, credential azcore.Toke // - options - PrivateLinkResourcesClientGetOptions contains the optional parameters for the PrivateLinkResourcesClient.Get // method. func (client *PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string, options *PrivateLinkResourcesClientGetOptions) (PrivateLinkResourcesClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, privateLinkResourceName, options) if err != nil { return PrivateLinkResourcesClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return PrivateLinkResourcesClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return PrivateLinkResourcesClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return PrivateLinkResourcesClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client_example_test.go index 81495488f10f..7b6e17e9aa4c 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/privatelinkresources_client_example_test.go @@ -17,7 +17,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateLinkResourceListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateLinkResourceListByCluster.json func ExamplePrivateLinkResourcesClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -85,7 +85,7 @@ func ExamplePrivateLinkResourcesClient_NewListByClusterPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateLinkResourcesGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/PrivateLinkResourcesGet.json func ExamplePrivateLinkResourcesClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/response_types.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/response_types.go index 2953cbdda3bf..a1ce23737aa0 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/response_types.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/response_types.go @@ -3,19 +3,20 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql // ClustersClientCheckNameAvailabilityResponse contains the response from method ClustersClient.CheckNameAvailability. type ClustersClientCheckNameAvailabilityResponse struct { + // Represents cluster name availability. NameAvailability } // ClustersClientCreateResponse contains the response from method ClustersClient.BeginCreate. type ClustersClientCreateResponse struct { + // Represents a cluster. Cluster } @@ -26,16 +27,19 @@ type ClustersClientDeleteResponse struct { // ClustersClientGetResponse contains the response from method ClustersClient.Get. type ClustersClientGetResponse struct { + // Represents a cluster. Cluster } // ClustersClientListByResourceGroupResponse contains the response from method ClustersClient.NewListByResourceGroupPager. type ClustersClientListByResourceGroupResponse struct { + // A list of clusters. ClusterListResult } // ClustersClientListResponse contains the response from method ClustersClient.NewListPager. type ClustersClientListResponse struct { + // A list of clusters. ClusterListResult } @@ -61,46 +65,55 @@ type ClustersClientStopResponse struct { // ClustersClientUpdateResponse contains the response from method ClustersClient.BeginUpdate. type ClustersClientUpdateResponse struct { + // Represents a cluster. Cluster } // ConfigurationsClientGetCoordinatorResponse contains the response from method ConfigurationsClient.GetCoordinator. type ConfigurationsClientGetCoordinatorResponse struct { + // Represents a configuration. ServerConfiguration } // ConfigurationsClientGetNodeResponse contains the response from method ConfigurationsClient.GetNode. type ConfigurationsClientGetNodeResponse struct { + // Represents a configuration. ServerConfiguration } // ConfigurationsClientGetResponse contains the response from method ConfigurationsClient.Get. type ConfigurationsClientGetResponse struct { + // Represents configuration details for coordinator and node. Configuration } // ConfigurationsClientListByClusterResponse contains the response from method ConfigurationsClient.NewListByClusterPager. type ConfigurationsClientListByClusterResponse struct { + // A list of cluster configurations. ClusterConfigurationListResult } // ConfigurationsClientListByServerResponse contains the response from method ConfigurationsClient.NewListByServerPager. type ConfigurationsClientListByServerResponse struct { + // A list of server configurations. ServerConfigurationListResult } // ConfigurationsClientUpdateOnCoordinatorResponse contains the response from method ConfigurationsClient.BeginUpdateOnCoordinator. type ConfigurationsClientUpdateOnCoordinatorResponse struct { + // Represents a configuration. ServerConfiguration } // ConfigurationsClientUpdateOnNodeResponse contains the response from method ConfigurationsClient.BeginUpdateOnNode. type ConfigurationsClientUpdateOnNodeResponse struct { + // Represents a configuration. ServerConfiguration } // FirewallRulesClientCreateOrUpdateResponse contains the response from method FirewallRulesClient.BeginCreateOrUpdate. type FirewallRulesClientCreateOrUpdateResponse struct { + // Represents a cluster firewall rule. FirewallRule } @@ -111,21 +124,25 @@ type FirewallRulesClientDeleteResponse struct { // FirewallRulesClientGetResponse contains the response from method FirewallRulesClient.Get. type FirewallRulesClientGetResponse struct { + // Represents a cluster firewall rule. FirewallRule } // FirewallRulesClientListByClusterResponse contains the response from method FirewallRulesClient.NewListByClusterPager. type FirewallRulesClientListByClusterResponse struct { + // A list of firewall rules. FirewallRuleListResult } // OperationsClientListResponse contains the response from method OperationsClient.NewListPager. type OperationsClientListResponse struct { + // A list of resource provider operations. OperationListResult } // PrivateEndpointConnectionsClientCreateOrUpdateResponse contains the response from method PrivateEndpointConnectionsClient.BeginCreateOrUpdate. type PrivateEndpointConnectionsClientCreateOrUpdateResponse struct { + // The private endpoint connection resource. PrivateEndpointConnection } @@ -136,26 +153,31 @@ type PrivateEndpointConnectionsClientDeleteResponse struct { // PrivateEndpointConnectionsClientGetResponse contains the response from method PrivateEndpointConnectionsClient.Get. type PrivateEndpointConnectionsClientGetResponse struct { + // The private endpoint connection resource. PrivateEndpointConnection } // PrivateEndpointConnectionsClientListByClusterResponse contains the response from method PrivateEndpointConnectionsClient.NewListByClusterPager. type PrivateEndpointConnectionsClientListByClusterResponse struct { + // List of private endpoint connections associated with the specified resource. PrivateEndpointConnectionListResult } // PrivateLinkResourcesClientGetResponse contains the response from method PrivateLinkResourcesClient.Get. type PrivateLinkResourcesClientGetResponse struct { + // A private link resource. PrivateLinkResource } // PrivateLinkResourcesClientListByClusterResponse contains the response from method PrivateLinkResourcesClient.NewListByClusterPager. type PrivateLinkResourcesClientListByClusterResponse struct { + // A list of private link resources. PrivateLinkResourceListResult } // RolesClientCreateResponse contains the response from method RolesClient.BeginCreate. type RolesClientCreateResponse struct { + // Represents a cluster role. Role } @@ -166,20 +188,24 @@ type RolesClientDeleteResponse struct { // RolesClientGetResponse contains the response from method RolesClient.Get. type RolesClientGetResponse struct { + // Represents a cluster role. Role } // RolesClientListByClusterResponse contains the response from method RolesClient.NewListByClusterPager. type RolesClientListByClusterResponse struct { + // A list of roles. RoleListResult } // ServersClientGetResponse contains the response from method ServersClient.Get. type ServersClientGetResponse struct { + // Represents a server in a cluster. ClusterServer } // ServersClientListByClusterResponse contains the response from method ServersClient.NewListByClusterPager. type ServersClientListByClusterResponse struct { + // A list of servers in a cluster. ClusterServerListResult } diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client.go index 88d255ca63ac..6a78791b80fc 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -59,9 +58,10 @@ func (client *RolesClient) BeginCreate(ctx context.Context, resourceGroupName st if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[RolesClientCreateResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[RolesClientCreateResponse]{ FinalStateVia: runtime.FinalStateViaAzureAsyncOp, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[RolesClientCreateResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -72,18 +72,20 @@ func (client *RolesClient) BeginCreate(ctx context.Context, resourceGroupName st // // Generated from API version 2022-11-08 func (client *RolesClient) create(ctx context.Context, resourceGroupName string, clusterName string, roleName string, parameters Role, options *RolesClientBeginCreateOptions) (*http.Response, error) { + var err error req, err := client.createCreateRequest(ctx, resourceGroupName, clusterName, roleName, parameters, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusOK, http.StatusCreated) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK, http.StatusCreated) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // createCreateRequest creates the Create request. @@ -110,7 +112,10 @@ func (client *RolesClient) createCreateRequest(ctx context.Context, resourceGrou reqQP.Set("api-version", "2022-11-08") req.Raw().URL.RawQuery = reqQP.Encode() req.Raw().Header["Accept"] = []string{"application/json"} - return req, runtime.MarshalAsJSON(req, parameters) + if err := runtime.MarshalAsJSON(req, parameters); err != nil { + return nil, err + } + return req, nil } // BeginDelete - Deletes a cluster role. @@ -127,9 +132,10 @@ func (client *RolesClient) BeginDelete(ctx context.Context, resourceGroupName st if err != nil { return nil, err } - return runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[RolesClientDeleteResponse]{ + poller, err := runtime.NewPoller(resp, client.internal.Pipeline(), &runtime.NewPollerOptions[RolesClientDeleteResponse]{ FinalStateVia: runtime.FinalStateViaLocation, }) + return poller, err } else { return runtime.NewPollerFromResumeToken[RolesClientDeleteResponse](options.ResumeToken, client.internal.Pipeline(), nil) } @@ -140,18 +146,20 @@ func (client *RolesClient) BeginDelete(ctx context.Context, resourceGroupName st // // Generated from API version 2022-11-08 func (client *RolesClient) deleteOperation(ctx context.Context, resourceGroupName string, clusterName string, roleName string, options *RolesClientBeginDeleteOptions) (*http.Response, error) { + var err error req, err := client.deleteCreateRequest(ctx, resourceGroupName, clusterName, roleName, options) if err != nil { return nil, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return nil, err } - if !runtime.HasStatusCode(resp, http.StatusAccepted, http.StatusNoContent) { - return nil, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusAccepted, http.StatusNoContent) { + err = runtime.NewResponseError(httpResp) + return nil, err } - return resp, nil + return httpResp, nil } // deleteCreateRequest creates the Delete request. @@ -190,18 +198,21 @@ func (client *RolesClient) deleteCreateRequest(ctx context.Context, resourceGrou // - roleName - The name of the cluster role. // - options - RolesClientGetOptions contains the optional parameters for the RolesClient.Get method. func (client *RolesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, roleName string, options *RolesClientGetOptions) (RolesClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, roleName, options) if err != nil { return RolesClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return RolesClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return RolesClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return RolesClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client_example_test.go index 4d825705f82e..fb9a7bbce829 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/roles_client_example_test.go @@ -18,7 +18,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleGet.json func ExampleRolesClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -54,7 +54,7 @@ func ExampleRolesClient_Get() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleCreate.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleCreate.json func ExampleRolesClient_BeginCreate() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -98,7 +98,7 @@ func ExampleRolesClient_BeginCreate() { // } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleDelete.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleDelete.json func ExampleRolesClient_BeginDelete() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -119,7 +119,7 @@ func ExampleRolesClient_BeginDelete() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/RoleListByCluster.json func ExampleRolesClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client.go index 095e3747168c..c7de8fef93c8 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql @@ -53,18 +52,21 @@ func NewServersClient(subscriptionID string, credential azcore.TokenCredential, // - serverName - The name of the server. // - options - ServersClientGetOptions contains the optional parameters for the ServersClient.Get method. func (client *ServersClient) Get(ctx context.Context, resourceGroupName string, clusterName string, serverName string, options *ServersClientGetOptions) (ServersClientGetResponse, error) { + var err error req, err := client.getCreateRequest(ctx, resourceGroupName, clusterName, serverName, options) if err != nil { return ServersClientGetResponse{}, err } - resp, err := client.internal.Pipeline().Do(req) + httpResp, err := client.internal.Pipeline().Do(req) if err != nil { return ServersClientGetResponse{}, err } - if !runtime.HasStatusCode(resp, http.StatusOK) { - return ServersClientGetResponse{}, runtime.NewResponseError(resp) + if !runtime.HasStatusCode(httpResp, http.StatusOK) { + err = runtime.NewResponseError(httpResp) + return ServersClientGetResponse{}, err } - return client.getHandleResponse(resp) + resp, err := client.getHandleResponse(httpResp) + return resp, err } // getCreateRequest creates the Get request. diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client_example_test.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client_example_test.go index 9e20b5dcf596..5db751a9e7ce 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client_example_test.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/servers_client_example_test.go @@ -17,7 +17,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql" ) -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ServerListByCluster.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ServerListByCluster.json func ExampleServersClient_NewListByClusterPager() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { @@ -132,7 +132,7 @@ func ExampleServersClient_NewListByClusterPager() { } } -// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/0d41e635294dce73dfa99b07f3da4b68a9c9e29c/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ServerGet.json +// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/80c21c17b4a7aa57f637ee594f7cfd653255a7e0/specification/postgresqlhsc/resource-manager/Microsoft.DBforPostgreSQL/stable/2022-11-08/examples/ServerGet.json func ExampleServersClient_Get() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { diff --git a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/time_rfc3339.go b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/time_rfc3339.go index 578ba20c8ff0..88444573b255 100644 --- a/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/time_rfc3339.go +++ b/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql/time_rfc3339.go @@ -3,9 +3,8 @@ // Copyright (c) Microsoft Corporation. All rights reserved. // Licensed under the MIT License. See License.txt in the project root for license information. -// Code generated by Microsoft (R) AutoRest Code Generator. +// Code generated by Microsoft (R) AutoRest Code Generator. DO NOT EDIT. // Changes may cause incorrect behavior and will be lost if the code is regenerated. -// DO NOT EDIT. package armcosmosforpostgresql