1 package hybridcompute
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/tracing"
14 "net/http"
15 )
16
17
18 type MachinesClient struct {
19 BaseClient
20 }
21
22
23 func NewMachinesClient(subscriptionID string) MachinesClient {
24 return NewMachinesClientWithBaseURI(DefaultBaseURI, subscriptionID)
25 }
26
27
28
29 func NewMachinesClientWithBaseURI(baseURI string, subscriptionID string) MachinesClient {
30 return MachinesClient{NewWithBaseURI(baseURI, subscriptionID)}
31 }
32
33
34
35
36
37
38 func (client MachinesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, name string, parameters Machine) (result Machine, err error) {
39 if tracing.IsEnabled() {
40 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.CreateOrUpdate")
41 defer func() {
42 sc := -1
43 if result.Response.Response != nil {
44 sc = result.Response.Response.StatusCode
45 }
46 tracing.EndSpan(ctx, sc, err)
47 }()
48 }
49 req, err := client.CreateOrUpdatePreparer(ctx, resourceGroupName, name, parameters)
50 if err != nil {
51 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "CreateOrUpdate", nil, "Failure preparing request")
52 return
53 }
54
55 resp, err := client.CreateOrUpdateSender(req)
56 if err != nil {
57 result.Response = autorest.Response{Response: resp}
58 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "CreateOrUpdate", resp, "Failure sending request")
59 return
60 }
61
62 result, err = client.CreateOrUpdateResponder(resp)
63 if err != nil {
64 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "CreateOrUpdate", resp, "Failure responding to request")
65 return
66 }
67
68 return
69 }
70
71
72 func (client MachinesClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, name string, parameters Machine) (*http.Request, error) {
73 pathParameters := map[string]interface{}{
74 "name": autorest.Encode("path", name),
75 "resourceGroupName": autorest.Encode("path", resourceGroupName),
76 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
77 }
78
79 const APIVersion = "2020-08-02"
80 queryParameters := map[string]interface{}{
81 "api-version": APIVersion,
82 }
83
84 preparer := autorest.CreatePreparer(
85 autorest.AsContentType("application/json; charset=utf-8"),
86 autorest.AsPut(),
87 autorest.WithBaseURL(client.BaseURI),
88 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HybridCompute/machines/{name}", pathParameters),
89 autorest.WithJSON(parameters),
90 autorest.WithQueryParameters(queryParameters))
91 return preparer.Prepare((&http.Request{}).WithContext(ctx))
92 }
93
94
95
96 func (client MachinesClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error) {
97 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
98 }
99
100
101
102 func (client MachinesClient) CreateOrUpdateResponder(resp *http.Response) (result Machine, err error) {
103 err = autorest.Respond(
104 resp,
105 azure.WithErrorUnlessStatusCode(http.StatusOK),
106 autorest.ByUnmarshallingJSON(&result),
107 autorest.ByClosing())
108 result.Response = autorest.Response{Response: resp}
109 return
110 }
111
112
113
114
115
116 func (client MachinesClient) Delete(ctx context.Context, resourceGroupName string, name string) (result autorest.Response, err error) {
117 if tracing.IsEnabled() {
118 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.Delete")
119 defer func() {
120 sc := -1
121 if result.Response != nil {
122 sc = result.Response.StatusCode
123 }
124 tracing.EndSpan(ctx, sc, err)
125 }()
126 }
127 req, err := client.DeletePreparer(ctx, resourceGroupName, name)
128 if err != nil {
129 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Delete", nil, "Failure preparing request")
130 return
131 }
132
133 resp, err := client.DeleteSender(req)
134 if err != nil {
135 result.Response = resp
136 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Delete", resp, "Failure sending request")
137 return
138 }
139
140 result, err = client.DeleteResponder(resp)
141 if err != nil {
142 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Delete", resp, "Failure responding to request")
143 return
144 }
145
146 return
147 }
148
149
150 func (client MachinesClient) DeletePreparer(ctx context.Context, resourceGroupName string, name string) (*http.Request, error) {
151 pathParameters := map[string]interface{}{
152 "name": autorest.Encode("path", name),
153 "resourceGroupName": autorest.Encode("path", resourceGroupName),
154 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
155 }
156
157 const APIVersion = "2020-08-02"
158 queryParameters := map[string]interface{}{
159 "api-version": APIVersion,
160 }
161
162 preparer := autorest.CreatePreparer(
163 autorest.AsDelete(),
164 autorest.WithBaseURL(client.BaseURI),
165 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HybridCompute/machines/{name}", pathParameters),
166 autorest.WithQueryParameters(queryParameters))
167 return preparer.Prepare((&http.Request{}).WithContext(ctx))
168 }
169
170
171
172 func (client MachinesClient) DeleteSender(req *http.Request) (*http.Response, error) {
173 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
174 }
175
176
177
178 func (client MachinesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) {
179 err = autorest.Respond(
180 resp,
181 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusNoContent),
182 autorest.ByClosing())
183 result.Response = resp
184 return
185 }
186
187
188
189
190
191
192 func (client MachinesClient) Get(ctx context.Context, resourceGroupName string, name string, expand InstanceViewTypes) (result Machine, err error) {
193 if tracing.IsEnabled() {
194 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.Get")
195 defer func() {
196 sc := -1
197 if result.Response.Response != nil {
198 sc = result.Response.Response.StatusCode
199 }
200 tracing.EndSpan(ctx, sc, err)
201 }()
202 }
203 req, err := client.GetPreparer(ctx, resourceGroupName, name, expand)
204 if err != nil {
205 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Get", nil, "Failure preparing request")
206 return
207 }
208
209 resp, err := client.GetSender(req)
210 if err != nil {
211 result.Response = autorest.Response{Response: resp}
212 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Get", resp, "Failure sending request")
213 return
214 }
215
216 result, err = client.GetResponder(resp)
217 if err != nil {
218 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Get", resp, "Failure responding to request")
219 return
220 }
221
222 return
223 }
224
225
226 func (client MachinesClient) GetPreparer(ctx context.Context, resourceGroupName string, name string, expand InstanceViewTypes) (*http.Request, error) {
227 pathParameters := map[string]interface{}{
228 "name": autorest.Encode("path", name),
229 "resourceGroupName": autorest.Encode("path", resourceGroupName),
230 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
231 }
232
233 const APIVersion = "2020-08-02"
234 queryParameters := map[string]interface{}{
235 "api-version": APIVersion,
236 }
237 if len(string(expand)) > 0 {
238 queryParameters["$expand"] = autorest.Encode("query", expand)
239 }
240
241 preparer := autorest.CreatePreparer(
242 autorest.AsGet(),
243 autorest.WithBaseURL(client.BaseURI),
244 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HybridCompute/machines/{name}", pathParameters),
245 autorest.WithQueryParameters(queryParameters))
246 return preparer.Prepare((&http.Request{}).WithContext(ctx))
247 }
248
249
250
251 func (client MachinesClient) GetSender(req *http.Request) (*http.Response, error) {
252 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
253 }
254
255
256
257 func (client MachinesClient) GetResponder(resp *http.Response) (result Machine, err error) {
258 err = autorest.Respond(
259 resp,
260 azure.WithErrorUnlessStatusCode(http.StatusOK),
261 autorest.ByUnmarshallingJSON(&result),
262 autorest.ByClosing())
263 result.Response = autorest.Response{Response: resp}
264 return
265 }
266
267
268
269
270 func (client MachinesClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result MachineListResultPage, err error) {
271 if tracing.IsEnabled() {
272 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.ListByResourceGroup")
273 defer func() {
274 sc := -1
275 if result.mlr.Response.Response != nil {
276 sc = result.mlr.Response.Response.StatusCode
277 }
278 tracing.EndSpan(ctx, sc, err)
279 }()
280 }
281 result.fn = client.listByResourceGroupNextResults
282 req, err := client.ListByResourceGroupPreparer(ctx, resourceGroupName)
283 if err != nil {
284 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListByResourceGroup", nil, "Failure preparing request")
285 return
286 }
287
288 resp, err := client.ListByResourceGroupSender(req)
289 if err != nil {
290 result.mlr.Response = autorest.Response{Response: resp}
291 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListByResourceGroup", resp, "Failure sending request")
292 return
293 }
294
295 result.mlr, err = client.ListByResourceGroupResponder(resp)
296 if err != nil {
297 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListByResourceGroup", resp, "Failure responding to request")
298 return
299 }
300 if result.mlr.hasNextLink() && result.mlr.IsEmpty() {
301 err = result.NextWithContext(ctx)
302 return
303 }
304
305 return
306 }
307
308
309 func (client MachinesClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error) {
310 pathParameters := map[string]interface{}{
311 "resourceGroupName": autorest.Encode("path", resourceGroupName),
312 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
313 }
314
315 const APIVersion = "2020-08-02"
316 queryParameters := map[string]interface{}{
317 "api-version": APIVersion,
318 }
319
320 preparer := autorest.CreatePreparer(
321 autorest.AsGet(),
322 autorest.WithBaseURL(client.BaseURI),
323 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HybridCompute/machines", pathParameters),
324 autorest.WithQueryParameters(queryParameters))
325 return preparer.Prepare((&http.Request{}).WithContext(ctx))
326 }
327
328
329
330 func (client MachinesClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error) {
331 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
332 }
333
334
335
336 func (client MachinesClient) ListByResourceGroupResponder(resp *http.Response) (result MachineListResult, err error) {
337 err = autorest.Respond(
338 resp,
339 azure.WithErrorUnlessStatusCode(http.StatusOK),
340 autorest.ByUnmarshallingJSON(&result),
341 autorest.ByClosing())
342 result.Response = autorest.Response{Response: resp}
343 return
344 }
345
346
347 func (client MachinesClient) listByResourceGroupNextResults(ctx context.Context, lastResults MachineListResult) (result MachineListResult, err error) {
348 req, err := lastResults.machineListResultPreparer(ctx)
349 if err != nil {
350 return result, autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listByResourceGroupNextResults", nil, "Failure preparing next results request")
351 }
352 if req == nil {
353 return
354 }
355 resp, err := client.ListByResourceGroupSender(req)
356 if err != nil {
357 result.Response = autorest.Response{Response: resp}
358 return result, autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listByResourceGroupNextResults", resp, "Failure sending next results request")
359 }
360 result, err = client.ListByResourceGroupResponder(resp)
361 if err != nil {
362 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listByResourceGroupNextResults", resp, "Failure responding to next results request")
363 }
364 return
365 }
366
367
368 func (client MachinesClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string) (result MachineListResultIterator, err error) {
369 if tracing.IsEnabled() {
370 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.ListByResourceGroup")
371 defer func() {
372 sc := -1
373 if result.Response().Response.Response != nil {
374 sc = result.page.Response().Response.Response.StatusCode
375 }
376 tracing.EndSpan(ctx, sc, err)
377 }()
378 }
379 result.page, err = client.ListByResourceGroup(ctx, resourceGroupName)
380 return
381 }
382
383
384 func (client MachinesClient) ListBySubscription(ctx context.Context) (result MachineListResultPage, err error) {
385 if tracing.IsEnabled() {
386 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.ListBySubscription")
387 defer func() {
388 sc := -1
389 if result.mlr.Response.Response != nil {
390 sc = result.mlr.Response.Response.StatusCode
391 }
392 tracing.EndSpan(ctx, sc, err)
393 }()
394 }
395 result.fn = client.listBySubscriptionNextResults
396 req, err := client.ListBySubscriptionPreparer(ctx)
397 if err != nil {
398 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListBySubscription", nil, "Failure preparing request")
399 return
400 }
401
402 resp, err := client.ListBySubscriptionSender(req)
403 if err != nil {
404 result.mlr.Response = autorest.Response{Response: resp}
405 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListBySubscription", resp, "Failure sending request")
406 return
407 }
408
409 result.mlr, err = client.ListBySubscriptionResponder(resp)
410 if err != nil {
411 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "ListBySubscription", resp, "Failure responding to request")
412 return
413 }
414 if result.mlr.hasNextLink() && result.mlr.IsEmpty() {
415 err = result.NextWithContext(ctx)
416 return
417 }
418
419 return
420 }
421
422
423 func (client MachinesClient) ListBySubscriptionPreparer(ctx context.Context) (*http.Request, error) {
424 pathParameters := map[string]interface{}{
425 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
426 }
427
428 const APIVersion = "2020-08-02"
429 queryParameters := map[string]interface{}{
430 "api-version": APIVersion,
431 }
432
433 preparer := autorest.CreatePreparer(
434 autorest.AsGet(),
435 autorest.WithBaseURL(client.BaseURI),
436 autorest.WithPathParameters("/subscriptions/{subscriptionId}/providers/Microsoft.HybridCompute/machines", pathParameters),
437 autorest.WithQueryParameters(queryParameters))
438 return preparer.Prepare((&http.Request{}).WithContext(ctx))
439 }
440
441
442
443 func (client MachinesClient) ListBySubscriptionSender(req *http.Request) (*http.Response, error) {
444 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
445 }
446
447
448
449 func (client MachinesClient) ListBySubscriptionResponder(resp *http.Response) (result MachineListResult, err error) {
450 err = autorest.Respond(
451 resp,
452 azure.WithErrorUnlessStatusCode(http.StatusOK),
453 autorest.ByUnmarshallingJSON(&result),
454 autorest.ByClosing())
455 result.Response = autorest.Response{Response: resp}
456 return
457 }
458
459
460 func (client MachinesClient) listBySubscriptionNextResults(ctx context.Context, lastResults MachineListResult) (result MachineListResult, err error) {
461 req, err := lastResults.machineListResultPreparer(ctx)
462 if err != nil {
463 return result, autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listBySubscriptionNextResults", nil, "Failure preparing next results request")
464 }
465 if req == nil {
466 return
467 }
468 resp, err := client.ListBySubscriptionSender(req)
469 if err != nil {
470 result.Response = autorest.Response{Response: resp}
471 return result, autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listBySubscriptionNextResults", resp, "Failure sending next results request")
472 }
473 result, err = client.ListBySubscriptionResponder(resp)
474 if err != nil {
475 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "listBySubscriptionNextResults", resp, "Failure responding to next results request")
476 }
477 return
478 }
479
480
481 func (client MachinesClient) ListBySubscriptionComplete(ctx context.Context) (result MachineListResultIterator, err error) {
482 if tracing.IsEnabled() {
483 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.ListBySubscription")
484 defer func() {
485 sc := -1
486 if result.Response().Response.Response != nil {
487 sc = result.page.Response().Response.Response.StatusCode
488 }
489 tracing.EndSpan(ctx, sc, err)
490 }()
491 }
492 result.page, err = client.ListBySubscription(ctx)
493 return
494 }
495
496
497
498
499
500
501 func (client MachinesClient) Update(ctx context.Context, resourceGroupName string, name string, parameters MachineUpdate) (result Machine, err error) {
502 if tracing.IsEnabled() {
503 ctx = tracing.StartSpan(ctx, fqdn+"/MachinesClient.Update")
504 defer func() {
505 sc := -1
506 if result.Response.Response != nil {
507 sc = result.Response.Response.StatusCode
508 }
509 tracing.EndSpan(ctx, sc, err)
510 }()
511 }
512 req, err := client.UpdatePreparer(ctx, resourceGroupName, name, parameters)
513 if err != nil {
514 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Update", nil, "Failure preparing request")
515 return
516 }
517
518 resp, err := client.UpdateSender(req)
519 if err != nil {
520 result.Response = autorest.Response{Response: resp}
521 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Update", resp, "Failure sending request")
522 return
523 }
524
525 result, err = client.UpdateResponder(resp)
526 if err != nil {
527 err = autorest.NewErrorWithError(err, "hybridcompute.MachinesClient", "Update", resp, "Failure responding to request")
528 return
529 }
530
531 return
532 }
533
534
535 func (client MachinesClient) UpdatePreparer(ctx context.Context, resourceGroupName string, name string, parameters MachineUpdate) (*http.Request, error) {
536 pathParameters := map[string]interface{}{
537 "name": autorest.Encode("path", name),
538 "resourceGroupName": autorest.Encode("path", resourceGroupName),
539 "subscriptionId": autorest.Encode("path", client.SubscriptionID),
540 }
541
542 const APIVersion = "2020-08-02"
543 queryParameters := map[string]interface{}{
544 "api-version": APIVersion,
545 }
546
547 preparer := autorest.CreatePreparer(
548 autorest.AsContentType("application/json; charset=utf-8"),
549 autorest.AsPatch(),
550 autorest.WithBaseURL(client.BaseURI),
551 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HybridCompute/machines/{name}", pathParameters),
552 autorest.WithJSON(parameters),
553 autorest.WithQueryParameters(queryParameters))
554 return preparer.Prepare((&http.Request{}).WithContext(ctx))
555 }
556
557
558
559 func (client MachinesClient) UpdateSender(req *http.Request) (*http.Response, error) {
560 return client.Send(req, azure.DoRetryWithRegistration(client.Client))
561 }
562
563
564
565 func (client MachinesClient) UpdateResponder(resp *http.Response) (result Machine, err error) {
566 err = autorest.Respond(
567 resp,
568 azure.WithErrorUnlessStatusCode(http.StatusOK),
569 autorest.ByUnmarshallingJSON(&result),
570 autorest.ByClosing())
571 result.Response = autorest.Response{Response: resp}
572 return
573 }
574
View as plain text