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