1package synapse 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// 6// Code generated by Microsoft (R) AutoRest Code Generator. 7// Changes may cause incorrect behavior and will be lost if the code is regenerated. 8 9import ( 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// IPFirewallRulesClient is the azure Synapse Analytics Management Client 19type IPFirewallRulesClient struct { 20 BaseClient 21} 22 23// NewIPFirewallRulesClient creates an instance of the IPFirewallRulesClient client. 24func NewIPFirewallRulesClient(subscriptionID string) IPFirewallRulesClient { 25 return NewIPFirewallRulesClientWithBaseURI(DefaultBaseURI, subscriptionID) 26} 27 28// NewIPFirewallRulesClientWithBaseURI creates an instance of the IPFirewallRulesClient client using a custom endpoint. 29// Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack). 30func NewIPFirewallRulesClientWithBaseURI(baseURI string, subscriptionID string) IPFirewallRulesClient { 31 return IPFirewallRulesClient{NewWithBaseURI(baseURI, subscriptionID)} 32} 33 34// CreateOrUpdate creates or updates a firewall rule 35// Parameters: 36// resourceGroupName - the name of the resource group. The name is case insensitive. 37// workspaceName - the name of the workspace 38// ruleName - the IP firewall rule name 39// IPFirewallRuleInfo - IP firewall rule properties 40func (client IPFirewallRulesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string, IPFirewallRuleInfo IPFirewallRuleInfo) (result IPFirewallRulesCreateOrUpdateFuture, err error) { 41 if tracing.IsEnabled() { 42 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.CreateOrUpdate") 43 defer func() { 44 sc := -1 45 if result.FutureAPI != nil && result.FutureAPI.Response() != nil { 46 sc = result.FutureAPI.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}}}, 54 {TargetValue: resourceGroupName, 55 Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, 56 {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, 57 {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}}); err != nil { 58 return result, validation.NewError("synapse.IPFirewallRulesClient", "CreateOrUpdate", err.Error()) 59 } 60 61 req, err := client.CreateOrUpdatePreparer(ctx, resourceGroupName, workspaceName, ruleName, IPFirewallRuleInfo) 62 if err != nil { 63 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "CreateOrUpdate", nil, "Failure preparing request") 64 return 65 } 66 67 result, err = client.CreateOrUpdateSender(req) 68 if err != nil { 69 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "CreateOrUpdate", nil, "Failure sending request") 70 return 71 } 72 73 return 74} 75 76// CreateOrUpdatePreparer prepares the CreateOrUpdate request. 77func (client IPFirewallRulesClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string, IPFirewallRuleInfo IPFirewallRuleInfo) (*http.Request, error) { 78 pathParameters := map[string]interface{}{ 79 "resourceGroupName": autorest.Encode("path", resourceGroupName), 80 "ruleName": autorest.Encode("path", ruleName), 81 "subscriptionId": autorest.Encode("path", client.SubscriptionID), 82 "workspaceName": autorest.Encode("path", workspaceName), 83 } 84 85 const APIVersion = "2021-03-01" 86 queryParameters := map[string]interface{}{ 87 "api-version": APIVersion, 88 } 89 90 preparer := autorest.CreatePreparer( 91 autorest.AsContentType("application/json; charset=utf-8"), 92 autorest.AsPut(), 93 autorest.WithBaseURL(client.BaseURI), 94 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse/workspaces/{workspaceName}/firewallRules/{ruleName}", pathParameters), 95 autorest.WithJSON(IPFirewallRuleInfo), 96 autorest.WithQueryParameters(queryParameters)) 97 return preparer.Prepare((&http.Request{}).WithContext(ctx)) 98} 99 100// CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the 101// http.Response Body if it receives an error. 102func (client IPFirewallRulesClient) CreateOrUpdateSender(req *http.Request) (future IPFirewallRulesCreateOrUpdateFuture, err error) { 103 var resp *http.Response 104 resp, err = client.Send(req, azure.DoRetryWithRegistration(client.Client)) 105 if err != nil { 106 return 107 } 108 var azf azure.Future 109 azf, err = azure.NewFutureFromResponse(resp) 110 future.FutureAPI = &azf 111 future.Result = future.result 112 return 113} 114 115// CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always 116// closes the http.Response Body. 117func (client IPFirewallRulesClient) CreateOrUpdateResponder(resp *http.Response) (result IPFirewallRuleInfo, err error) { 118 err = autorest.Respond( 119 resp, 120 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusCreated), 121 autorest.ByUnmarshallingJSON(&result), 122 autorest.ByClosing()) 123 result.Response = autorest.Response{Response: resp} 124 return 125} 126 127// Delete deletes a firewall rule 128// Parameters: 129// resourceGroupName - the name of the resource group. The name is case insensitive. 130// workspaceName - the name of the workspace 131// ruleName - the IP firewall rule name 132func (client IPFirewallRulesClient) Delete(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string) (result IPFirewallRulesDeleteFuture, err error) { 133 if tracing.IsEnabled() { 134 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.Delete") 135 defer func() { 136 sc := -1 137 if result.FutureAPI != nil && result.FutureAPI.Response() != nil { 138 sc = result.FutureAPI.Response().StatusCode 139 } 140 tracing.EndSpan(ctx, sc, err) 141 }() 142 } 143 if err := validation.Validate([]validation.Validation{ 144 {TargetValue: client.SubscriptionID, 145 Constraints: []validation.Constraint{{Target: "client.SubscriptionID", Name: validation.MinLength, Rule: 1, Chain: nil}}}, 146 {TargetValue: resourceGroupName, 147 Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, 148 {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, 149 {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}}); err != nil { 150 return result, validation.NewError("synapse.IPFirewallRulesClient", "Delete", err.Error()) 151 } 152 153 req, err := client.DeletePreparer(ctx, resourceGroupName, workspaceName, ruleName) 154 if err != nil { 155 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "Delete", nil, "Failure preparing request") 156 return 157 } 158 159 result, err = client.DeleteSender(req) 160 if err != nil { 161 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "Delete", nil, "Failure sending request") 162 return 163 } 164 165 return 166} 167 168// DeletePreparer prepares the Delete request. 169func (client IPFirewallRulesClient) DeletePreparer(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string) (*http.Request, error) { 170 pathParameters := map[string]interface{}{ 171 "resourceGroupName": autorest.Encode("path", resourceGroupName), 172 "ruleName": autorest.Encode("path", ruleName), 173 "subscriptionId": autorest.Encode("path", client.SubscriptionID), 174 "workspaceName": autorest.Encode("path", workspaceName), 175 } 176 177 const APIVersion = "2021-03-01" 178 queryParameters := map[string]interface{}{ 179 "api-version": APIVersion, 180 } 181 182 preparer := autorest.CreatePreparer( 183 autorest.AsDelete(), 184 autorest.WithBaseURL(client.BaseURI), 185 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse/workspaces/{workspaceName}/firewallRules/{ruleName}", pathParameters), 186 autorest.WithQueryParameters(queryParameters)) 187 return preparer.Prepare((&http.Request{}).WithContext(ctx)) 188} 189 190// DeleteSender sends the Delete request. The method will close the 191// http.Response Body if it receives an error. 192func (client IPFirewallRulesClient) DeleteSender(req *http.Request) (future IPFirewallRulesDeleteFuture, err error) { 193 var resp *http.Response 194 resp, err = client.Send(req, azure.DoRetryWithRegistration(client.Client)) 195 if err != nil { 196 return 197 } 198 var azf azure.Future 199 azf, err = azure.NewFutureFromResponse(resp) 200 future.FutureAPI = &azf 201 future.Result = future.result 202 return 203} 204 205// DeleteResponder handles the response to the Delete request. The method always 206// closes the http.Response Body. 207func (client IPFirewallRulesClient) DeleteResponder(resp *http.Response) (result SetObject, err error) { 208 err = autorest.Respond( 209 resp, 210 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted, http.StatusNoContent), 211 autorest.ByUnmarshallingJSON(&result), 212 autorest.ByClosing()) 213 result.Response = autorest.Response{Response: resp} 214 return 215} 216 217// Get get a firewall rule 218// Parameters: 219// resourceGroupName - the name of the resource group. The name is case insensitive. 220// workspaceName - the name of the workspace 221// ruleName - the IP firewall rule name 222func (client IPFirewallRulesClient) Get(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string) (result IPFirewallRuleInfo, err error) { 223 if tracing.IsEnabled() { 224 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.Get") 225 defer func() { 226 sc := -1 227 if result.Response.Response != nil { 228 sc = result.Response.Response.StatusCode 229 } 230 tracing.EndSpan(ctx, sc, err) 231 }() 232 } 233 if err := validation.Validate([]validation.Validation{ 234 {TargetValue: client.SubscriptionID, 235 Constraints: []validation.Constraint{{Target: "client.SubscriptionID", Name: validation.MinLength, Rule: 1, Chain: nil}}}, 236 {TargetValue: resourceGroupName, 237 Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, 238 {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, 239 {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}}); err != nil { 240 return result, validation.NewError("synapse.IPFirewallRulesClient", "Get", err.Error()) 241 } 242 243 req, err := client.GetPreparer(ctx, resourceGroupName, workspaceName, ruleName) 244 if err != nil { 245 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "Get", nil, "Failure preparing request") 246 return 247 } 248 249 resp, err := client.GetSender(req) 250 if err != nil { 251 result.Response = autorest.Response{Response: resp} 252 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "Get", resp, "Failure sending request") 253 return 254 } 255 256 result, err = client.GetResponder(resp) 257 if err != nil { 258 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "Get", resp, "Failure responding to request") 259 return 260 } 261 262 return 263} 264 265// GetPreparer prepares the Get request. 266func (client IPFirewallRulesClient) GetPreparer(ctx context.Context, resourceGroupName string, workspaceName string, ruleName string) (*http.Request, error) { 267 pathParameters := map[string]interface{}{ 268 "resourceGroupName": autorest.Encode("path", resourceGroupName), 269 "ruleName": autorest.Encode("path", ruleName), 270 "subscriptionId": autorest.Encode("path", client.SubscriptionID), 271 "workspaceName": autorest.Encode("path", workspaceName), 272 } 273 274 const APIVersion = "2021-03-01" 275 queryParameters := map[string]interface{}{ 276 "api-version": APIVersion, 277 } 278 279 preparer := autorest.CreatePreparer( 280 autorest.AsGet(), 281 autorest.WithBaseURL(client.BaseURI), 282 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse/workspaces/{workspaceName}/firewallRules/{ruleName}", pathParameters), 283 autorest.WithQueryParameters(queryParameters)) 284 return preparer.Prepare((&http.Request{}).WithContext(ctx)) 285} 286 287// GetSender sends the Get request. The method will close the 288// http.Response Body if it receives an error. 289func (client IPFirewallRulesClient) GetSender(req *http.Request) (*http.Response, error) { 290 return client.Send(req, azure.DoRetryWithRegistration(client.Client)) 291} 292 293// GetResponder handles the response to the Get request. The method always 294// closes the http.Response Body. 295func (client IPFirewallRulesClient) GetResponder(resp *http.Response) (result IPFirewallRuleInfo, err error) { 296 err = autorest.Respond( 297 resp, 298 azure.WithErrorUnlessStatusCode(http.StatusOK), 299 autorest.ByUnmarshallingJSON(&result), 300 autorest.ByClosing()) 301 result.Response = autorest.Response{Response: resp} 302 return 303} 304 305// ListByWorkspace returns a list of firewall rules 306// Parameters: 307// resourceGroupName - the name of the resource group. The name is case insensitive. 308// workspaceName - the name of the workspace 309func (client IPFirewallRulesClient) ListByWorkspace(ctx context.Context, resourceGroupName string, workspaceName string) (result IPFirewallRuleInfoListResultPage, err error) { 310 if tracing.IsEnabled() { 311 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.ListByWorkspace") 312 defer func() { 313 sc := -1 314 if result.ifrilr.Response.Response != nil { 315 sc = result.ifrilr.Response.Response.StatusCode 316 } 317 tracing.EndSpan(ctx, sc, err) 318 }() 319 } 320 if err := validation.Validate([]validation.Validation{ 321 {TargetValue: client.SubscriptionID, 322 Constraints: []validation.Constraint{{Target: "client.SubscriptionID", Name: validation.MinLength, Rule: 1, Chain: nil}}}, 323 {TargetValue: resourceGroupName, 324 Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, 325 {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, 326 {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}}); err != nil { 327 return result, validation.NewError("synapse.IPFirewallRulesClient", "ListByWorkspace", err.Error()) 328 } 329 330 result.fn = client.listByWorkspaceNextResults 331 req, err := client.ListByWorkspacePreparer(ctx, resourceGroupName, workspaceName) 332 if err != nil { 333 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "ListByWorkspace", nil, "Failure preparing request") 334 return 335 } 336 337 resp, err := client.ListByWorkspaceSender(req) 338 if err != nil { 339 result.ifrilr.Response = autorest.Response{Response: resp} 340 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "ListByWorkspace", resp, "Failure sending request") 341 return 342 } 343 344 result.ifrilr, err = client.ListByWorkspaceResponder(resp) 345 if err != nil { 346 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "ListByWorkspace", resp, "Failure responding to request") 347 return 348 } 349 if result.ifrilr.hasNextLink() && result.ifrilr.IsEmpty() { 350 err = result.NextWithContext(ctx) 351 return 352 } 353 354 return 355} 356 357// ListByWorkspacePreparer prepares the ListByWorkspace request. 358func (client IPFirewallRulesClient) ListByWorkspacePreparer(ctx context.Context, resourceGroupName string, workspaceName string) (*http.Request, error) { 359 pathParameters := map[string]interface{}{ 360 "resourceGroupName": autorest.Encode("path", resourceGroupName), 361 "subscriptionId": autorest.Encode("path", client.SubscriptionID), 362 "workspaceName": autorest.Encode("path", workspaceName), 363 } 364 365 const APIVersion = "2021-03-01" 366 queryParameters := map[string]interface{}{ 367 "api-version": APIVersion, 368 } 369 370 preparer := autorest.CreatePreparer( 371 autorest.AsGet(), 372 autorest.WithBaseURL(client.BaseURI), 373 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse/workspaces/{workspaceName}/firewallRules", pathParameters), 374 autorest.WithQueryParameters(queryParameters)) 375 return preparer.Prepare((&http.Request{}).WithContext(ctx)) 376} 377 378// ListByWorkspaceSender sends the ListByWorkspace request. The method will close the 379// http.Response Body if it receives an error. 380func (client IPFirewallRulesClient) ListByWorkspaceSender(req *http.Request) (*http.Response, error) { 381 return client.Send(req, azure.DoRetryWithRegistration(client.Client)) 382} 383 384// ListByWorkspaceResponder handles the response to the ListByWorkspace request. The method always 385// closes the http.Response Body. 386func (client IPFirewallRulesClient) ListByWorkspaceResponder(resp *http.Response) (result IPFirewallRuleInfoListResult, err error) { 387 err = autorest.Respond( 388 resp, 389 azure.WithErrorUnlessStatusCode(http.StatusOK), 390 autorest.ByUnmarshallingJSON(&result), 391 autorest.ByClosing()) 392 result.Response = autorest.Response{Response: resp} 393 return 394} 395 396// listByWorkspaceNextResults retrieves the next set of results, if any. 397func (client IPFirewallRulesClient) listByWorkspaceNextResults(ctx context.Context, lastResults IPFirewallRuleInfoListResult) (result IPFirewallRuleInfoListResult, err error) { 398 req, err := lastResults.iPFirewallRuleInfoListResultPreparer(ctx) 399 if err != nil { 400 return result, autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "listByWorkspaceNextResults", nil, "Failure preparing next results request") 401 } 402 if req == nil { 403 return 404 } 405 resp, err := client.ListByWorkspaceSender(req) 406 if err != nil { 407 result.Response = autorest.Response{Response: resp} 408 return result, autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "listByWorkspaceNextResults", resp, "Failure sending next results request") 409 } 410 result, err = client.ListByWorkspaceResponder(resp) 411 if err != nil { 412 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "listByWorkspaceNextResults", resp, "Failure responding to next results request") 413 } 414 return 415} 416 417// ListByWorkspaceComplete enumerates all values, automatically crossing page boundaries as required. 418func (client IPFirewallRulesClient) ListByWorkspaceComplete(ctx context.Context, resourceGroupName string, workspaceName string) (result IPFirewallRuleInfoListResultIterator, err error) { 419 if tracing.IsEnabled() { 420 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.ListByWorkspace") 421 defer func() { 422 sc := -1 423 if result.Response().Response.Response != nil { 424 sc = result.page.Response().Response.Response.StatusCode 425 } 426 tracing.EndSpan(ctx, sc, err) 427 }() 428 } 429 result.page, err = client.ListByWorkspace(ctx, resourceGroupName, workspaceName) 430 return 431} 432 433// ReplaceAll replaces firewall rules 434// Parameters: 435// resourceGroupName - the name of the resource group. The name is case insensitive. 436// workspaceName - the name of the workspace 437// request - replace all IP firewall rules request 438func (client IPFirewallRulesClient) ReplaceAll(ctx context.Context, resourceGroupName string, workspaceName string, request ReplaceAllIPFirewallRulesRequest) (result IPFirewallRulesReplaceAllFuture, err error) { 439 if tracing.IsEnabled() { 440 ctx = tracing.StartSpan(ctx, fqdn+"/IPFirewallRulesClient.ReplaceAll") 441 defer func() { 442 sc := -1 443 if result.FutureAPI != nil && result.FutureAPI.Response() != nil { 444 sc = result.FutureAPI.Response().StatusCode 445 } 446 tracing.EndSpan(ctx, sc, err) 447 }() 448 } 449 if err := validation.Validate([]validation.Validation{ 450 {TargetValue: client.SubscriptionID, 451 Constraints: []validation.Constraint{{Target: "client.SubscriptionID", Name: validation.MinLength, Rule: 1, Chain: nil}}}, 452 {TargetValue: resourceGroupName, 453 Constraints: []validation.Constraint{{Target: "resourceGroupName", Name: validation.MaxLength, Rule: 90, Chain: nil}, 454 {Target: "resourceGroupName", Name: validation.MinLength, Rule: 1, Chain: nil}, 455 {Target: "resourceGroupName", Name: validation.Pattern, Rule: `^[-\w\._\(\)]+$`, Chain: nil}}}}); err != nil { 456 return result, validation.NewError("synapse.IPFirewallRulesClient", "ReplaceAll", err.Error()) 457 } 458 459 req, err := client.ReplaceAllPreparer(ctx, resourceGroupName, workspaceName, request) 460 if err != nil { 461 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "ReplaceAll", nil, "Failure preparing request") 462 return 463 } 464 465 result, err = client.ReplaceAllSender(req) 466 if err != nil { 467 err = autorest.NewErrorWithError(err, "synapse.IPFirewallRulesClient", "ReplaceAll", nil, "Failure sending request") 468 return 469 } 470 471 return 472} 473 474// ReplaceAllPreparer prepares the ReplaceAll request. 475func (client IPFirewallRulesClient) ReplaceAllPreparer(ctx context.Context, resourceGroupName string, workspaceName string, request ReplaceAllIPFirewallRulesRequest) (*http.Request, error) { 476 pathParameters := map[string]interface{}{ 477 "resourceGroupName": autorest.Encode("path", resourceGroupName), 478 "subscriptionId": autorest.Encode("path", client.SubscriptionID), 479 "workspaceName": autorest.Encode("path", workspaceName), 480 } 481 482 const APIVersion = "2021-03-01" 483 queryParameters := map[string]interface{}{ 484 "api-version": APIVersion, 485 } 486 487 preparer := autorest.CreatePreparer( 488 autorest.AsContentType("application/json; charset=utf-8"), 489 autorest.AsPost(), 490 autorest.WithBaseURL(client.BaseURI), 491 autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Synapse/workspaces/{workspaceName}/replaceAllIpFirewallRules", pathParameters), 492 autorest.WithJSON(request), 493 autorest.WithQueryParameters(queryParameters)) 494 return preparer.Prepare((&http.Request{}).WithContext(ctx)) 495} 496 497// ReplaceAllSender sends the ReplaceAll request. The method will close the 498// http.Response Body if it receives an error. 499func (client IPFirewallRulesClient) ReplaceAllSender(req *http.Request) (future IPFirewallRulesReplaceAllFuture, err error) { 500 var resp *http.Response 501 resp, err = client.Send(req, azure.DoRetryWithRegistration(client.Client)) 502 if err != nil { 503 return 504 } 505 var azf azure.Future 506 azf, err = azure.NewFutureFromResponse(resp) 507 future.FutureAPI = &azf 508 future.Result = future.result 509 return 510} 511 512// ReplaceAllResponder handles the response to the ReplaceAll request. The method always 513// closes the http.Response Body. 514func (client IPFirewallRulesClient) ReplaceAllResponder(resp *http.Response) (result ReplaceAllFirewallRulesOperationResponse, err error) { 515 err = autorest.Respond( 516 resp, 517 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), 518 autorest.ByUnmarshallingJSON(&result), 519 autorest.ByClosing()) 520 result.Response = autorest.Response{Response: resp} 521 return 522} 523