1// +build go1.13 2 3// Copyright (c) Microsoft Corporation. All rights reserved. 4// Licensed under the MIT License. See License.txt in the project root for license information. 5// Code generated by Microsoft (R) AutoRest Code Generator. 6// Changes may cause incorrect behavior and will be lost if the code is regenerated. 7 8package armweb 9 10import ( 11 "context" 12 "errors" 13 "fmt" 14 "github.com/Azure/azure-sdk-for-go/sdk/armcore" 15 "github.com/Azure/azure-sdk-for-go/sdk/azcore" 16 "net/http" 17 "net/url" 18 "strings" 19 "time" 20) 21 22// KubeEnvironmentsClient contains the methods for the KubeEnvironments group. 23// Don't use this type directly, use NewKubeEnvironmentsClient() instead. 24type KubeEnvironmentsClient struct { 25 con *armcore.Connection 26 subscriptionID string 27} 28 29// NewKubeEnvironmentsClient creates a new instance of KubeEnvironmentsClient with the specified values. 30func NewKubeEnvironmentsClient(con *armcore.Connection, subscriptionID string) *KubeEnvironmentsClient { 31 return &KubeEnvironmentsClient{con: con, subscriptionID: subscriptionID} 32} 33 34// BeginCreateOrUpdate - Description for Creates or updates a Kubernetes Environment. 35// If the operation fails it returns the *DefaultErrorResponse error type. 36func (client *KubeEnvironmentsClient) BeginCreateOrUpdate(ctx context.Context, resourceGroupName string, name string, kubeEnvironmentEnvelope KubeEnvironment, options *KubeEnvironmentsBeginCreateOrUpdateOptions) (KubeEnvironmentsCreateOrUpdatePollerResponse, error) { 37 resp, err := client.createOrUpdate(ctx, resourceGroupName, name, kubeEnvironmentEnvelope, options) 38 if err != nil { 39 return KubeEnvironmentsCreateOrUpdatePollerResponse{}, err 40 } 41 result := KubeEnvironmentsCreateOrUpdatePollerResponse{ 42 RawResponse: resp.Response, 43 } 44 pt, err := armcore.NewLROPoller("KubeEnvironmentsClient.CreateOrUpdate", "", resp, client.con.Pipeline(), client.createOrUpdateHandleError) 45 if err != nil { 46 return KubeEnvironmentsCreateOrUpdatePollerResponse{}, err 47 } 48 poller := &kubeEnvironmentsCreateOrUpdatePoller{ 49 pt: pt, 50 } 51 result.Poller = poller 52 result.PollUntilDone = func(ctx context.Context, frequency time.Duration) (KubeEnvironmentsCreateOrUpdateResponse, error) { 53 return poller.pollUntilDone(ctx, frequency) 54 } 55 return result, nil 56} 57 58// ResumeCreateOrUpdate creates a new KubeEnvironmentsCreateOrUpdatePoller from the specified resume token. 59// token - The value must come from a previous call to KubeEnvironmentsCreateOrUpdatePoller.ResumeToken(). 60func (client *KubeEnvironmentsClient) ResumeCreateOrUpdate(ctx context.Context, token string) (KubeEnvironmentsCreateOrUpdatePollerResponse, error) { 61 pt, err := armcore.NewLROPollerFromResumeToken("KubeEnvironmentsClient.CreateOrUpdate", token, client.con.Pipeline(), client.createOrUpdateHandleError) 62 if err != nil { 63 return KubeEnvironmentsCreateOrUpdatePollerResponse{}, err 64 } 65 poller := &kubeEnvironmentsCreateOrUpdatePoller{ 66 pt: pt, 67 } 68 resp, err := poller.Poll(ctx) 69 if err != nil { 70 return KubeEnvironmentsCreateOrUpdatePollerResponse{}, err 71 } 72 result := KubeEnvironmentsCreateOrUpdatePollerResponse{ 73 RawResponse: resp, 74 } 75 result.Poller = poller 76 result.PollUntilDone = func(ctx context.Context, frequency time.Duration) (KubeEnvironmentsCreateOrUpdateResponse, error) { 77 return poller.pollUntilDone(ctx, frequency) 78 } 79 return result, nil 80} 81 82// CreateOrUpdate - Description for Creates or updates a Kubernetes Environment. 83// If the operation fails it returns the *DefaultErrorResponse error type. 84func (client *KubeEnvironmentsClient) createOrUpdate(ctx context.Context, resourceGroupName string, name string, kubeEnvironmentEnvelope KubeEnvironment, options *KubeEnvironmentsBeginCreateOrUpdateOptions) (*azcore.Response, error) { 85 req, err := client.createOrUpdateCreateRequest(ctx, resourceGroupName, name, kubeEnvironmentEnvelope, options) 86 if err != nil { 87 return nil, err 88 } 89 resp, err := client.con.Pipeline().Do(req) 90 if err != nil { 91 return nil, err 92 } 93 if !resp.HasStatusCode(http.StatusOK, http.StatusCreated) { 94 return nil, client.createOrUpdateHandleError(resp) 95 } 96 return resp, nil 97} 98 99// createOrUpdateCreateRequest creates the CreateOrUpdate request. 100func (client *KubeEnvironmentsClient) createOrUpdateCreateRequest(ctx context.Context, resourceGroupName string, name string, kubeEnvironmentEnvelope KubeEnvironment, options *KubeEnvironmentsBeginCreateOrUpdateOptions) (*azcore.Request, error) { 101 urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Web/kubeEnvironments/{name}" 102 if resourceGroupName == "" { 103 return nil, errors.New("parameter resourceGroupName cannot be empty") 104 } 105 urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) 106 if name == "" { 107 return nil, errors.New("parameter name cannot be empty") 108 } 109 urlPath = strings.ReplaceAll(urlPath, "{name}", url.PathEscape(name)) 110 if client.subscriptionID == "" { 111 return nil, errors.New("parameter client.subscriptionID cannot be empty") 112 } 113 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 114 req, err := azcore.NewRequest(ctx, http.MethodPut, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 115 if err != nil { 116 return nil, err 117 } 118 req.Telemetry(telemetryInfo) 119 reqQP := req.URL.Query() 120 reqQP.Set("api-version", "2021-01-15") 121 req.URL.RawQuery = reqQP.Encode() 122 req.Header.Set("Accept", "application/json") 123 return req, req.MarshalAsJSON(kubeEnvironmentEnvelope) 124} 125 126// createOrUpdateHandleError handles the CreateOrUpdate error response. 127func (client *KubeEnvironmentsClient) createOrUpdateHandleError(resp *azcore.Response) error { 128 body, err := resp.Payload() 129 if err != nil { 130 return azcore.NewResponseError(err, resp.Response) 131 } 132 errType := DefaultErrorResponse{raw: string(body)} 133 if err := resp.UnmarshalAsJSON(&errType); err != nil { 134 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 135 } 136 return azcore.NewResponseError(&errType, resp.Response) 137} 138 139// BeginDelete - Description for Delete a Kubernetes Environment. 140// If the operation fails it returns the *DefaultErrorResponse error type. 141func (client *KubeEnvironmentsClient) BeginDelete(ctx context.Context, resourceGroupName string, name string, options *KubeEnvironmentsBeginDeleteOptions) (KubeEnvironmentsDeletePollerResponse, error) { 142 resp, err := client.deleteOperation(ctx, resourceGroupName, name, options) 143 if err != nil { 144 return KubeEnvironmentsDeletePollerResponse{}, err 145 } 146 result := KubeEnvironmentsDeletePollerResponse{ 147 RawResponse: resp.Response, 148 } 149 pt, err := armcore.NewLROPoller("KubeEnvironmentsClient.Delete", "", resp, client.con.Pipeline(), client.deleteHandleError) 150 if err != nil { 151 return KubeEnvironmentsDeletePollerResponse{}, err 152 } 153 poller := &kubeEnvironmentsDeletePoller{ 154 pt: pt, 155 } 156 result.Poller = poller 157 result.PollUntilDone = func(ctx context.Context, frequency time.Duration) (KubeEnvironmentsDeleteResponse, error) { 158 return poller.pollUntilDone(ctx, frequency) 159 } 160 return result, nil 161} 162 163// ResumeDelete creates a new KubeEnvironmentsDeletePoller from the specified resume token. 164// token - The value must come from a previous call to KubeEnvironmentsDeletePoller.ResumeToken(). 165func (client *KubeEnvironmentsClient) ResumeDelete(ctx context.Context, token string) (KubeEnvironmentsDeletePollerResponse, error) { 166 pt, err := armcore.NewLROPollerFromResumeToken("KubeEnvironmentsClient.Delete", token, client.con.Pipeline(), client.deleteHandleError) 167 if err != nil { 168 return KubeEnvironmentsDeletePollerResponse{}, err 169 } 170 poller := &kubeEnvironmentsDeletePoller{ 171 pt: pt, 172 } 173 resp, err := poller.Poll(ctx) 174 if err != nil { 175 return KubeEnvironmentsDeletePollerResponse{}, err 176 } 177 result := KubeEnvironmentsDeletePollerResponse{ 178 RawResponse: resp, 179 } 180 result.Poller = poller 181 result.PollUntilDone = func(ctx context.Context, frequency time.Duration) (KubeEnvironmentsDeleteResponse, error) { 182 return poller.pollUntilDone(ctx, frequency) 183 } 184 return result, nil 185} 186 187// Delete - Description for Delete a Kubernetes Environment. 188// If the operation fails it returns the *DefaultErrorResponse error type. 189func (client *KubeEnvironmentsClient) deleteOperation(ctx context.Context, resourceGroupName string, name string, options *KubeEnvironmentsBeginDeleteOptions) (*azcore.Response, error) { 190 req, err := client.deleteCreateRequest(ctx, resourceGroupName, name, options) 191 if err != nil { 192 return nil, err 193 } 194 resp, err := client.con.Pipeline().Do(req) 195 if err != nil { 196 return nil, err 197 } 198 if !resp.HasStatusCode(http.StatusOK, http.StatusAccepted, http.StatusNoContent) { 199 return nil, client.deleteHandleError(resp) 200 } 201 return resp, nil 202} 203 204// deleteCreateRequest creates the Delete request. 205func (client *KubeEnvironmentsClient) deleteCreateRequest(ctx context.Context, resourceGroupName string, name string, options *KubeEnvironmentsBeginDeleteOptions) (*azcore.Request, error) { 206 urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Web/kubeEnvironments/{name}" 207 if resourceGroupName == "" { 208 return nil, errors.New("parameter resourceGroupName cannot be empty") 209 } 210 urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) 211 if name == "" { 212 return nil, errors.New("parameter name cannot be empty") 213 } 214 urlPath = strings.ReplaceAll(urlPath, "{name}", url.PathEscape(name)) 215 if client.subscriptionID == "" { 216 return nil, errors.New("parameter client.subscriptionID cannot be empty") 217 } 218 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 219 req, err := azcore.NewRequest(ctx, http.MethodDelete, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 220 if err != nil { 221 return nil, err 222 } 223 req.Telemetry(telemetryInfo) 224 reqQP := req.URL.Query() 225 reqQP.Set("api-version", "2021-01-15") 226 req.URL.RawQuery = reqQP.Encode() 227 req.Header.Set("Accept", "application/json") 228 return req, nil 229} 230 231// deleteHandleError handles the Delete error response. 232func (client *KubeEnvironmentsClient) deleteHandleError(resp *azcore.Response) error { 233 body, err := resp.Payload() 234 if err != nil { 235 return azcore.NewResponseError(err, resp.Response) 236 } 237 errType := DefaultErrorResponse{raw: string(body)} 238 if err := resp.UnmarshalAsJSON(&errType); err != nil { 239 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 240 } 241 return azcore.NewResponseError(&errType, resp.Response) 242} 243 244// Get - Description for Get the properties of a Kubernetes Environment. 245// If the operation fails it returns the *DefaultErrorResponse error type. 246func (client *KubeEnvironmentsClient) Get(ctx context.Context, resourceGroupName string, name string, options *KubeEnvironmentsGetOptions) (KubeEnvironmentsGetResponse, error) { 247 req, err := client.getCreateRequest(ctx, resourceGroupName, name, options) 248 if err != nil { 249 return KubeEnvironmentsGetResponse{}, err 250 } 251 resp, err := client.con.Pipeline().Do(req) 252 if err != nil { 253 return KubeEnvironmentsGetResponse{}, err 254 } 255 if !resp.HasStatusCode(http.StatusOK) { 256 return KubeEnvironmentsGetResponse{}, client.getHandleError(resp) 257 } 258 return client.getHandleResponse(resp) 259} 260 261// getCreateRequest creates the Get request. 262func (client *KubeEnvironmentsClient) getCreateRequest(ctx context.Context, resourceGroupName string, name string, options *KubeEnvironmentsGetOptions) (*azcore.Request, error) { 263 urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Web/kubeEnvironments/{name}" 264 if resourceGroupName == "" { 265 return nil, errors.New("parameter resourceGroupName cannot be empty") 266 } 267 urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) 268 if name == "" { 269 return nil, errors.New("parameter name cannot be empty") 270 } 271 urlPath = strings.ReplaceAll(urlPath, "{name}", url.PathEscape(name)) 272 if client.subscriptionID == "" { 273 return nil, errors.New("parameter client.subscriptionID cannot be empty") 274 } 275 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 276 req, err := azcore.NewRequest(ctx, http.MethodGet, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 277 if err != nil { 278 return nil, err 279 } 280 req.Telemetry(telemetryInfo) 281 reqQP := req.URL.Query() 282 reqQP.Set("api-version", "2021-01-15") 283 req.URL.RawQuery = reqQP.Encode() 284 req.Header.Set("Accept", "application/json") 285 return req, nil 286} 287 288// getHandleResponse handles the Get response. 289func (client *KubeEnvironmentsClient) getHandleResponse(resp *azcore.Response) (KubeEnvironmentsGetResponse, error) { 290 result := KubeEnvironmentsGetResponse{RawResponse: resp.Response} 291 if err := resp.UnmarshalAsJSON(&result.KubeEnvironment); err != nil { 292 return KubeEnvironmentsGetResponse{}, err 293 } 294 return result, nil 295} 296 297// getHandleError handles the Get error response. 298func (client *KubeEnvironmentsClient) getHandleError(resp *azcore.Response) error { 299 body, err := resp.Payload() 300 if err != nil { 301 return azcore.NewResponseError(err, resp.Response) 302 } 303 errType := DefaultErrorResponse{raw: string(body)} 304 if err := resp.UnmarshalAsJSON(&errType); err != nil { 305 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 306 } 307 return azcore.NewResponseError(&errType, resp.Response) 308} 309 310// ListByResourceGroup - Description for Get all the Kubernetes Environments in a resource group. 311// If the operation fails it returns the *DefaultErrorResponse error type. 312func (client *KubeEnvironmentsClient) ListByResourceGroup(resourceGroupName string, options *KubeEnvironmentsListByResourceGroupOptions) KubeEnvironmentsListByResourceGroupPager { 313 return &kubeEnvironmentsListByResourceGroupPager{ 314 client: client, 315 requester: func(ctx context.Context) (*azcore.Request, error) { 316 return client.listByResourceGroupCreateRequest(ctx, resourceGroupName, options) 317 }, 318 advancer: func(ctx context.Context, resp KubeEnvironmentsListByResourceGroupResponse) (*azcore.Request, error) { 319 return azcore.NewRequest(ctx, http.MethodGet, *resp.KubeEnvironmentCollection.NextLink) 320 }, 321 } 322} 323 324// listByResourceGroupCreateRequest creates the ListByResourceGroup request. 325func (client *KubeEnvironmentsClient) listByResourceGroupCreateRequest(ctx context.Context, resourceGroupName string, options *KubeEnvironmentsListByResourceGroupOptions) (*azcore.Request, error) { 326 urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Web/kubeEnvironments" 327 if resourceGroupName == "" { 328 return nil, errors.New("parameter resourceGroupName cannot be empty") 329 } 330 urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) 331 if client.subscriptionID == "" { 332 return nil, errors.New("parameter client.subscriptionID cannot be empty") 333 } 334 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 335 req, err := azcore.NewRequest(ctx, http.MethodGet, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 336 if err != nil { 337 return nil, err 338 } 339 req.Telemetry(telemetryInfo) 340 reqQP := req.URL.Query() 341 reqQP.Set("api-version", "2021-01-15") 342 req.URL.RawQuery = reqQP.Encode() 343 req.Header.Set("Accept", "application/json") 344 return req, nil 345} 346 347// listByResourceGroupHandleResponse handles the ListByResourceGroup response. 348func (client *KubeEnvironmentsClient) listByResourceGroupHandleResponse(resp *azcore.Response) (KubeEnvironmentsListByResourceGroupResponse, error) { 349 result := KubeEnvironmentsListByResourceGroupResponse{RawResponse: resp.Response} 350 if err := resp.UnmarshalAsJSON(&result.KubeEnvironmentCollection); err != nil { 351 return KubeEnvironmentsListByResourceGroupResponse{}, err 352 } 353 return result, nil 354} 355 356// listByResourceGroupHandleError handles the ListByResourceGroup error response. 357func (client *KubeEnvironmentsClient) listByResourceGroupHandleError(resp *azcore.Response) error { 358 body, err := resp.Payload() 359 if err != nil { 360 return azcore.NewResponseError(err, resp.Response) 361 } 362 errType := DefaultErrorResponse{raw: string(body)} 363 if err := resp.UnmarshalAsJSON(&errType); err != nil { 364 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 365 } 366 return azcore.NewResponseError(&errType, resp.Response) 367} 368 369// ListBySubscription - Description for Get all Kubernetes Environments for a subscription. 370// If the operation fails it returns the *DefaultErrorResponse error type. 371func (client *KubeEnvironmentsClient) ListBySubscription(options *KubeEnvironmentsListBySubscriptionOptions) KubeEnvironmentsListBySubscriptionPager { 372 return &kubeEnvironmentsListBySubscriptionPager{ 373 client: client, 374 requester: func(ctx context.Context) (*azcore.Request, error) { 375 return client.listBySubscriptionCreateRequest(ctx, options) 376 }, 377 advancer: func(ctx context.Context, resp KubeEnvironmentsListBySubscriptionResponse) (*azcore.Request, error) { 378 return azcore.NewRequest(ctx, http.MethodGet, *resp.KubeEnvironmentCollection.NextLink) 379 }, 380 } 381} 382 383// listBySubscriptionCreateRequest creates the ListBySubscription request. 384func (client *KubeEnvironmentsClient) listBySubscriptionCreateRequest(ctx context.Context, options *KubeEnvironmentsListBySubscriptionOptions) (*azcore.Request, error) { 385 urlPath := "/subscriptions/{subscriptionId}/providers/Microsoft.Web/kubeEnvironments" 386 if client.subscriptionID == "" { 387 return nil, errors.New("parameter client.subscriptionID cannot be empty") 388 } 389 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 390 req, err := azcore.NewRequest(ctx, http.MethodGet, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 391 if err != nil { 392 return nil, err 393 } 394 req.Telemetry(telemetryInfo) 395 reqQP := req.URL.Query() 396 reqQP.Set("api-version", "2021-01-15") 397 req.URL.RawQuery = reqQP.Encode() 398 req.Header.Set("Accept", "application/json") 399 return req, nil 400} 401 402// listBySubscriptionHandleResponse handles the ListBySubscription response. 403func (client *KubeEnvironmentsClient) listBySubscriptionHandleResponse(resp *azcore.Response) (KubeEnvironmentsListBySubscriptionResponse, error) { 404 result := KubeEnvironmentsListBySubscriptionResponse{RawResponse: resp.Response} 405 if err := resp.UnmarshalAsJSON(&result.KubeEnvironmentCollection); err != nil { 406 return KubeEnvironmentsListBySubscriptionResponse{}, err 407 } 408 return result, nil 409} 410 411// listBySubscriptionHandleError handles the ListBySubscription error response. 412func (client *KubeEnvironmentsClient) listBySubscriptionHandleError(resp *azcore.Response) error { 413 body, err := resp.Payload() 414 if err != nil { 415 return azcore.NewResponseError(err, resp.Response) 416 } 417 errType := DefaultErrorResponse{raw: string(body)} 418 if err := resp.UnmarshalAsJSON(&errType); err != nil { 419 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 420 } 421 return azcore.NewResponseError(&errType, resp.Response) 422} 423 424// Update - Description for Creates or updates a Kubernetes Environment. 425// If the operation fails it returns the *DefaultErrorResponse error type. 426func (client *KubeEnvironmentsClient) Update(ctx context.Context, resourceGroupName string, name string, kubeEnvironmentEnvelope KubeEnvironmentPatchResource, options *KubeEnvironmentsUpdateOptions) (KubeEnvironmentsUpdateResponse, error) { 427 req, err := client.updateCreateRequest(ctx, resourceGroupName, name, kubeEnvironmentEnvelope, options) 428 if err != nil { 429 return KubeEnvironmentsUpdateResponse{}, err 430 } 431 resp, err := client.con.Pipeline().Do(req) 432 if err != nil { 433 return KubeEnvironmentsUpdateResponse{}, err 434 } 435 if !resp.HasStatusCode(http.StatusOK, http.StatusCreated) { 436 return KubeEnvironmentsUpdateResponse{}, client.updateHandleError(resp) 437 } 438 return client.updateHandleResponse(resp) 439} 440 441// updateCreateRequest creates the Update request. 442func (client *KubeEnvironmentsClient) updateCreateRequest(ctx context.Context, resourceGroupName string, name string, kubeEnvironmentEnvelope KubeEnvironmentPatchResource, options *KubeEnvironmentsUpdateOptions) (*azcore.Request, error) { 443 urlPath := "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Web/kubeEnvironments/{name}" 444 if resourceGroupName == "" { 445 return nil, errors.New("parameter resourceGroupName cannot be empty") 446 } 447 urlPath = strings.ReplaceAll(urlPath, "{resourceGroupName}", url.PathEscape(resourceGroupName)) 448 if name == "" { 449 return nil, errors.New("parameter name cannot be empty") 450 } 451 urlPath = strings.ReplaceAll(urlPath, "{name}", url.PathEscape(name)) 452 if client.subscriptionID == "" { 453 return nil, errors.New("parameter client.subscriptionID cannot be empty") 454 } 455 urlPath = strings.ReplaceAll(urlPath, "{subscriptionId}", url.PathEscape(client.subscriptionID)) 456 req, err := azcore.NewRequest(ctx, http.MethodPatch, azcore.JoinPaths(client.con.Endpoint(), urlPath)) 457 if err != nil { 458 return nil, err 459 } 460 req.Telemetry(telemetryInfo) 461 reqQP := req.URL.Query() 462 reqQP.Set("api-version", "2021-01-15") 463 req.URL.RawQuery = reqQP.Encode() 464 req.Header.Set("Accept", "application/json") 465 return req, req.MarshalAsJSON(kubeEnvironmentEnvelope) 466} 467 468// updateHandleResponse handles the Update response. 469func (client *KubeEnvironmentsClient) updateHandleResponse(resp *azcore.Response) (KubeEnvironmentsUpdateResponse, error) { 470 result := KubeEnvironmentsUpdateResponse{RawResponse: resp.Response} 471 if err := resp.UnmarshalAsJSON(&result.KubeEnvironment); err != nil { 472 return KubeEnvironmentsUpdateResponse{}, err 473 } 474 return result, nil 475} 476 477// updateHandleError handles the Update error response. 478func (client *KubeEnvironmentsClient) updateHandleError(resp *azcore.Response) error { 479 body, err := resp.Payload() 480 if err != nil { 481 return azcore.NewResponseError(err, resp.Response) 482 } 483 errType := DefaultErrorResponse{raw: string(body)} 484 if err := resp.UnmarshalAsJSON(&errType); err != nil { 485 return azcore.NewResponseError(fmt.Errorf("%s\n%s", string(body), err), resp.Response) 486 } 487 return azcore.NewResponseError(&errType, resp.Response) 488} 489