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