| package network |
| |
| // Copyright (c) Microsoft and contributors. All rights reserved. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| // |
| // Code generated by Microsoft (R) AutoRest Code Generator. |
| // Changes may cause incorrect behavior and will be lost if the code is regenerated. |
| |
| import ( |
| "context" |
| "github.com/Azure/go-autorest/autorest" |
| "github.com/Azure/go-autorest/autorest/azure" |
| "github.com/Azure/go-autorest/autorest/validation" |
| "github.com/Azure/go-autorest/tracing" |
| "net/http" |
| ) |
| |
| // WatchersClient is the network Client |
| type WatchersClient struct { |
| BaseClient |
| } |
| |
| // NewWatchersClient creates an instance of the WatchersClient client. |
| func NewWatchersClient(subscriptionID string) WatchersClient { |
| return NewWatchersClientWithBaseURI(DefaultBaseURI, subscriptionID) |
| } |
| |
| // NewWatchersClientWithBaseURI creates an instance of the WatchersClient client. |
| func NewWatchersClientWithBaseURI(baseURI string, subscriptionID string) WatchersClient { |
| return WatchersClient{NewWithBaseURI(baseURI, subscriptionID)} |
| } |
| |
| // CheckConnectivity verifies the possibility of establishing a direct TCP connection from a virtual machine to a given |
| // endpoint including another VM or an arbitrary remote server. |
| // Parameters: |
| // resourceGroupName - the name of the network watcher resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that determine how the connectivity check will be performed. |
| func (client WatchersClient) CheckConnectivity(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters ConnectivityParameters) (result WatchersCheckConnectivityFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.CheckConnectivity") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.Source", Name: validation.Null, Rule: true, |
| Chain: []validation.Constraint{{Target: "parameters.Source.ResourceID", Name: validation.Null, Rule: true, Chain: nil}}}, |
| {Target: "parameters.Destination", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "CheckConnectivity", err.Error()) |
| } |
| |
| req, err := client.CheckConnectivityPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "CheckConnectivity", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.CheckConnectivitySender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "CheckConnectivity", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // CheckConnectivityPreparer prepares the CheckConnectivity request. |
| func (client WatchersClient) CheckConnectivityPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters ConnectivityParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/connectivityCheck", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // CheckConnectivitySender sends the CheckConnectivity request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) CheckConnectivitySender(req *http.Request) (future WatchersCheckConnectivityFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // CheckConnectivityResponder handles the response to the CheckConnectivity request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) CheckConnectivityResponder(resp *http.Response) (result ConnectivityInformation, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // CreateOrUpdate creates or updates a network watcher in the specified resource group. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters that define the network watcher resource. |
| func (client WatchersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters Watcher) (result Watcher, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.CreateOrUpdate") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.CreateOrUpdatePreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "CreateOrUpdate", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.CreateOrUpdateSender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "CreateOrUpdate", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.CreateOrUpdateResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "CreateOrUpdate", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // CreateOrUpdatePreparer prepares the CreateOrUpdate request. |
| func (client WatchersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters Watcher) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPut(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) CreateOrUpdateResponder(resp *http.Response) (result Watcher, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusCreated), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // Delete deletes the specified network watcher resource. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| func (client WatchersClient) Delete(ctx context.Context, resourceGroupName string, networkWatcherName string) (result WatchersDeleteFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.Delete") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.DeletePreparer(ctx, resourceGroupName, networkWatcherName) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "Delete", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.DeleteSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "Delete", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // DeletePreparer prepares the Delete request. |
| func (client WatchersClient) DeletePreparer(ctx context.Context, resourceGroupName string, networkWatcherName string) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsDelete(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}", pathParameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // DeleteSender sends the Delete request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) DeleteSender(req *http.Request) (future WatchersDeleteFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // DeleteResponder handles the response to the Delete request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted, http.StatusNoContent), |
| autorest.ByClosing()) |
| result.Response = resp |
| return |
| } |
| |
| // Get gets the specified network watcher by resource group. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| func (client WatchersClient) Get(ctx context.Context, resourceGroupName string, networkWatcherName string) (result Watcher, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.Get") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.GetPreparer(ctx, resourceGroupName, networkWatcherName) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "Get", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.GetSender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "Get", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.GetResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "Get", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // GetPreparer prepares the Get request. |
| func (client WatchersClient) GetPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsGet(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}", pathParameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetSender sends the Get request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetSender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // GetResponder handles the response to the Get request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetResponder(resp *http.Response) (result Watcher, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetAzureReachabilityReport gets the relative latency score for internet service providers from a specified location |
| // to Azure regions. |
| // Parameters: |
| // resourceGroupName - the name of the network watcher resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that determine Azure reachability report configuration. |
| func (client WatchersClient) GetAzureReachabilityReport(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters AzureReachabilityReportParameters) (result WatchersGetAzureReachabilityReportFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetAzureReachabilityReport") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.ProviderLocation", Name: validation.Null, Rule: true, |
| Chain: []validation.Constraint{{Target: "parameters.ProviderLocation.Country", Name: validation.Null, Rule: true, Chain: nil}}}, |
| {Target: "parameters.StartTime", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.EndTime", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetAzureReachabilityReport", err.Error()) |
| } |
| |
| req, err := client.GetAzureReachabilityReportPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetAzureReachabilityReport", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetAzureReachabilityReportSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetAzureReachabilityReport", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetAzureReachabilityReportPreparer prepares the GetAzureReachabilityReport request. |
| func (client WatchersClient) GetAzureReachabilityReportPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters AzureReachabilityReportParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/azureReachabilityReport", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetAzureReachabilityReportSender sends the GetAzureReachabilityReport request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetAzureReachabilityReportSender(req *http.Request) (future WatchersGetAzureReachabilityReportFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetAzureReachabilityReportResponder handles the response to the GetAzureReachabilityReport request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetAzureReachabilityReportResponder(resp *http.Response) (result AzureReachabilityReport, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetFlowLogStatus queries status of flow log on a specified resource. |
| // Parameters: |
| // resourceGroupName - the name of the network watcher resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that define a resource to query flow log status. |
| func (client WatchersClient) GetFlowLogStatus(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters FlowLogStatusParameters) (result WatchersGetFlowLogStatusFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetFlowLogStatus") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetFlowLogStatus", err.Error()) |
| } |
| |
| req, err := client.GetFlowLogStatusPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetFlowLogStatus", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetFlowLogStatusSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetFlowLogStatus", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetFlowLogStatusPreparer prepares the GetFlowLogStatus request. |
| func (client WatchersClient) GetFlowLogStatusPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters FlowLogStatusParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/queryFlowLogStatus", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetFlowLogStatusSender sends the GetFlowLogStatus request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetFlowLogStatusSender(req *http.Request) (future WatchersGetFlowLogStatusFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetFlowLogStatusResponder handles the response to the GetFlowLogStatus request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetFlowLogStatusResponder(resp *http.Response) (result FlowLogInformation, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetNextHop gets the next hop from the specified VM. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters that define the source and destination endpoint. |
| func (client WatchersClient) GetNextHop(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters NextHopParameters) (result WatchersGetNextHopFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetNextHop") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.SourceIPAddress", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.DestinationIPAddress", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetNextHop", err.Error()) |
| } |
| |
| req, err := client.GetNextHopPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetNextHop", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetNextHopSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetNextHop", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetNextHopPreparer prepares the GetNextHop request. |
| func (client WatchersClient) GetNextHopPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters NextHopParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/nextHop", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetNextHopSender sends the GetNextHop request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetNextHopSender(req *http.Request) (future WatchersGetNextHopFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetNextHopResponder handles the response to the GetNextHop request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetNextHopResponder(resp *http.Response) (result NextHopResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetTopology gets the current network topology by resource group. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters that define the representation of topology. |
| func (client WatchersClient) GetTopology(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TopologyParameters) (result Topology, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetTopology") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceGroupName", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetTopology", err.Error()) |
| } |
| |
| req, err := client.GetTopologyPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTopology", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.GetTopologySender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTopology", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.GetTopologyResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTopology", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // GetTopologyPreparer prepares the GetTopology request. |
| func (client WatchersClient) GetTopologyPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TopologyParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/topology", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetTopologySender sends the GetTopology request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetTopologySender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // GetTopologyResponder handles the response to the GetTopology request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetTopologyResponder(resp *http.Response) (result Topology, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetTroubleshooting initiate troubleshooting on a specified resource |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that define the resource to troubleshoot. |
| func (client WatchersClient) GetTroubleshooting(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TroubleshootingParameters) (result WatchersGetTroubleshootingFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetTroubleshooting") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.TroubleshootingProperties", Name: validation.Null, Rule: true, |
| Chain: []validation.Constraint{{Target: "parameters.TroubleshootingProperties.StorageID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.TroubleshootingProperties.StoragePath", Name: validation.Null, Rule: true, Chain: nil}, |
| }}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetTroubleshooting", err.Error()) |
| } |
| |
| req, err := client.GetTroubleshootingPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTroubleshooting", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetTroubleshootingSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTroubleshooting", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetTroubleshootingPreparer prepares the GetTroubleshooting request. |
| func (client WatchersClient) GetTroubleshootingPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TroubleshootingParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/troubleshoot", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetTroubleshootingSender sends the GetTroubleshooting request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetTroubleshootingSender(req *http.Request) (future WatchersGetTroubleshootingFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetTroubleshootingResponder handles the response to the GetTroubleshooting request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetTroubleshootingResponder(resp *http.Response) (result TroubleshootingResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetTroubleshootingResult get the last completed troubleshooting result on a specified resource |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that define the resource to query the troubleshooting result. |
| func (client WatchersClient) GetTroubleshootingResult(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters QueryTroubleshootingParameters) (result WatchersGetTroubleshootingResultFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetTroubleshootingResult") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetTroubleshootingResult", err.Error()) |
| } |
| |
| req, err := client.GetTroubleshootingResultPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTroubleshootingResult", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetTroubleshootingResultSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetTroubleshootingResult", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetTroubleshootingResultPreparer prepares the GetTroubleshootingResult request. |
| func (client WatchersClient) GetTroubleshootingResultPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters QueryTroubleshootingParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/queryTroubleshootResult", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetTroubleshootingResultSender sends the GetTroubleshootingResult request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetTroubleshootingResultSender(req *http.Request) (future WatchersGetTroubleshootingResultFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetTroubleshootingResultResponder handles the response to the GetTroubleshootingResult request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetTroubleshootingResultResponder(resp *http.Response) (result TroubleshootingResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // GetVMSecurityRules gets the configured and effective security group rules on the specified VM. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters that define the VM to check security groups for. |
| func (client WatchersClient) GetVMSecurityRules(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters SecurityGroupViewParameters) (result WatchersGetVMSecurityRulesFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.GetVMSecurityRules") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "GetVMSecurityRules", err.Error()) |
| } |
| |
| req, err := client.GetVMSecurityRulesPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetVMSecurityRules", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.GetVMSecurityRulesSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "GetVMSecurityRules", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // GetVMSecurityRulesPreparer prepares the GetVMSecurityRules request. |
| func (client WatchersClient) GetVMSecurityRulesPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters SecurityGroupViewParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/securityGroupView", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // GetVMSecurityRulesSender sends the GetVMSecurityRules request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) GetVMSecurityRulesSender(req *http.Request) (future WatchersGetVMSecurityRulesFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // GetVMSecurityRulesResponder handles the response to the GetVMSecurityRules request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) GetVMSecurityRulesResponder(resp *http.Response) (result SecurityGroupViewResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // List gets all network watchers by resource group. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| func (client WatchersClient) List(ctx context.Context, resourceGroupName string) (result WatcherListResult, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.List") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.ListPreparer(ctx, resourceGroupName) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "List", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.ListSender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "List", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.ListResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "List", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // ListPreparer prepares the List request. |
| func (client WatchersClient) ListPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsGet(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers", pathParameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // ListSender sends the List request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) ListSender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // ListResponder handles the response to the List request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) ListResponder(resp *http.Response) (result WatcherListResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // ListAll gets all network watchers by subscription. |
| func (client WatchersClient) ListAll(ctx context.Context) (result WatcherListResult, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.ListAll") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.ListAllPreparer(ctx) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "ListAll", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.ListAllSender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "ListAll", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.ListAllResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "ListAll", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // ListAllPreparer prepares the ListAll request. |
| func (client WatchersClient) ListAllPreparer(ctx context.Context) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsGet(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/providers/Microsoft.Network/networkWatchers", pathParameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // ListAllSender sends the ListAll request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) ListAllSender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // ListAllResponder handles the response to the ListAll request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) ListAllResponder(resp *http.Response) (result WatcherListResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // ListAvailableProviders lists all available internet service providers for a specified Azure region. |
| // Parameters: |
| // resourceGroupName - the name of the network watcher resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that scope the list of available providers. |
| func (client WatchersClient) ListAvailableProviders(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters AvailableProvidersListParameters) (result WatchersListAvailableProvidersFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.ListAvailableProviders") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.ListAvailableProvidersPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "ListAvailableProviders", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.ListAvailableProvidersSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "ListAvailableProviders", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // ListAvailableProvidersPreparer prepares the ListAvailableProviders request. |
| func (client WatchersClient) ListAvailableProvidersPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters AvailableProvidersListParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/availableProvidersList", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // ListAvailableProvidersSender sends the ListAvailableProviders request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) ListAvailableProvidersSender(req *http.Request) (future WatchersListAvailableProvidersFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // ListAvailableProvidersResponder handles the response to the ListAvailableProviders request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) ListAvailableProvidersResponder(resp *http.Response) (result AvailableProvidersList, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // SetFlowLogConfiguration configures flow log on a specified resource. |
| // Parameters: |
| // resourceGroupName - the name of the network watcher resource group. |
| // networkWatcherName - the name of the network watcher resource. |
| // parameters - parameters that define the configuration of flow log. |
| func (client WatchersClient) SetFlowLogConfiguration(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters FlowLogInformation) (result WatchersSetFlowLogConfigurationFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.SetFlowLogConfiguration") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.FlowLogProperties", Name: validation.Null, Rule: true, |
| Chain: []validation.Constraint{{Target: "parameters.FlowLogProperties.StorageID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.FlowLogProperties.Enabled", Name: validation.Null, Rule: true, Chain: nil}, |
| }}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "SetFlowLogConfiguration", err.Error()) |
| } |
| |
| req, err := client.SetFlowLogConfigurationPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "SetFlowLogConfiguration", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.SetFlowLogConfigurationSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "SetFlowLogConfiguration", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // SetFlowLogConfigurationPreparer prepares the SetFlowLogConfiguration request. |
| func (client WatchersClient) SetFlowLogConfigurationPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters FlowLogInformation) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/configureFlowLog", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // SetFlowLogConfigurationSender sends the SetFlowLogConfiguration request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) SetFlowLogConfigurationSender(req *http.Request) (future WatchersSetFlowLogConfigurationFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // SetFlowLogConfigurationResponder handles the response to the SetFlowLogConfiguration request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) SetFlowLogConfigurationResponder(resp *http.Response) (result FlowLogInformation, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // UpdateTags updates a network watcher tags. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters supplied to update network watcher tags. |
| func (client WatchersClient) UpdateTags(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TagsObject) (result Watcher, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.UpdateTags") |
| defer func() { |
| sc := -1 |
| if result.Response.Response != nil { |
| sc = result.Response.Response.StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| req, err := client.UpdateTagsPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "UpdateTags", nil, "Failure preparing request") |
| return |
| } |
| |
| resp, err := client.UpdateTagsSender(req) |
| if err != nil { |
| result.Response = autorest.Response{Response: resp} |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "UpdateTags", resp, "Failure sending request") |
| return |
| } |
| |
| result, err = client.UpdateTagsResponder(resp) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "UpdateTags", resp, "Failure responding to request") |
| } |
| |
| return |
| } |
| |
| // UpdateTagsPreparer prepares the UpdateTags request. |
| func (client WatchersClient) UpdateTagsPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters TagsObject) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPatch(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // UpdateTagsSender sends the UpdateTags request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) UpdateTagsSender(req *http.Request) (*http.Response, error) { |
| return autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| } |
| |
| // UpdateTagsResponder handles the response to the UpdateTags request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) UpdateTagsResponder(resp *http.Response) (result Watcher, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
| |
| // VerifyIPFlow verify IP flow from the specified VM to a location given the currently configured NSG rules. |
| // Parameters: |
| // resourceGroupName - the name of the resource group. |
| // networkWatcherName - the name of the network watcher. |
| // parameters - parameters that define the IP flow to be verified. |
| func (client WatchersClient) VerifyIPFlow(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters VerificationIPFlowParameters) (result WatchersVerifyIPFlowFuture, err error) { |
| if tracing.IsEnabled() { |
| ctx = tracing.StartSpan(ctx, fqdn+"/WatchersClient.VerifyIPFlow") |
| defer func() { |
| sc := -1 |
| if result.Response() != nil { |
| sc = result.Response().StatusCode |
| } |
| tracing.EndSpan(ctx, sc, err) |
| }() |
| } |
| if err := validation.Validate([]validation.Validation{ |
| {TargetValue: parameters, |
| Constraints: []validation.Constraint{{Target: "parameters.TargetResourceID", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.LocalPort", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.RemotePort", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.LocalIPAddress", Name: validation.Null, Rule: true, Chain: nil}, |
| {Target: "parameters.RemoteIPAddress", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil { |
| return result, validation.NewError("network.WatchersClient", "VerifyIPFlow", err.Error()) |
| } |
| |
| req, err := client.VerifyIPFlowPreparer(ctx, resourceGroupName, networkWatcherName, parameters) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "VerifyIPFlow", nil, "Failure preparing request") |
| return |
| } |
| |
| result, err = client.VerifyIPFlowSender(req) |
| if err != nil { |
| err = autorest.NewErrorWithError(err, "network.WatchersClient", "VerifyIPFlow", result.Response(), "Failure sending request") |
| return |
| } |
| |
| return |
| } |
| |
| // VerifyIPFlowPreparer prepares the VerifyIPFlow request. |
| func (client WatchersClient) VerifyIPFlowPreparer(ctx context.Context, resourceGroupName string, networkWatcherName string, parameters VerificationIPFlowParameters) (*http.Request, error) { |
| pathParameters := map[string]interface{}{ |
| "networkWatcherName": autorest.Encode("path", networkWatcherName), |
| "resourceGroupName": autorest.Encode("path", resourceGroupName), |
| "subscriptionId": autorest.Encode("path", client.SubscriptionID), |
| } |
| |
| const APIVersion = "2017-09-01" |
| queryParameters := map[string]interface{}{ |
| "api-version": APIVersion, |
| } |
| |
| preparer := autorest.CreatePreparer( |
| autorest.AsContentType("application/json; charset=utf-8"), |
| autorest.AsPost(), |
| autorest.WithBaseURL(client.BaseURI), |
| autorest.WithPathParameters("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/ipFlowVerify", pathParameters), |
| autorest.WithJSON(parameters), |
| autorest.WithQueryParameters(queryParameters)) |
| return preparer.Prepare((&http.Request{}).WithContext(ctx)) |
| } |
| |
| // VerifyIPFlowSender sends the VerifyIPFlow request. The method will close the |
| // http.Response Body if it receives an error. |
| func (client WatchersClient) VerifyIPFlowSender(req *http.Request) (future WatchersVerifyIPFlowFuture, err error) { |
| var resp *http.Response |
| resp, err = autorest.SendWithSender(client, req, |
| azure.DoRetryWithRegistration(client.Client)) |
| if err != nil { |
| return |
| } |
| future.Future, err = azure.NewFutureFromResponse(resp) |
| return |
| } |
| |
| // VerifyIPFlowResponder handles the response to the VerifyIPFlow request. The method always |
| // closes the http.Response Body. |
| func (client WatchersClient) VerifyIPFlowResponder(resp *http.Response) (result VerificationIPFlowResult, err error) { |
| err = autorest.Respond( |
| resp, |
| client.ByInspecting(), |
| azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusAccepted), |
| autorest.ByUnmarshallingJSON(&result), |
| autorest.ByClosing()) |
| result.Response = autorest.Response{Response: resp} |
| return |
| } |
