Class: Azure::ARM::Network::NetworkWatchers

Inherits:
Object
  • Object
show all
Includes:
MsRestAzure
Defined in:
lib/generated/azure_mgmt_network/network_watchers.rb

Overview

Network Client

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client) ⇒ NetworkWatchers

Creates and initializes a new instance of the NetworkWatchers class.



17
18
19
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 17

def initialize(client)
  @client = client
end

Instance Attribute Details

#client ⇒ NetworkManagementClient (readonly) 



22
23
24
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 22

def client
  @client
end

Instance Method Details

#begin_check_connectivity(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ ConnectivityInformation

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.

group. resource. connectivity check will be performed. will be added to the HTTP request.



1971
1972
1973
1974
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1971

def begin_check_connectivity(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

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.

group. resource. connectivity check will be performed. to the HTTP request.



2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
2025
2026
2027
2028
2029
2030
2031
2032
2033
2034
2035
2036
2037
2038
2039
2040
2041
2042
2043
2044
2045
2046
2047
2048
2049
2050
2051
2052
2053
2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
2065
2066
2067
2068
2069
2070
2071
2072
2073
2074
2075
2076
2077
2078
2079
2080
2081
2082
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2012

def begin_check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::ConnectivityParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/connectivityCheck'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::ConnectivityInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::ConnectivityInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_check_connectivity_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

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.

group. resource. connectivity check will be performed. will be added to the HTTP request.



1992
1993
1994
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1992

def begin_check_connectivity_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_delete(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ Object

Deletes the specified network watcher resource.

will be added to the HTTP request.



1044
1045
1046
1047
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1044

def begin_delete(resource_group_name, network_watcher_name, custom_headers = nil)
  response = begin_delete_async(resource_group_name, network_watcher_name, custom_headers).value!
  nil
end

#begin_delete_async(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ Concurrent::Promise

Deletes the specified network watcher resource.

to the HTTP request.



1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
1112
1113
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1073

def begin_delete_async(resource_group_name, network_watcher_name, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:delete, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 202 || status_code == 204
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?

    result
  end

  promise.execute
end

#begin_delete_with_http_info(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Deletes the specified network watcher resource.

will be added to the HTTP request.



1059
1060
1061
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1059

def begin_delete_with_http_info(resource_group_name, network_watcher_name, custom_headers = nil)
  begin_delete_async(resource_group_name, network_watcher_name, custom_headers).value!
end

#begin_get_azure_reachability_report(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ AzureReachabilityReport

Gets the relative latency score for internet service providers from a specified location to Azure regions.

group. resource. determine Azure reachability report configuration. will be added to the HTTP request.



2099
2100
2101
2102
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2099

def begin_get_azure_reachability_report(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Gets the relative latency score for internet service providers from a specified location to Azure regions.

group. resource. determine Azure reachability report configuration. to the HTTP request.



2138
2139
2140
2141
2142
2143
2144
2145
2146
2147
2148
2149
2150
2151
2152
2153
2154
2155
2156
2157
2158
2159
2160
2161
2162
2163
2164
2165
2166
2167
2168
2169
2170
2171
2172
2173
2174
2175
2176
2177
2178
2179
2180
2181
2182
2183
2184
2185
2186
2187
2188
2189
2190
2191
2192
2193
2194
2195
2196
2197
2198
2199
2200
2201
2202
2203
2204
2205
2206
2207
2208
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2138

def begin_get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::AzureReachabilityReportParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/azureReachabilityReport'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::AzureReachabilityReport.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::AzureReachabilityReport.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_azure_reachability_report_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets the relative latency score for internet service providers from a specified location to Azure regions.

group. resource. determine Azure reachability report configuration. will be added to the HTTP request.



2119
2120
2121
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2119

def begin_get_azure_reachability_report_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_get_flow_log_status(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ FlowLogInformation

Queries status of flow log on a specified resource.

group. resource. to query flow log status. will be added to the HTTP request.



1846
1847
1848
1849
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1846

def begin_get_flow_log_status(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Queries status of flow log on a specified resource.

group. resource. to query flow log status. to the HTTP request.



1883
1884
1885
1886
1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
1897
1898
1899
1900
1901
1902
1903
1904
1905
1906
1907
1908
1909
1910
1911
1912
1913
1914
1915
1916
1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
1930
1931
1932
1933
1934
1935
1936
1937
1938
1939
1940
1941
1942
1943
1944
1945
1946
1947
1948
1949
1950
1951
1952
1953
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1883

def begin_get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::FlowLogStatusParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/queryFlowLogStatus'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_flow_log_status_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Queries status of flow log on a specified resource.

group. resource. to query flow log status. will be added to the HTTP request.



1865
1866
1867
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1865

def begin_get_flow_log_status_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_get_next_hop(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ NextHopResult

Gets the next hop from the specified VM.

destination endpoint. will be added to the HTTP request.



1247
1248
1249
1250
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1247

def begin_get_next_hop(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Gets the next hop from the specified VM.

destination endpoint. to the HTTP request.



1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
1347
1348
1349
1350
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1280

def begin_get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::NextHopParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/nextHop'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NextHopResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NextHopResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_next_hop_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets the next hop from the specified VM.

destination endpoint. will be added to the HTTP request.



1264
1265
1266
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1264

def begin_get_next_hop_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_get_troubleshooting(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ TroubleshootingResult

Initiate troubleshooting on a specified resource

resource. resource to troubleshoot. will be added to the HTTP request.



1482
1483
1484
1485
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1482

def begin_get_troubleshooting(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Initiate troubleshooting on a specified resource

resource. resource to troubleshoot. to the HTTP request.



1517
1518
1519
1520
1521
1522
1523
1524
1525
1526
1527
1528
1529
1530
1531
1532
1533
1534
1535
1536
1537
1538
1539
1540
1541
1542
1543
1544
1545
1546
1547
1548
1549
1550
1551
1552
1553
1554
1555
1556
1557
1558
1559
1560
1561
1562
1563
1564
1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1517

def begin_get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::TroubleshootingParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/troubleshoot'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_troubleshooting_result(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ TroubleshootingResult

Get the last completed troubleshooting result on a specified resource

resource. resource to query the troubleshooting result. will be added to the HTTP request.



1602
1603
1604
1605
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1602

def begin_get_troubleshooting_result(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Get the last completed troubleshooting result on a specified resource

resource. resource to query the troubleshooting result. to the HTTP request.



1637
1638
1639
1640
1641
1642
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
1653
1654
1655
1656
1657
1658
1659
1660
1661
1662
1663
1664
1665
1666
1667
1668
1669
1670
1671
1672
1673
1674
1675
1676
1677
1678
1679
1680
1681
1682
1683
1684
1685
1686
1687
1688
1689
1690
1691
1692
1693
1694
1695
1696
1697
1698
1699
1700
1701
1702
1703
1704
1705
1706
1707
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1637

def begin_get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::QueryTroubleshootingParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/queryTroubleshootResult'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_troubleshooting_result_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Get the last completed troubleshooting result on a specified resource

resource. resource to query the troubleshooting result. will be added to the HTTP request.



1620
1621
1622
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1620

def begin_get_troubleshooting_result_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_get_troubleshooting_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Initiate troubleshooting on a specified resource

resource. resource to troubleshoot. will be added to the HTTP request.



1500
1501
1502
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1500

def begin_get_troubleshooting_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_get_vmsecurity_rules(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ SecurityGroupViewResult

Gets the configured and effective security group rules on the specified VM.

to check security groups for. will be added to the HTTP request.



1364
1365
1366
1367
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1364

def begin_get_vmsecurity_rules(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Gets the configured and effective security group rules on the specified VM.

to check security groups for. to the HTTP request.



1397
1398
1399
1400
1401
1402
1403
1404
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
1435
1436
1437
1438
1439
1440
1441
1442
1443
1444
1445
1446
1447
1448
1449
1450
1451
1452
1453
1454
1455
1456
1457
1458
1459
1460
1461
1462
1463
1464
1465
1466
1467
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1397

def begin_get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::SecurityGroupViewParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/securityGroupView'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::SecurityGroupViewResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::SecurityGroupViewResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_get_vmsecurity_rules_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets the configured and effective security group rules on the specified VM.

to check security groups for. will be added to the HTTP request.



1381
1382
1383
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1381

def begin_get_vmsecurity_rules_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_list_available_providers(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ AvailableProvidersList

Lists all available internet service providers for a specified Azure region.

group. resource. the list of available providers. will be added to the HTTP request.



2224
2225
2226
2227
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2224

def begin_list_available_providers(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Lists all available internet service providers for a specified Azure region.

group. resource. the list of available providers. to the HTTP request.



2261
2262
2263
2264
2265
2266
2267
2268
2269
2270
2271
2272
2273
2274
2275
2276
2277
2278
2279
2280
2281
2282
2283
2284
2285
2286
2287
2288
2289
2290
2291
2292
2293
2294
2295
2296
2297
2298
2299
2300
2301
2302
2303
2304
2305
2306
2307
2308
2309
2310
2311
2312
2313
2314
2315
2316
2317
2318
2319
2320
2321
2322
2323
2324
2325
2326
2327
2328
2329
2330
2331
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2261

def begin_list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::AvailableProvidersListParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/availableProvidersList'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::AvailableProvidersList.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::AvailableProvidersList.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_list_available_providers_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Lists all available internet service providers for a specified Azure region.

group. resource. the list of available providers. will be added to the HTTP request.



2243
2244
2245
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 2243

def begin_list_available_providers_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_set_flow_log_configuration(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ FlowLogInformation

Configures flow log on a specified resource.

group. resource. configuration of flow log. will be added to the HTTP request.



1723
1724
1725
1726
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1723

def begin_set_flow_log_configuration(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Configures flow log on a specified resource.

group. resource. configuration of flow log. to the HTTP request.



1760
1761
1762
1763
1764
1765
1766
1767
1768
1769
1770
1771
1772
1773
1774
1775
1776
1777
1778
1779
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792
1793
1794
1795
1796
1797
1798
1799
1800
1801
1802
1803
1804
1805
1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
1817
1818
1819
1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1760

def begin_set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/configureFlowLog'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_set_flow_log_configuration_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Configures flow log on a specified resource.

group. resource. configuration of flow log. will be added to the HTTP request.



1742
1743
1744
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1742

def begin_set_flow_log_configuration_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#begin_verify_ipflow(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ VerificationIPFlowResult

Verify IP flow from the specified VM to a location given the currently configured NSG rules.

IP flow to be verified. will be added to the HTTP request.



1128
1129
1130
1131
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1128

def begin_verify_ipflow(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = begin_verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#begin_verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Verify IP flow from the specified VM to a location given the currently configured NSG rules.

IP flow to be verified. to the HTTP request.



1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1163

def begin_verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::VerificationIPFlowParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/ipFlowVerify'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 202
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::VerificationIPFlowResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 202
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::VerificationIPFlowResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#begin_verify_ipflow_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Verify IP flow from the specified VM to a location given the currently configured NSG rules.

IP flow to be verified. will be added to the HTTP request.



1146
1147
1148
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1146

def begin_verify_ipflow_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  begin_verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#check_connectivity(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ ConnectivityInformation

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.

group. resource. connectivity check will be performed. will be added to the HTTP request.



898
899
900
901
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 898

def check_connectivity(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

group. resource. connectivity check will be performed. will be added to the HTTP request.

response.



916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 916

def check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_check_connectivity_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::ConnectivityInformation.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#create_or_update(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ NetworkWatcher

Creates or updates a network watcher in the specified resource group.

resource. will be added to the HTTP request.



36
37
38
39
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 36

def create_or_update(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = create_or_update_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#create_or_update_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Creates or updates a network watcher in the specified resource group.

resource. to the HTTP request.



69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 69

def create_or_update_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::NetworkWatcher.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:put, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200 || status_code == 201
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NetworkWatcher.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end
    # Deserialize Response
    if status_code == 201
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NetworkWatcher.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#create_or_update_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Creates or updates a network watcher in the specified resource group.

resource. will be added to the HTTP request.



53
54
55
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 53

def create_or_update_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  create_or_update_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#delete(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ Object

Deletes the specified network watcher resource.

will be added to the HTTP request.



240
241
242
243
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 240

def delete(resource_group_name, network_watcher_name, custom_headers = nil)
  response = delete_async(resource_group_name, network_watcher_name, custom_headers).value!
  nil
end

#delete_async(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ Concurrent::Promise

will be added to the HTTP request.

response.



254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 254

def delete_async(resource_group_name, network_watcher_name, custom_headers = nil)
  # Send request
  promise = begin_delete_async(resource_group_name, network_watcher_name, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ NetworkWatcher

Gets the specified network watcher by resource group.

will be added to the HTTP request.



151
152
153
154
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 151

def get(resource_group_name, network_watcher_name, custom_headers = nil)
  response = get_async(resource_group_name, network_watcher_name, custom_headers).value!
  response.body unless response.nil?
end

#get_async(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ Concurrent::Promise

Gets the specified network watcher by resource group.

to the HTTP request.



180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 180

def get_async(resource_group_name, network_watcher_name, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:get, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NetworkWatcher.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#get_azure_reachability_report(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ AzureReachabilityReport

Gets the relative latency score for internet service providers from a specified location to Azure regions.

group. resource. determine Azure reachability report configuration. will be added to the HTTP request.



949
950
951
952
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 949

def get_azure_reachability_report(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

group. resource. determine Azure reachability report configuration. will be added to the HTTP request.

response.



967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 967

def get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_azure_reachability_report_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::AzureReachabilityReport.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_flow_log_status(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ FlowLogInformation

Queries status of flow log on a specified resource.

group. resource. to query flow log status. will be added to the HTTP request.



846
847
848
849
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 846

def get_flow_log_status(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

group. resource. to query flow log status. will be added to the HTTP request.

response.



864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 864

def get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_flow_log_status_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_next_hop(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ NextHopResult

Gets the next hop from the specified VM.

destination endpoint. will be added to the HTTP request.



606
607
608
609
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 606

def get_next_hop(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

destination endpoint. will be added to the HTTP request.

response.



622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 622

def get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_next_hop_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::NextHopResult.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_topology(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Topology

Gets the current network topology by resource group.

representation of topology. will be added to the HTTP request.



452
453
454
455
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 452

def get_topology(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_topology_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_topology_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

Gets the current network topology by resource group.

representation of topology. to the HTTP request.



485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 485

def get_topology_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  fail ArgumentError, 'network_watcher_name is nil' if network_watcher_name.nil?
  fail ArgumentError, 'parameters is nil' if parameters.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?

  request_headers['Content-Type'] = 'application/json; charset=utf-8'

  # Serialize Request
  request_mapper = Azure::ARM::Network::Models::TopologyParameters.mapper()
  request_content = @client.serialize(request_mapper,  parameters)
  request_content = request_content != nil ? JSON.generate(request_content, quirks_mode: true) : nil

  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers/{networkWatcherName}/topology'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'networkWatcherName' => network_watcher_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      body: request_content,
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:post, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::Topology.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#get_topology_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets the current network topology by resource group.

representation of topology. will be added to the HTTP request.



469
470
471
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 469

def get_topology_with_http_info(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  get_topology_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
end

#get_troubleshooting(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ TroubleshootingResult

Initiate troubleshooting on a specified resource

resource. resource to troubleshoot. will be added to the HTTP request.



699
700
701
702
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 699

def get_troubleshooting(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

resource. resource to troubleshoot. will be added to the HTTP request.

response.



716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 716

def get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_troubleshooting_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_troubleshooting_result(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ TroubleshootingResult

Get the last completed troubleshooting result on a specified resource

resource. resource to query the troubleshooting result. will be added to the HTTP request.



747
748
749
750
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 747

def get_troubleshooting_result(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

resource. resource to query the troubleshooting result. will be added to the HTTP request.

response.



764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 764

def get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_troubleshooting_result_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::TroubleshootingResult.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_vmsecurity_rules(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ SecurityGroupViewResult

Gets the configured and effective security group rules on the specified VM.

to check security groups for. will be added to the HTTP request.



652
653
654
655
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 652

def get_vmsecurity_rules(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

to check security groups for. will be added to the HTTP request.

response.



668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 668

def get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_get_vmsecurity_rules_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::SecurityGroupViewResult.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#get_with_http_info(resource_group_name, network_watcher_name, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets the specified network watcher by resource group.

will be added to the HTTP request.



166
167
168
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 166

def get_with_http_info(resource_group_name, network_watcher_name, custom_headers = nil)
  get_async(resource_group_name, network_watcher_name, custom_headers).value!
end

#list(resource_group_name, custom_headers = nil) ⇒ NetworkWatcherListResult

Gets all network watchers by resource group.

will be added to the HTTP request.



279
280
281
282
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 279

def list(resource_group_name, custom_headers = nil)
  response = list_async(resource_group_name, custom_headers).value!
  response.body unless response.nil?
end

#list_all(custom_headers = nil) ⇒ NetworkWatcherListResult

Gets all network watchers by subscription.

will be added to the HTTP request.



365
366
367
368
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 365

def list_all(custom_headers = nil)
  response = list_all_async(custom_headers).value!
  response.body unless response.nil?
end

#list_all_async(custom_headers = nil) ⇒ Concurrent::Promise

Gets all network watchers by subscription.

to the HTTP request.



390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 390

def list_all_async(custom_headers = nil)
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
  path_template = 'subscriptions/{subscriptionId}/providers/Microsoft.Network/networkWatchers'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:get, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NetworkWatcherListResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#list_all_with_http_info(custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets all network watchers by subscription.

will be added to the HTTP request.



378
379
380
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 378

def list_all_with_http_info(custom_headers = nil)
  list_all_async(custom_headers).value!
end

#list_async(resource_group_name, custom_headers = nil) ⇒ Concurrent::Promise

Gets all network watchers by resource group.

to the HTTP request.



306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 306

def list_async(resource_group_name, custom_headers = nil)
  fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
  api_version = '2017-09-01'
  fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?


  request_headers = {}

  # Set Headers
  request_headers['x-ms-client-request-id'] = SecureRandom.uuid
  request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
  path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/networkWatchers'

  request_url = @base_url || @client.base_url

  options = {
      middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
      path_params: {'resourceGroupName' => resource_group_name,'subscriptionId' => @client.subscription_id},
      query_params: {'api-version' => api_version},
      headers: request_headers.merge(custom_headers || {}),
      base_url: request_url
  }
  promise = @client.make_request_async(:get, path_template, options)

  promise = promise.then do |result|
    http_response = result.response
    status_code = http_response.status
    response_content = http_response.body
    unless status_code == 200
      error_model = JSON.load(response_content)
      fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
    end

    result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
    # Deserialize Response
    if status_code == 200
      begin
        parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
        result_mapper = Azure::ARM::Network::Models::NetworkWatcherListResult.mapper()
        result.body = @client.deserialize(result_mapper, parsed_response)
      rescue Exception => e
        fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
      end
    end

    result
  end

  promise.execute
end

#list_available_providers(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ AvailableProvidersList

Lists all available internet service providers for a specified Azure region.

group. resource. the list of available providers. will be added to the HTTP request.



999
1000
1001
1002
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 999

def list_available_providers(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

group. resource. the list of available providers. will be added to the HTTP request.

response.



1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 1017

def list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_list_available_providers_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::AvailableProvidersList.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#list_with_http_info(resource_group_name, custom_headers = nil) ⇒ MsRestAzure::AzureOperationResponse

Gets all network watchers by resource group.

will be added to the HTTP request.



293
294
295
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 293

def list_with_http_info(resource_group_name, custom_headers = nil)
  list_async(resource_group_name, custom_headers).value!
end

#set_flow_log_configuration(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ FlowLogInformation

Configures flow log on a specified resource.

group. resource. configuration of flow log. will be added to the HTTP request.



796
797
798
799
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 796

def set_flow_log_configuration(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

group. resource. configuration of flow log. will be added to the HTTP request.

response.



814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 814

def set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_set_flow_log_configuration_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::FlowLogInformation.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end

#verify_ipflow(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ VerificationIPFlowResult

Verify IP flow from the specified VM to a location given the currently configured NSG rules.

IP flow to be verified. will be added to the HTTP request.



560
561
562
563
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 560

def verify_ipflow(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  response = verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers).value!
  response.body unless response.nil?
end

#verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil) ⇒ Concurrent::Promise

IP flow to be verified. will be added to the HTTP request.

response.



576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
 
# File 'lib/generated/azure_mgmt_network/network_watchers.rb', line 576

def verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers = nil)
  # Send request
  promise = begin_verify_ipflow_async(resource_group_name, network_watcher_name, parameters, custom_headers)

  promise = promise.then do |response|
    # Defining deserialization method.
    deserialize_method = lambda do |parsed_response|
      result_mapper = Azure::ARM::Network::Models::VerificationIPFlowResult.mapper()
      parsed_response = @client.deserialize(result_mapper, parsed_response)
    end

    # Waiting for response.
    @client.get_long_running_operation_result(response, deserialize_method)
  end

  promise
end