1 package postgresqlflexibleservers
2
3
4
5
6
7
8
9 import (
10 "context"
11 "github.com/Azure/go-autorest/autorest"
12 "github.com/Azure/go-autorest/autorest/azure"
13 "github.com/Azure/go-autorest/autorest/validation"
14 "github.com/Azure/go-autorest/tracing"
15 "net/http"
16 )
17
18
19
20
21 type LocationBasedCapabilitiesClient struct {
22 BaseClient
23 }
24
25
26 func NewLocationBasedCapabilitiesClient(subscriptionID string) LocationBasedCapabilitiesClient {
27 return NewLocationBasedCapabilitiesClientWithBaseURI(DefaultBaseURI, subscriptionID)
28 }
29
30
31
32
33 func NewLocationBasedCapabilitiesClientWithBaseURI(baseURI string, subscriptionID string) LocationBasedCapabilitiesClient {
34 return LocationBasedCapabilitiesClient{NewWithBaseURI(baseURI, subscriptionID)}
35 }
36
37
38
39
40 func (client LocationBasedCapabilitiesClient) Execute(ctx context.Context, locationName string) (result CapabilitiesListResultPage, err error) {
41 if tracing.IsEnabled() {
42 ctx = tracing.StartSpan(ctx, fqdn+"/LocationBasedCapabilitiesClient.Execute")
43 defer func() {
44 sc := -1
45 if result.clr.Response.Response != nil {
46 sc = result.clr.Response.Response.StatusCode
47 }
48 tracing.EndSpan(ctx, sc, err)
49 }()
50 }
51 if err := validation.Validate([]validation.Validation{
52 {TargetValue: client.SubscriptionID,
53 Constraints: []validation.Constraint{{Target: "client.SubscriptionID", Name: validation.MinLength, Rule: 1, Chain: nil}}}}); err != nil {
54 return result, validation.NewError("postgresqlflexibleservers.LocationBasedCapabilitiesClient", "Execute", err.Error())
55 }
56
57 result.fn = client.executeNextResults
58 req, err := client.ExecutePreparer(ctx, locationName)
59 if err != nil {
60 err = autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "Execute", nil, "Failure preparing request")
61 return
62 }
63
64 resp, err := client.ExecuteSender(req)
65 if err != nil {
66 result.clr.Response = autorest.Response{Response: resp}
67 err = autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "Execute", resp, "Failure sending request")
68 return
69 }
70
71 result.clr, err = client.ExecuteResponder(resp)
72 if err != nil {
73 err = autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "Execute", resp, "Failure responding to request")
74 return
75 }
76 if result.clr.hasNextLink() && result.clr.IsEmpty() {
77 err = result.NextWithContext(ctx)
78 return
79 }
80
81 return
82 }
83
84
85 func (client LocationBasedCapabilitiesClient) ExecutePreparer(ctx context.Context, locationName string) (*http.Request, error) {
86 pathParameters := map[string]interface{}{
87 "locationName": autorest.Encode("path", locationName),
88 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
89 }
90
91 const APIVersion = "2021-06-01"
92 queryParameters := map[string]interface{}{
93 "api-version": APIVersion,
94 }
95
96 preparer := autorest.CreatePreparer(
97 autorest.AsGet(),
98 autorest.WithBaseURL(client.BaseURI),
99 autorest.WithPathParameters("/subscriptions/{subscriptionId}/providers/Microsoft.DBforPostgreSQL/locations/{locationName}/capabilities", pathParameters),
100 autorest.WithQueryParameters(queryParameters))
101 return preparer.Prepare((&http.Request{}).WithContext(ctx))
102 }
103
104
105
106 func (client LocationBasedCapabilitiesClient) ExecuteSender(req *http.Request) (*http.Response, error) {
107 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
108 }
109
110
111
112 func (client LocationBasedCapabilitiesClient) ExecuteResponder(resp *http.Response) (result CapabilitiesListResult, err error) {
113 err = autorest.Respond(
114 resp,
115 azure.WithErrorUnlessStatusCode(http.StatusOK),
116 autorest.ByUnmarshallingJSON(&result),
117 autorest.ByClosing())
118 result.Response = autorest.Response{Response: resp}
119 return
120 }
121
122
123 func (client LocationBasedCapabilitiesClient) executeNextResults(ctx context.Context, lastResults CapabilitiesListResult) (result CapabilitiesListResult, err error) {
124 req, err := lastResults.capabilitiesListResultPreparer(ctx)
125 if err != nil {
126 return result, autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "executeNextResults", nil, "Failure preparing next results request")
127 }
128 if req == nil {
129 return
130 }
131 resp, err := client.ExecuteSender(req)
132 if err != nil {
133 result.Response = autorest.Response{Response: resp}
134 return result, autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "executeNextResults", resp, "Failure sending next results request")
135 }
136 result, err = client.ExecuteResponder(resp)
137 if err != nil {
138 err = autorest.NewErrorWithError(err, "postgresqlflexibleservers.LocationBasedCapabilitiesClient", "executeNextResults", resp, "Failure responding to next results request")
139 }
140 return
141 }
142
143
144 func (client LocationBasedCapabilitiesClient) ExecuteComplete(ctx context.Context, locationName string) (result CapabilitiesListResultIterator, err error) {
145 if tracing.IsEnabled() {
146 ctx = tracing.StartSpan(ctx, fqdn+"/LocationBasedCapabilitiesClient.Execute")
147 defer func() {
148 sc := -1
149 if result.Response().Response.Response != nil {
150 sc = result.page.Response().Response.Response.StatusCode
151 }
152 tracing.EndSpan(ctx, sc, err)
153 }()
154 }
155 result.page, err = client.Execute(ctx, locationName)
156 return
157 }
158
View as plain text