NetworkManagementClientImpl.java
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// Code generated by Microsoft (R) AutoRest Code Generator.
package com.azure.resourcemanager.network.implementation;
import com.azure.core.annotation.BodyParam;
import com.azure.core.annotation.ExpectedResponses;
import com.azure.core.annotation.Get;
import com.azure.core.annotation.Headers;
import com.azure.core.annotation.Host;
import com.azure.core.annotation.HostParam;
import com.azure.core.annotation.PathParam;
import com.azure.core.annotation.Post;
import com.azure.core.annotation.QueryParam;
import com.azure.core.annotation.ReturnType;
import com.azure.core.annotation.ServiceClient;
import com.azure.core.annotation.ServiceInterface;
import com.azure.core.annotation.ServiceMethod;
import com.azure.core.annotation.UnexpectedResponseExceptionType;
import com.azure.core.http.HttpPipeline;
import com.azure.core.http.rest.PagedFlux;
import com.azure.core.http.rest.PagedIterable;
import com.azure.core.http.rest.PagedResponse;
import com.azure.core.http.rest.PagedResponseBase;
import com.azure.core.http.rest.Response;
import com.azure.core.http.rest.RestProxy;
import com.azure.core.management.AzureEnvironment;
import com.azure.core.management.exception.ManagementException;
import com.azure.core.management.polling.PollResult;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.PollerFlux;
import com.azure.core.util.polling.SyncPoller;
import com.azure.core.util.serializer.SerializerAdapter;
import com.azure.resourcemanager.network.fluent.ApplicationGatewayPrivateEndpointConnectionsClient;
import com.azure.resourcemanager.network.fluent.ApplicationGatewayPrivateLinkResourcesClient;
import com.azure.resourcemanager.network.fluent.ApplicationGatewaysClient;
import com.azure.resourcemanager.network.fluent.ApplicationSecurityGroupsClient;
import com.azure.resourcemanager.network.fluent.AvailableDelegationsClient;
import com.azure.resourcemanager.network.fluent.AvailableEndpointServicesClient;
import com.azure.resourcemanager.network.fluent.AvailablePrivateEndpointTypesClient;
import com.azure.resourcemanager.network.fluent.AvailableResourceGroupDelegationsClient;
import com.azure.resourcemanager.network.fluent.AvailableServiceAliasesClient;
import com.azure.resourcemanager.network.fluent.AzureFirewallFqdnTagsClient;
import com.azure.resourcemanager.network.fluent.AzureFirewallsClient;
import com.azure.resourcemanager.network.fluent.BastionHostsClient;
import com.azure.resourcemanager.network.fluent.BgpServiceCommunitiesClient;
import com.azure.resourcemanager.network.fluent.ConnectionMonitorsClient;
import com.azure.resourcemanager.network.fluent.DdosCustomPoliciesClient;
import com.azure.resourcemanager.network.fluent.DdosProtectionPlansClient;
import com.azure.resourcemanager.network.fluent.DefaultSecurityRulesClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCircuitAuthorizationsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCircuitConnectionsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCircuitPeeringsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCircuitsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteConnectionsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCrossConnectionPeeringsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteCrossConnectionsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteGatewaysClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteLinksClient;
import com.azure.resourcemanager.network.fluent.ExpressRoutePortsClient;
import com.azure.resourcemanager.network.fluent.ExpressRoutePortsLocationsClient;
import com.azure.resourcemanager.network.fluent.ExpressRouteServiceProvidersClient;
import com.azure.resourcemanager.network.fluent.FirewallPoliciesClient;
import com.azure.resourcemanager.network.fluent.FirewallPolicyRuleCollectionGroupsClient;
import com.azure.resourcemanager.network.fluent.FlowLogsClient;
import com.azure.resourcemanager.network.fluent.HubRouteTablesClient;
import com.azure.resourcemanager.network.fluent.HubVirtualNetworkConnectionsClient;
import com.azure.resourcemanager.network.fluent.InboundNatRulesClient;
import com.azure.resourcemanager.network.fluent.IpAllocationsClient;
import com.azure.resourcemanager.network.fluent.IpGroupsClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerBackendAddressPoolsClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerFrontendIpConfigurationsClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerLoadBalancingRulesClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerNetworkInterfacesClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerOutboundRulesClient;
import com.azure.resourcemanager.network.fluent.LoadBalancerProbesClient;
import com.azure.resourcemanager.network.fluent.LoadBalancersClient;
import com.azure.resourcemanager.network.fluent.LocalNetworkGatewaysClient;
import com.azure.resourcemanager.network.fluent.NatGatewaysClient;
import com.azure.resourcemanager.network.fluent.NetworkInterfaceIpConfigurationsClient;
import com.azure.resourcemanager.network.fluent.NetworkInterfaceLoadBalancersClient;
import com.azure.resourcemanager.network.fluent.NetworkInterfaceTapConfigurationsClient;
import com.azure.resourcemanager.network.fluent.NetworkInterfacesClient;
import com.azure.resourcemanager.network.fluent.NetworkManagementClient;
import com.azure.resourcemanager.network.fluent.NetworkProfilesClient;
import com.azure.resourcemanager.network.fluent.NetworkSecurityGroupsClient;
import com.azure.resourcemanager.network.fluent.NetworkVirtualAppliancesClient;
import com.azure.resourcemanager.network.fluent.NetworkWatchersClient;
import com.azure.resourcemanager.network.fluent.OperationsClient;
import com.azure.resourcemanager.network.fluent.P2SVpnGatewaysClient;
import com.azure.resourcemanager.network.fluent.PacketCapturesClient;
import com.azure.resourcemanager.network.fluent.PeerExpressRouteCircuitConnectionsClient;
import com.azure.resourcemanager.network.fluent.PrivateDnsZoneGroupsClient;
import com.azure.resourcemanager.network.fluent.PrivateEndpointsClient;
import com.azure.resourcemanager.network.fluent.PrivateLinkServicesClient;
import com.azure.resourcemanager.network.fluent.PublicIpAddressesClient;
import com.azure.resourcemanager.network.fluent.PublicIpPrefixesClient;
import com.azure.resourcemanager.network.fluent.ResourceNavigationLinksClient;
import com.azure.resourcemanager.network.fluent.RouteFilterRulesClient;
import com.azure.resourcemanager.network.fluent.RouteFiltersClient;
import com.azure.resourcemanager.network.fluent.RouteTablesClient;
import com.azure.resourcemanager.network.fluent.RoutesClient;
import com.azure.resourcemanager.network.fluent.SecurityPartnerProvidersClient;
import com.azure.resourcemanager.network.fluent.SecurityRulesClient;
import com.azure.resourcemanager.network.fluent.ServiceAssociationLinksClient;
import com.azure.resourcemanager.network.fluent.ServiceEndpointPoliciesClient;
import com.azure.resourcemanager.network.fluent.ServiceEndpointPolicyDefinitionsClient;
import com.azure.resourcemanager.network.fluent.ServiceTagsClient;
import com.azure.resourcemanager.network.fluent.SubnetsClient;
import com.azure.resourcemanager.network.fluent.UsagesClient;
import com.azure.resourcemanager.network.fluent.VirtualApplianceSitesClient;
import com.azure.resourcemanager.network.fluent.VirtualApplianceSkusClient;
import com.azure.resourcemanager.network.fluent.VirtualHubBgpConnectionsClient;
import com.azure.resourcemanager.network.fluent.VirtualHubIpConfigurationsClient;
import com.azure.resourcemanager.network.fluent.VirtualHubRouteTableV2SClient;
import com.azure.resourcemanager.network.fluent.VirtualHubsClient;
import com.azure.resourcemanager.network.fluent.VirtualNetworkGatewayConnectionsClient;
import com.azure.resourcemanager.network.fluent.VirtualNetworkGatewaysClient;
import com.azure.resourcemanager.network.fluent.VirtualNetworkPeeringsClient;
import com.azure.resourcemanager.network.fluent.VirtualNetworkTapsClient;
import com.azure.resourcemanager.network.fluent.VirtualNetworksClient;
import com.azure.resourcemanager.network.fluent.VirtualRouterPeeringsClient;
import com.azure.resourcemanager.network.fluent.VirtualRoutersClient;
import com.azure.resourcemanager.network.fluent.VirtualWansClient;
import com.azure.resourcemanager.network.fluent.VpnConnectionsClient;
import com.azure.resourcemanager.network.fluent.VpnGatewaysClient;
import com.azure.resourcemanager.network.fluent.VpnLinkConnectionsClient;
import com.azure.resourcemanager.network.fluent.VpnServerConfigurationsAssociatedWithVirtualWansClient;
import com.azure.resourcemanager.network.fluent.VpnServerConfigurationsClient;
import com.azure.resourcemanager.network.fluent.VpnSiteLinkConnectionsClient;
import com.azure.resourcemanager.network.fluent.VpnSiteLinksClient;
import com.azure.resourcemanager.network.fluent.VpnSitesClient;
import com.azure.resourcemanager.network.fluent.VpnSitesConfigurationsClient;
import com.azure.resourcemanager.network.fluent.WebApplicationFirewallPoliciesClient;
import com.azure.resourcemanager.network.fluent.models.BastionActiveSessionInner;
import com.azure.resourcemanager.network.fluent.models.BastionSessionStateInner;
import com.azure.resourcemanager.network.fluent.models.BastionShareableLinkInner;
import com.azure.resourcemanager.network.fluent.models.DnsNameAvailabilityResultInner;
import com.azure.resourcemanager.network.fluent.models.VirtualWanSecurityProvidersInner;
import com.azure.resourcemanager.network.fluent.models.VpnProfileResponseInner;
import com.azure.resourcemanager.network.models.BastionActiveSessionListResult;
import com.azure.resourcemanager.network.models.BastionSessionDeleteResult;
import com.azure.resourcemanager.network.models.BastionShareableLinkListRequest;
import com.azure.resourcemanager.network.models.BastionShareableLinkListResult;
import com.azure.resourcemanager.network.models.SessionIds;
import com.azure.resourcemanager.network.models.VirtualWanVpnProfileParameters;
import com.azure.resourcemanager.resources.fluentcore.AzureServiceClient;
import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.List;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
/** Initializes a new instance of the NetworkManagementClientImpl type. */
@ServiceClient(builder = NetworkManagementClientBuilder.class)
public final class NetworkManagementClientImpl extends AzureServiceClient implements NetworkManagementClient {
private final ClientLogger logger = new ClientLogger(NetworkManagementClientImpl.class);
/** The proxy service used to perform REST calls. */
private final NetworkManagementClientService service;
/**
* The subscription credentials which uniquely identify the Microsoft Azure subscription. The subscription ID forms
* part of the URI for every service call.
*/
private final String subscriptionId;
/**
* Gets The subscription credentials which uniquely identify the Microsoft Azure subscription. The subscription ID
* forms part of the URI for every service call.
*
* @return the subscriptionId value.
*/
public String getSubscriptionId() {
return this.subscriptionId;
}
/** server parameter. */
private final String endpoint;
/**
* Gets server parameter.
*
* @return the endpoint value.
*/
public String getEndpoint() {
return this.endpoint;
}
/** The HTTP pipeline to send requests through. */
private final HttpPipeline httpPipeline;
/**
* Gets The HTTP pipeline to send requests through.
*
* @return the httpPipeline value.
*/
public HttpPipeline getHttpPipeline() {
return this.httpPipeline;
}
/** The serializer to serialize an object into a string. */
private final SerializerAdapter serializerAdapter;
/**
* Gets The serializer to serialize an object into a string.
*
* @return the serializerAdapter value.
*/
SerializerAdapter getSerializerAdapter() {
return this.serializerAdapter;
}
/** The default poll interval for long-running operation. */
private final Duration defaultPollInterval;
/**
* Gets The default poll interval for long-running operation.
*
* @return the defaultPollInterval value.
*/
public Duration getDefaultPollInterval() {
return this.defaultPollInterval;
}
/** The ApplicationGatewaysClient object to access its operations. */
private final ApplicationGatewaysClient applicationGateways;
/**
* Gets the ApplicationGatewaysClient object to access its operations.
*
* @return the ApplicationGatewaysClient object.
*/
public ApplicationGatewaysClient getApplicationGateways() {
return this.applicationGateways;
}
/** The ApplicationGatewayPrivateLinkResourcesClient object to access its operations. */
private final ApplicationGatewayPrivateLinkResourcesClient applicationGatewayPrivateLinkResources;
/**
* Gets the ApplicationGatewayPrivateLinkResourcesClient object to access its operations.
*
* @return the ApplicationGatewayPrivateLinkResourcesClient object.
*/
public ApplicationGatewayPrivateLinkResourcesClient getApplicationGatewayPrivateLinkResources() {
return this.applicationGatewayPrivateLinkResources;
}
/** The ApplicationGatewayPrivateEndpointConnectionsClient object to access its operations. */
private final ApplicationGatewayPrivateEndpointConnectionsClient applicationGatewayPrivateEndpointConnections;
/**
* Gets the ApplicationGatewayPrivateEndpointConnectionsClient object to access its operations.
*
* @return the ApplicationGatewayPrivateEndpointConnectionsClient object.
*/
public ApplicationGatewayPrivateEndpointConnectionsClient getApplicationGatewayPrivateEndpointConnections() {
return this.applicationGatewayPrivateEndpointConnections;
}
/** The ApplicationSecurityGroupsClient object to access its operations. */
private final ApplicationSecurityGroupsClient applicationSecurityGroups;
/**
* Gets the ApplicationSecurityGroupsClient object to access its operations.
*
* @return the ApplicationSecurityGroupsClient object.
*/
public ApplicationSecurityGroupsClient getApplicationSecurityGroups() {
return this.applicationSecurityGroups;
}
/** The AvailableDelegationsClient object to access its operations. */
private final AvailableDelegationsClient availableDelegations;
/**
* Gets the AvailableDelegationsClient object to access its operations.
*
* @return the AvailableDelegationsClient object.
*/
public AvailableDelegationsClient getAvailableDelegations() {
return this.availableDelegations;
}
/** The AvailableResourceGroupDelegationsClient object to access its operations. */
private final AvailableResourceGroupDelegationsClient availableResourceGroupDelegations;
/**
* Gets the AvailableResourceGroupDelegationsClient object to access its operations.
*
* @return the AvailableResourceGroupDelegationsClient object.
*/
public AvailableResourceGroupDelegationsClient getAvailableResourceGroupDelegations() {
return this.availableResourceGroupDelegations;
}
/** The AvailableServiceAliasesClient object to access its operations. */
private final AvailableServiceAliasesClient availableServiceAliases;
/**
* Gets the AvailableServiceAliasesClient object to access its operations.
*
* @return the AvailableServiceAliasesClient object.
*/
public AvailableServiceAliasesClient getAvailableServiceAliases() {
return this.availableServiceAliases;
}
/** The AzureFirewallsClient object to access its operations. */
private final AzureFirewallsClient azureFirewalls;
/**
* Gets the AzureFirewallsClient object to access its operations.
*
* @return the AzureFirewallsClient object.
*/
public AzureFirewallsClient getAzureFirewalls() {
return this.azureFirewalls;
}
/** The AzureFirewallFqdnTagsClient object to access its operations. */
private final AzureFirewallFqdnTagsClient azureFirewallFqdnTags;
/**
* Gets the AzureFirewallFqdnTagsClient object to access its operations.
*
* @return the AzureFirewallFqdnTagsClient object.
*/
public AzureFirewallFqdnTagsClient getAzureFirewallFqdnTags() {
return this.azureFirewallFqdnTags;
}
/** The BastionHostsClient object to access its operations. */
private final BastionHostsClient bastionHosts;
/**
* Gets the BastionHostsClient object to access its operations.
*
* @return the BastionHostsClient object.
*/
public BastionHostsClient getBastionHosts() {
return this.bastionHosts;
}
/** The DdosCustomPoliciesClient object to access its operations. */
private final DdosCustomPoliciesClient ddosCustomPolicies;
/**
* Gets the DdosCustomPoliciesClient object to access its operations.
*
* @return the DdosCustomPoliciesClient object.
*/
public DdosCustomPoliciesClient getDdosCustomPolicies() {
return this.ddosCustomPolicies;
}
/** The DdosProtectionPlansClient object to access its operations. */
private final DdosProtectionPlansClient ddosProtectionPlans;
/**
* Gets the DdosProtectionPlansClient object to access its operations.
*
* @return the DdosProtectionPlansClient object.
*/
public DdosProtectionPlansClient getDdosProtectionPlans() {
return this.ddosProtectionPlans;
}
/** The AvailableEndpointServicesClient object to access its operations. */
private final AvailableEndpointServicesClient availableEndpointServices;
/**
* Gets the AvailableEndpointServicesClient object to access its operations.
*
* @return the AvailableEndpointServicesClient object.
*/
public AvailableEndpointServicesClient getAvailableEndpointServices() {
return this.availableEndpointServices;
}
/** The ExpressRouteCircuitAuthorizationsClient object to access its operations. */
private final ExpressRouteCircuitAuthorizationsClient expressRouteCircuitAuthorizations;
/**
* Gets the ExpressRouteCircuitAuthorizationsClient object to access its operations.
*
* @return the ExpressRouteCircuitAuthorizationsClient object.
*/
public ExpressRouteCircuitAuthorizationsClient getExpressRouteCircuitAuthorizations() {
return this.expressRouteCircuitAuthorizations;
}
/** The ExpressRouteCircuitPeeringsClient object to access its operations. */
private final ExpressRouteCircuitPeeringsClient expressRouteCircuitPeerings;
/**
* Gets the ExpressRouteCircuitPeeringsClient object to access its operations.
*
* @return the ExpressRouteCircuitPeeringsClient object.
*/
public ExpressRouteCircuitPeeringsClient getExpressRouteCircuitPeerings() {
return this.expressRouteCircuitPeerings;
}
/** The ExpressRouteCircuitConnectionsClient object to access its operations. */
private final ExpressRouteCircuitConnectionsClient expressRouteCircuitConnections;
/**
* Gets the ExpressRouteCircuitConnectionsClient object to access its operations.
*
* @return the ExpressRouteCircuitConnectionsClient object.
*/
public ExpressRouteCircuitConnectionsClient getExpressRouteCircuitConnections() {
return this.expressRouteCircuitConnections;
}
/** The PeerExpressRouteCircuitConnectionsClient object to access its operations. */
private final PeerExpressRouteCircuitConnectionsClient peerExpressRouteCircuitConnections;
/**
* Gets the PeerExpressRouteCircuitConnectionsClient object to access its operations.
*
* @return the PeerExpressRouteCircuitConnectionsClient object.
*/
public PeerExpressRouteCircuitConnectionsClient getPeerExpressRouteCircuitConnections() {
return this.peerExpressRouteCircuitConnections;
}
/** The ExpressRouteCircuitsClient object to access its operations. */
private final ExpressRouteCircuitsClient expressRouteCircuits;
/**
* Gets the ExpressRouteCircuitsClient object to access its operations.
*
* @return the ExpressRouteCircuitsClient object.
*/
public ExpressRouteCircuitsClient getExpressRouteCircuits() {
return this.expressRouteCircuits;
}
/** The ExpressRouteServiceProvidersClient object to access its operations. */
private final ExpressRouteServiceProvidersClient expressRouteServiceProviders;
/**
* Gets the ExpressRouteServiceProvidersClient object to access its operations.
*
* @return the ExpressRouteServiceProvidersClient object.
*/
public ExpressRouteServiceProvidersClient getExpressRouteServiceProviders() {
return this.expressRouteServiceProviders;
}
/** The ExpressRouteCrossConnectionsClient object to access its operations. */
private final ExpressRouteCrossConnectionsClient expressRouteCrossConnections;
/**
* Gets the ExpressRouteCrossConnectionsClient object to access its operations.
*
* @return the ExpressRouteCrossConnectionsClient object.
*/
public ExpressRouteCrossConnectionsClient getExpressRouteCrossConnections() {
return this.expressRouteCrossConnections;
}
/** The ExpressRouteCrossConnectionPeeringsClient object to access its operations. */
private final ExpressRouteCrossConnectionPeeringsClient expressRouteCrossConnectionPeerings;
/**
* Gets the ExpressRouteCrossConnectionPeeringsClient object to access its operations.
*
* @return the ExpressRouteCrossConnectionPeeringsClient object.
*/
public ExpressRouteCrossConnectionPeeringsClient getExpressRouteCrossConnectionPeerings() {
return this.expressRouteCrossConnectionPeerings;
}
/** The ExpressRoutePortsLocationsClient object to access its operations. */
private final ExpressRoutePortsLocationsClient expressRoutePortsLocations;
/**
* Gets the ExpressRoutePortsLocationsClient object to access its operations.
*
* @return the ExpressRoutePortsLocationsClient object.
*/
public ExpressRoutePortsLocationsClient getExpressRoutePortsLocations() {
return this.expressRoutePortsLocations;
}
/** The ExpressRoutePortsClient object to access its operations. */
private final ExpressRoutePortsClient expressRoutePorts;
/**
* Gets the ExpressRoutePortsClient object to access its operations.
*
* @return the ExpressRoutePortsClient object.
*/
public ExpressRoutePortsClient getExpressRoutePorts() {
return this.expressRoutePorts;
}
/** The ExpressRouteLinksClient object to access its operations. */
private final ExpressRouteLinksClient expressRouteLinks;
/**
* Gets the ExpressRouteLinksClient object to access its operations.
*
* @return the ExpressRouteLinksClient object.
*/
public ExpressRouteLinksClient getExpressRouteLinks() {
return this.expressRouteLinks;
}
/** The FirewallPoliciesClient object to access its operations. */
private final FirewallPoliciesClient firewallPolicies;
/**
* Gets the FirewallPoliciesClient object to access its operations.
*
* @return the FirewallPoliciesClient object.
*/
public FirewallPoliciesClient getFirewallPolicies() {
return this.firewallPolicies;
}
/** The FirewallPolicyRuleCollectionGroupsClient object to access its operations. */
private final FirewallPolicyRuleCollectionGroupsClient firewallPolicyRuleCollectionGroups;
/**
* Gets the FirewallPolicyRuleCollectionGroupsClient object to access its operations.
*
* @return the FirewallPolicyRuleCollectionGroupsClient object.
*/
public FirewallPolicyRuleCollectionGroupsClient getFirewallPolicyRuleCollectionGroups() {
return this.firewallPolicyRuleCollectionGroups;
}
/** The IpAllocationsClient object to access its operations. */
private final IpAllocationsClient ipAllocations;
/**
* Gets the IpAllocationsClient object to access its operations.
*
* @return the IpAllocationsClient object.
*/
public IpAllocationsClient getIpAllocations() {
return this.ipAllocations;
}
/** The IpGroupsClient object to access its operations. */
private final IpGroupsClient ipGroups;
/**
* Gets the IpGroupsClient object to access its operations.
*
* @return the IpGroupsClient object.
*/
public IpGroupsClient getIpGroups() {
return this.ipGroups;
}
/** The LoadBalancersClient object to access its operations. */
private final LoadBalancersClient loadBalancers;
/**
* Gets the LoadBalancersClient object to access its operations.
*
* @return the LoadBalancersClient object.
*/
public LoadBalancersClient getLoadBalancers() {
return this.loadBalancers;
}
/** The LoadBalancerBackendAddressPoolsClient object to access its operations. */
private final LoadBalancerBackendAddressPoolsClient loadBalancerBackendAddressPools;
/**
* Gets the LoadBalancerBackendAddressPoolsClient object to access its operations.
*
* @return the LoadBalancerBackendAddressPoolsClient object.
*/
public LoadBalancerBackendAddressPoolsClient getLoadBalancerBackendAddressPools() {
return this.loadBalancerBackendAddressPools;
}
/** The LoadBalancerFrontendIpConfigurationsClient object to access its operations. */
private final LoadBalancerFrontendIpConfigurationsClient loadBalancerFrontendIpConfigurations;
/**
* Gets the LoadBalancerFrontendIpConfigurationsClient object to access its operations.
*
* @return the LoadBalancerFrontendIpConfigurationsClient object.
*/
public LoadBalancerFrontendIpConfigurationsClient getLoadBalancerFrontendIpConfigurations() {
return this.loadBalancerFrontendIpConfigurations;
}
/** The InboundNatRulesClient object to access its operations. */
private final InboundNatRulesClient inboundNatRules;
/**
* Gets the InboundNatRulesClient object to access its operations.
*
* @return the InboundNatRulesClient object.
*/
public InboundNatRulesClient getInboundNatRules() {
return this.inboundNatRules;
}
/** The LoadBalancerLoadBalancingRulesClient object to access its operations. */
private final LoadBalancerLoadBalancingRulesClient loadBalancerLoadBalancingRules;
/**
* Gets the LoadBalancerLoadBalancingRulesClient object to access its operations.
*
* @return the LoadBalancerLoadBalancingRulesClient object.
*/
public LoadBalancerLoadBalancingRulesClient getLoadBalancerLoadBalancingRules() {
return this.loadBalancerLoadBalancingRules;
}
/** The LoadBalancerOutboundRulesClient object to access its operations. */
private final LoadBalancerOutboundRulesClient loadBalancerOutboundRules;
/**
* Gets the LoadBalancerOutboundRulesClient object to access its operations.
*
* @return the LoadBalancerOutboundRulesClient object.
*/
public LoadBalancerOutboundRulesClient getLoadBalancerOutboundRules() {
return this.loadBalancerOutboundRules;
}
/** The LoadBalancerNetworkInterfacesClient object to access its operations. */
private final LoadBalancerNetworkInterfacesClient loadBalancerNetworkInterfaces;
/**
* Gets the LoadBalancerNetworkInterfacesClient object to access its operations.
*
* @return the LoadBalancerNetworkInterfacesClient object.
*/
public LoadBalancerNetworkInterfacesClient getLoadBalancerNetworkInterfaces() {
return this.loadBalancerNetworkInterfaces;
}
/** The LoadBalancerProbesClient object to access its operations. */
private final LoadBalancerProbesClient loadBalancerProbes;
/**
* Gets the LoadBalancerProbesClient object to access its operations.
*
* @return the LoadBalancerProbesClient object.
*/
public LoadBalancerProbesClient getLoadBalancerProbes() {
return this.loadBalancerProbes;
}
/** The NatGatewaysClient object to access its operations. */
private final NatGatewaysClient natGateways;
/**
* Gets the NatGatewaysClient object to access its operations.
*
* @return the NatGatewaysClient object.
*/
public NatGatewaysClient getNatGateways() {
return this.natGateways;
}
/** The NetworkInterfacesClient object to access its operations. */
private final NetworkInterfacesClient networkInterfaces;
/**
* Gets the NetworkInterfacesClient object to access its operations.
*
* @return the NetworkInterfacesClient object.
*/
public NetworkInterfacesClient getNetworkInterfaces() {
return this.networkInterfaces;
}
/** The NetworkInterfaceIpConfigurationsClient object to access its operations. */
private final NetworkInterfaceIpConfigurationsClient networkInterfaceIpConfigurations;
/**
* Gets the NetworkInterfaceIpConfigurationsClient object to access its operations.
*
* @return the NetworkInterfaceIpConfigurationsClient object.
*/
public NetworkInterfaceIpConfigurationsClient getNetworkInterfaceIpConfigurations() {
return this.networkInterfaceIpConfigurations;
}
/** The NetworkInterfaceLoadBalancersClient object to access its operations. */
private final NetworkInterfaceLoadBalancersClient networkInterfaceLoadBalancers;
/**
* Gets the NetworkInterfaceLoadBalancersClient object to access its operations.
*
* @return the NetworkInterfaceLoadBalancersClient object.
*/
public NetworkInterfaceLoadBalancersClient getNetworkInterfaceLoadBalancers() {
return this.networkInterfaceLoadBalancers;
}
/** The NetworkInterfaceTapConfigurationsClient object to access its operations. */
private final NetworkInterfaceTapConfigurationsClient networkInterfaceTapConfigurations;
/**
* Gets the NetworkInterfaceTapConfigurationsClient object to access its operations.
*
* @return the NetworkInterfaceTapConfigurationsClient object.
*/
public NetworkInterfaceTapConfigurationsClient getNetworkInterfaceTapConfigurations() {
return this.networkInterfaceTapConfigurations;
}
/** The NetworkProfilesClient object to access its operations. */
private final NetworkProfilesClient networkProfiles;
/**
* Gets the NetworkProfilesClient object to access its operations.
*
* @return the NetworkProfilesClient object.
*/
public NetworkProfilesClient getNetworkProfiles() {
return this.networkProfiles;
}
/** The NetworkSecurityGroupsClient object to access its operations. */
private final NetworkSecurityGroupsClient networkSecurityGroups;
/**
* Gets the NetworkSecurityGroupsClient object to access its operations.
*
* @return the NetworkSecurityGroupsClient object.
*/
public NetworkSecurityGroupsClient getNetworkSecurityGroups() {
return this.networkSecurityGroups;
}
/** The SecurityRulesClient object to access its operations. */
private final SecurityRulesClient securityRules;
/**
* Gets the SecurityRulesClient object to access its operations.
*
* @return the SecurityRulesClient object.
*/
public SecurityRulesClient getSecurityRules() {
return this.securityRules;
}
/** The DefaultSecurityRulesClient object to access its operations. */
private final DefaultSecurityRulesClient defaultSecurityRules;
/**
* Gets the DefaultSecurityRulesClient object to access its operations.
*
* @return the DefaultSecurityRulesClient object.
*/
public DefaultSecurityRulesClient getDefaultSecurityRules() {
return this.defaultSecurityRules;
}
/** The NetworkVirtualAppliancesClient object to access its operations. */
private final NetworkVirtualAppliancesClient networkVirtualAppliances;
/**
* Gets the NetworkVirtualAppliancesClient object to access its operations.
*
* @return the NetworkVirtualAppliancesClient object.
*/
public NetworkVirtualAppliancesClient getNetworkVirtualAppliances() {
return this.networkVirtualAppliances;
}
/** The VirtualApplianceSitesClient object to access its operations. */
private final VirtualApplianceSitesClient virtualApplianceSites;
/**
* Gets the VirtualApplianceSitesClient object to access its operations.
*
* @return the VirtualApplianceSitesClient object.
*/
public VirtualApplianceSitesClient getVirtualApplianceSites() {
return this.virtualApplianceSites;
}
/** The VirtualApplianceSkusClient object to access its operations. */
private final VirtualApplianceSkusClient virtualApplianceSkus;
/**
* Gets the VirtualApplianceSkusClient object to access its operations.
*
* @return the VirtualApplianceSkusClient object.
*/
public VirtualApplianceSkusClient getVirtualApplianceSkus() {
return this.virtualApplianceSkus;
}
/** The NetworkWatchersClient object to access its operations. */
private final NetworkWatchersClient networkWatchers;
/**
* Gets the NetworkWatchersClient object to access its operations.
*
* @return the NetworkWatchersClient object.
*/
public NetworkWatchersClient getNetworkWatchers() {
return this.networkWatchers;
}
/** The PacketCapturesClient object to access its operations. */
private final PacketCapturesClient packetCaptures;
/**
* Gets the PacketCapturesClient object to access its operations.
*
* @return the PacketCapturesClient object.
*/
public PacketCapturesClient getPacketCaptures() {
return this.packetCaptures;
}
/** The ConnectionMonitorsClient object to access its operations. */
private final ConnectionMonitorsClient connectionMonitors;
/**
* Gets the ConnectionMonitorsClient object to access its operations.
*
* @return the ConnectionMonitorsClient object.
*/
public ConnectionMonitorsClient getConnectionMonitors() {
return this.connectionMonitors;
}
/** The FlowLogsClient object to access its operations. */
private final FlowLogsClient flowLogs;
/**
* Gets the FlowLogsClient object to access its operations.
*
* @return the FlowLogsClient object.
*/
public FlowLogsClient getFlowLogs() {
return this.flowLogs;
}
/** The OperationsClient object to access its operations. */
private final OperationsClient operations;
/**
* Gets the OperationsClient object to access its operations.
*
* @return the OperationsClient object.
*/
public OperationsClient getOperations() {
return this.operations;
}
/** The PrivateEndpointsClient object to access its operations. */
private final PrivateEndpointsClient privateEndpoints;
/**
* Gets the PrivateEndpointsClient object to access its operations.
*
* @return the PrivateEndpointsClient object.
*/
public PrivateEndpointsClient getPrivateEndpoints() {
return this.privateEndpoints;
}
/** The AvailablePrivateEndpointTypesClient object to access its operations. */
private final AvailablePrivateEndpointTypesClient availablePrivateEndpointTypes;
/**
* Gets the AvailablePrivateEndpointTypesClient object to access its operations.
*
* @return the AvailablePrivateEndpointTypesClient object.
*/
public AvailablePrivateEndpointTypesClient getAvailablePrivateEndpointTypes() {
return this.availablePrivateEndpointTypes;
}
/** The PrivateDnsZoneGroupsClient object to access its operations. */
private final PrivateDnsZoneGroupsClient privateDnsZoneGroups;
/**
* Gets the PrivateDnsZoneGroupsClient object to access its operations.
*
* @return the PrivateDnsZoneGroupsClient object.
*/
public PrivateDnsZoneGroupsClient getPrivateDnsZoneGroups() {
return this.privateDnsZoneGroups;
}
/** The PrivateLinkServicesClient object to access its operations. */
private final PrivateLinkServicesClient privateLinkServices;
/**
* Gets the PrivateLinkServicesClient object to access its operations.
*
* @return the PrivateLinkServicesClient object.
*/
public PrivateLinkServicesClient getPrivateLinkServices() {
return this.privateLinkServices;
}
/** The PublicIpAddressesClient object to access its operations. */
private final PublicIpAddressesClient publicIpAddresses;
/**
* Gets the PublicIpAddressesClient object to access its operations.
*
* @return the PublicIpAddressesClient object.
*/
public PublicIpAddressesClient getPublicIpAddresses() {
return this.publicIpAddresses;
}
/** The PublicIpPrefixesClient object to access its operations. */
private final PublicIpPrefixesClient publicIpPrefixes;
/**
* Gets the PublicIpPrefixesClient object to access its operations.
*
* @return the PublicIpPrefixesClient object.
*/
public PublicIpPrefixesClient getPublicIpPrefixes() {
return this.publicIpPrefixes;
}
/** The RouteFiltersClient object to access its operations. */
private final RouteFiltersClient routeFilters;
/**
* Gets the RouteFiltersClient object to access its operations.
*
* @return the RouteFiltersClient object.
*/
public RouteFiltersClient getRouteFilters() {
return this.routeFilters;
}
/** The RouteFilterRulesClient object to access its operations. */
private final RouteFilterRulesClient routeFilterRules;
/**
* Gets the RouteFilterRulesClient object to access its operations.
*
* @return the RouteFilterRulesClient object.
*/
public RouteFilterRulesClient getRouteFilterRules() {
return this.routeFilterRules;
}
/** The RouteTablesClient object to access its operations. */
private final RouteTablesClient routeTables;
/**
* Gets the RouteTablesClient object to access its operations.
*
* @return the RouteTablesClient object.
*/
public RouteTablesClient getRouteTables() {
return this.routeTables;
}
/** The RoutesClient object to access its operations. */
private final RoutesClient routes;
/**
* Gets the RoutesClient object to access its operations.
*
* @return the RoutesClient object.
*/
public RoutesClient getRoutes() {
return this.routes;
}
/** The SecurityPartnerProvidersClient object to access its operations. */
private final SecurityPartnerProvidersClient securityPartnerProviders;
/**
* Gets the SecurityPartnerProvidersClient object to access its operations.
*
* @return the SecurityPartnerProvidersClient object.
*/
public SecurityPartnerProvidersClient getSecurityPartnerProviders() {
return this.securityPartnerProviders;
}
/** The BgpServiceCommunitiesClient object to access its operations. */
private final BgpServiceCommunitiesClient bgpServiceCommunities;
/**
* Gets the BgpServiceCommunitiesClient object to access its operations.
*
* @return the BgpServiceCommunitiesClient object.
*/
public BgpServiceCommunitiesClient getBgpServiceCommunities() {
return this.bgpServiceCommunities;
}
/** The ServiceEndpointPoliciesClient object to access its operations. */
private final ServiceEndpointPoliciesClient serviceEndpointPolicies;
/**
* Gets the ServiceEndpointPoliciesClient object to access its operations.
*
* @return the ServiceEndpointPoliciesClient object.
*/
public ServiceEndpointPoliciesClient getServiceEndpointPolicies() {
return this.serviceEndpointPolicies;
}
/** The ServiceEndpointPolicyDefinitionsClient object to access its operations. */
private final ServiceEndpointPolicyDefinitionsClient serviceEndpointPolicyDefinitions;
/**
* Gets the ServiceEndpointPolicyDefinitionsClient object to access its operations.
*
* @return the ServiceEndpointPolicyDefinitionsClient object.
*/
public ServiceEndpointPolicyDefinitionsClient getServiceEndpointPolicyDefinitions() {
return this.serviceEndpointPolicyDefinitions;
}
/** The ServiceTagsClient object to access its operations. */
private final ServiceTagsClient serviceTags;
/**
* Gets the ServiceTagsClient object to access its operations.
*
* @return the ServiceTagsClient object.
*/
public ServiceTagsClient getServiceTags() {
return this.serviceTags;
}
/** The UsagesClient object to access its operations. */
private final UsagesClient usages;
/**
* Gets the UsagesClient object to access its operations.
*
* @return the UsagesClient object.
*/
public UsagesClient getUsages() {
return this.usages;
}
/** The VirtualNetworksClient object to access its operations. */
private final VirtualNetworksClient virtualNetworks;
/**
* Gets the VirtualNetworksClient object to access its operations.
*
* @return the VirtualNetworksClient object.
*/
public VirtualNetworksClient getVirtualNetworks() {
return this.virtualNetworks;
}
/** The SubnetsClient object to access its operations. */
private final SubnetsClient subnets;
/**
* Gets the SubnetsClient object to access its operations.
*
* @return the SubnetsClient object.
*/
public SubnetsClient getSubnets() {
return this.subnets;
}
/** The ResourceNavigationLinksClient object to access its operations. */
private final ResourceNavigationLinksClient resourceNavigationLinks;
/**
* Gets the ResourceNavigationLinksClient object to access its operations.
*
* @return the ResourceNavigationLinksClient object.
*/
public ResourceNavigationLinksClient getResourceNavigationLinks() {
return this.resourceNavigationLinks;
}
/** The ServiceAssociationLinksClient object to access its operations. */
private final ServiceAssociationLinksClient serviceAssociationLinks;
/**
* Gets the ServiceAssociationLinksClient object to access its operations.
*
* @return the ServiceAssociationLinksClient object.
*/
public ServiceAssociationLinksClient getServiceAssociationLinks() {
return this.serviceAssociationLinks;
}
/** The VirtualNetworkPeeringsClient object to access its operations. */
private final VirtualNetworkPeeringsClient virtualNetworkPeerings;
/**
* Gets the VirtualNetworkPeeringsClient object to access its operations.
*
* @return the VirtualNetworkPeeringsClient object.
*/
public VirtualNetworkPeeringsClient getVirtualNetworkPeerings() {
return this.virtualNetworkPeerings;
}
/** The VirtualNetworkGatewaysClient object to access its operations. */
private final VirtualNetworkGatewaysClient virtualNetworkGateways;
/**
* Gets the VirtualNetworkGatewaysClient object to access its operations.
*
* @return the VirtualNetworkGatewaysClient object.
*/
public VirtualNetworkGatewaysClient getVirtualNetworkGateways() {
return this.virtualNetworkGateways;
}
/** The VirtualNetworkGatewayConnectionsClient object to access its operations. */
private final VirtualNetworkGatewayConnectionsClient virtualNetworkGatewayConnections;
/**
* Gets the VirtualNetworkGatewayConnectionsClient object to access its operations.
*
* @return the VirtualNetworkGatewayConnectionsClient object.
*/
public VirtualNetworkGatewayConnectionsClient getVirtualNetworkGatewayConnections() {
return this.virtualNetworkGatewayConnections;
}
/** The LocalNetworkGatewaysClient object to access its operations. */
private final LocalNetworkGatewaysClient localNetworkGateways;
/**
* Gets the LocalNetworkGatewaysClient object to access its operations.
*
* @return the LocalNetworkGatewaysClient object.
*/
public LocalNetworkGatewaysClient getLocalNetworkGateways() {
return this.localNetworkGateways;
}
/** The VirtualNetworkTapsClient object to access its operations. */
private final VirtualNetworkTapsClient virtualNetworkTaps;
/**
* Gets the VirtualNetworkTapsClient object to access its operations.
*
* @return the VirtualNetworkTapsClient object.
*/
public VirtualNetworkTapsClient getVirtualNetworkTaps() {
return this.virtualNetworkTaps;
}
/** The VirtualRoutersClient object to access its operations. */
private final VirtualRoutersClient virtualRouters;
/**
* Gets the VirtualRoutersClient object to access its operations.
*
* @return the VirtualRoutersClient object.
*/
public VirtualRoutersClient getVirtualRouters() {
return this.virtualRouters;
}
/** The VirtualRouterPeeringsClient object to access its operations. */
private final VirtualRouterPeeringsClient virtualRouterPeerings;
/**
* Gets the VirtualRouterPeeringsClient object to access its operations.
*
* @return the VirtualRouterPeeringsClient object.
*/
public VirtualRouterPeeringsClient getVirtualRouterPeerings() {
return this.virtualRouterPeerings;
}
/** The VirtualWansClient object to access its operations. */
private final VirtualWansClient virtualWans;
/**
* Gets the VirtualWansClient object to access its operations.
*
* @return the VirtualWansClient object.
*/
public VirtualWansClient getVirtualWans() {
return this.virtualWans;
}
/** The VpnSitesClient object to access its operations. */
private final VpnSitesClient vpnSites;
/**
* Gets the VpnSitesClient object to access its operations.
*
* @return the VpnSitesClient object.
*/
public VpnSitesClient getVpnSites() {
return this.vpnSites;
}
/** The VpnSiteLinksClient object to access its operations. */
private final VpnSiteLinksClient vpnSiteLinks;
/**
* Gets the VpnSiteLinksClient object to access its operations.
*
* @return the VpnSiteLinksClient object.
*/
public VpnSiteLinksClient getVpnSiteLinks() {
return this.vpnSiteLinks;
}
/** The VpnSitesConfigurationsClient object to access its operations. */
private final VpnSitesConfigurationsClient vpnSitesConfigurations;
/**
* Gets the VpnSitesConfigurationsClient object to access its operations.
*
* @return the VpnSitesConfigurationsClient object.
*/
public VpnSitesConfigurationsClient getVpnSitesConfigurations() {
return this.vpnSitesConfigurations;
}
/** The VpnServerConfigurationsClient object to access its operations. */
private final VpnServerConfigurationsClient vpnServerConfigurations;
/**
* Gets the VpnServerConfigurationsClient object to access its operations.
*
* @return the VpnServerConfigurationsClient object.
*/
public VpnServerConfigurationsClient getVpnServerConfigurations() {
return this.vpnServerConfigurations;
}
/** The VirtualHubsClient object to access its operations. */
private final VirtualHubsClient virtualHubs;
/**
* Gets the VirtualHubsClient object to access its operations.
*
* @return the VirtualHubsClient object.
*/
public VirtualHubsClient getVirtualHubs() {
return this.virtualHubs;
}
/** The HubVirtualNetworkConnectionsClient object to access its operations. */
private final HubVirtualNetworkConnectionsClient hubVirtualNetworkConnections;
/**
* Gets the HubVirtualNetworkConnectionsClient object to access its operations.
*
* @return the HubVirtualNetworkConnectionsClient object.
*/
public HubVirtualNetworkConnectionsClient getHubVirtualNetworkConnections() {
return this.hubVirtualNetworkConnections;
}
/** The VpnGatewaysClient object to access its operations. */
private final VpnGatewaysClient vpnGateways;
/**
* Gets the VpnGatewaysClient object to access its operations.
*
* @return the VpnGatewaysClient object.
*/
public VpnGatewaysClient getVpnGateways() {
return this.vpnGateways;
}
/** The VpnConnectionsClient object to access its operations. */
private final VpnConnectionsClient vpnConnections;
/**
* Gets the VpnConnectionsClient object to access its operations.
*
* @return the VpnConnectionsClient object.
*/
public VpnConnectionsClient getVpnConnections() {
return this.vpnConnections;
}
/** The VpnSiteLinkConnectionsClient object to access its operations. */
private final VpnSiteLinkConnectionsClient vpnSiteLinkConnections;
/**
* Gets the VpnSiteLinkConnectionsClient object to access its operations.
*
* @return the VpnSiteLinkConnectionsClient object.
*/
public VpnSiteLinkConnectionsClient getVpnSiteLinkConnections() {
return this.vpnSiteLinkConnections;
}
/** The VpnLinkConnectionsClient object to access its operations. */
private final VpnLinkConnectionsClient vpnLinkConnections;
/**
* Gets the VpnLinkConnectionsClient object to access its operations.
*
* @return the VpnLinkConnectionsClient object.
*/
public VpnLinkConnectionsClient getVpnLinkConnections() {
return this.vpnLinkConnections;
}
/** The P2SVpnGatewaysClient object to access its operations. */
private final P2SVpnGatewaysClient p2SVpnGateways;
/**
* Gets the P2SVpnGatewaysClient object to access its operations.
*
* @return the P2SVpnGatewaysClient object.
*/
public P2SVpnGatewaysClient getP2SVpnGateways() {
return this.p2SVpnGateways;
}
/** The VpnServerConfigurationsAssociatedWithVirtualWansClient object to access its operations. */
private final VpnServerConfigurationsAssociatedWithVirtualWansClient
vpnServerConfigurationsAssociatedWithVirtualWans;
/**
* Gets the VpnServerConfigurationsAssociatedWithVirtualWansClient object to access its operations.
*
* @return the VpnServerConfigurationsAssociatedWithVirtualWansClient object.
*/
public VpnServerConfigurationsAssociatedWithVirtualWansClient
getVpnServerConfigurationsAssociatedWithVirtualWans() {
return this.vpnServerConfigurationsAssociatedWithVirtualWans;
}
/** The VirtualHubRouteTableV2SClient object to access its operations. */
private final VirtualHubRouteTableV2SClient virtualHubRouteTableV2S;
/**
* Gets the VirtualHubRouteTableV2SClient object to access its operations.
*
* @return the VirtualHubRouteTableV2SClient object.
*/
public VirtualHubRouteTableV2SClient getVirtualHubRouteTableV2S() {
return this.virtualHubRouteTableV2S;
}
/** The ExpressRouteGatewaysClient object to access its operations. */
private final ExpressRouteGatewaysClient expressRouteGateways;
/**
* Gets the ExpressRouteGatewaysClient object to access its operations.
*
* @return the ExpressRouteGatewaysClient object.
*/
public ExpressRouteGatewaysClient getExpressRouteGateways() {
return this.expressRouteGateways;
}
/** The ExpressRouteConnectionsClient object to access its operations. */
private final ExpressRouteConnectionsClient expressRouteConnections;
/**
* Gets the ExpressRouteConnectionsClient object to access its operations.
*
* @return the ExpressRouteConnectionsClient object.
*/
public ExpressRouteConnectionsClient getExpressRouteConnections() {
return this.expressRouteConnections;
}
/** The VirtualHubBgpConnectionsClient object to access its operations. */
private final VirtualHubBgpConnectionsClient virtualHubBgpConnections;
/**
* Gets the VirtualHubBgpConnectionsClient object to access its operations.
*
* @return the VirtualHubBgpConnectionsClient object.
*/
public VirtualHubBgpConnectionsClient getVirtualHubBgpConnections() {
return this.virtualHubBgpConnections;
}
/** The VirtualHubIpConfigurationsClient object to access its operations. */
private final VirtualHubIpConfigurationsClient virtualHubIpConfigurations;
/**
* Gets the VirtualHubIpConfigurationsClient object to access its operations.
*
* @return the VirtualHubIpConfigurationsClient object.
*/
public VirtualHubIpConfigurationsClient getVirtualHubIpConfigurations() {
return this.virtualHubIpConfigurations;
}
/** The HubRouteTablesClient object to access its operations. */
private final HubRouteTablesClient hubRouteTables;
/**
* Gets the HubRouteTablesClient object to access its operations.
*
* @return the HubRouteTablesClient object.
*/
public HubRouteTablesClient getHubRouteTables() {
return this.hubRouteTables;
}
/** The WebApplicationFirewallPoliciesClient object to access its operations. */
private final WebApplicationFirewallPoliciesClient webApplicationFirewallPolicies;
/**
* Gets the WebApplicationFirewallPoliciesClient object to access its operations.
*
* @return the WebApplicationFirewallPoliciesClient object.
*/
public WebApplicationFirewallPoliciesClient getWebApplicationFirewallPolicies() {
return this.webApplicationFirewallPolicies;
}
/**
* Initializes an instance of NetworkManagementClient client.
*
* @param httpPipeline The HTTP pipeline to send requests through.
* @param serializerAdapter The serializer to serialize an object into a string.
* @param defaultPollInterval The default poll interval for long-running operation.
* @param environment The Azure environment.
* @param subscriptionId The subscription credentials which uniquely identify the Microsoft Azure subscription. The
* subscription ID forms part of the URI for every service call.
* @param endpoint server parameter.
*/
NetworkManagementClientImpl(
HttpPipeline httpPipeline,
SerializerAdapter serializerAdapter,
Duration defaultPollInterval,
AzureEnvironment environment,
String subscriptionId,
String endpoint) {
super(httpPipeline, serializerAdapter, environment);
this.httpPipeline = httpPipeline;
this.serializerAdapter = serializerAdapter;
this.defaultPollInterval = defaultPollInterval;
this.subscriptionId = subscriptionId;
this.endpoint = endpoint;
this.applicationGateways = new ApplicationGatewaysClientImpl(this);
this.applicationGatewayPrivateLinkResources = new ApplicationGatewayPrivateLinkResourcesClientImpl(this);
this.applicationGatewayPrivateEndpointConnections =
new ApplicationGatewayPrivateEndpointConnectionsClientImpl(this);
this.applicationSecurityGroups = new ApplicationSecurityGroupsClientImpl(this);
this.availableDelegations = new AvailableDelegationsClientImpl(this);
this.availableResourceGroupDelegations = new AvailableResourceGroupDelegationsClientImpl(this);
this.availableServiceAliases = new AvailableServiceAliasesClientImpl(this);
this.azureFirewalls = new AzureFirewallsClientImpl(this);
this.azureFirewallFqdnTags = new AzureFirewallFqdnTagsClientImpl(this);
this.bastionHosts = new BastionHostsClientImpl(this);
this.ddosCustomPolicies = new DdosCustomPoliciesClientImpl(this);
this.ddosProtectionPlans = new DdosProtectionPlansClientImpl(this);
this.availableEndpointServices = new AvailableEndpointServicesClientImpl(this);
this.expressRouteCircuitAuthorizations = new ExpressRouteCircuitAuthorizationsClientImpl(this);
this.expressRouteCircuitPeerings = new ExpressRouteCircuitPeeringsClientImpl(this);
this.expressRouteCircuitConnections = new ExpressRouteCircuitConnectionsClientImpl(this);
this.peerExpressRouteCircuitConnections = new PeerExpressRouteCircuitConnectionsClientImpl(this);
this.expressRouteCircuits = new ExpressRouteCircuitsClientImpl(this);
this.expressRouteServiceProviders = new ExpressRouteServiceProvidersClientImpl(this);
this.expressRouteCrossConnections = new ExpressRouteCrossConnectionsClientImpl(this);
this.expressRouteCrossConnectionPeerings = new ExpressRouteCrossConnectionPeeringsClientImpl(this);
this.expressRoutePortsLocations = new ExpressRoutePortsLocationsClientImpl(this);
this.expressRoutePorts = new ExpressRoutePortsClientImpl(this);
this.expressRouteLinks = new ExpressRouteLinksClientImpl(this);
this.firewallPolicies = new FirewallPoliciesClientImpl(this);
this.firewallPolicyRuleCollectionGroups = new FirewallPolicyRuleCollectionGroupsClientImpl(this);
this.ipAllocations = new IpAllocationsClientImpl(this);
this.ipGroups = new IpGroupsClientImpl(this);
this.loadBalancers = new LoadBalancersClientImpl(this);
this.loadBalancerBackendAddressPools = new LoadBalancerBackendAddressPoolsClientImpl(this);
this.loadBalancerFrontendIpConfigurations = new LoadBalancerFrontendIpConfigurationsClientImpl(this);
this.inboundNatRules = new InboundNatRulesClientImpl(this);
this.loadBalancerLoadBalancingRules = new LoadBalancerLoadBalancingRulesClientImpl(this);
this.loadBalancerOutboundRules = new LoadBalancerOutboundRulesClientImpl(this);
this.loadBalancerNetworkInterfaces = new LoadBalancerNetworkInterfacesClientImpl(this);
this.loadBalancerProbes = new LoadBalancerProbesClientImpl(this);
this.natGateways = new NatGatewaysClientImpl(this);
this.networkInterfaces = new NetworkInterfacesClientImpl(this);
this.networkInterfaceIpConfigurations = new NetworkInterfaceIpConfigurationsClientImpl(this);
this.networkInterfaceLoadBalancers = new NetworkInterfaceLoadBalancersClientImpl(this);
this.networkInterfaceTapConfigurations = new NetworkInterfaceTapConfigurationsClientImpl(this);
this.networkProfiles = new NetworkProfilesClientImpl(this);
this.networkSecurityGroups = new NetworkSecurityGroupsClientImpl(this);
this.securityRules = new SecurityRulesClientImpl(this);
this.defaultSecurityRules = new DefaultSecurityRulesClientImpl(this);
this.networkVirtualAppliances = new NetworkVirtualAppliancesClientImpl(this);
this.virtualApplianceSites = new VirtualApplianceSitesClientImpl(this);
this.virtualApplianceSkus = new VirtualApplianceSkusClientImpl(this);
this.networkWatchers = new NetworkWatchersClientImpl(this);
this.packetCaptures = new PacketCapturesClientImpl(this);
this.connectionMonitors = new ConnectionMonitorsClientImpl(this);
this.flowLogs = new FlowLogsClientImpl(this);
this.operations = new OperationsClientImpl(this);
this.privateEndpoints = new PrivateEndpointsClientImpl(this);
this.availablePrivateEndpointTypes = new AvailablePrivateEndpointTypesClientImpl(this);
this.privateDnsZoneGroups = new PrivateDnsZoneGroupsClientImpl(this);
this.privateLinkServices = new PrivateLinkServicesClientImpl(this);
this.publicIpAddresses = new PublicIpAddressesClientImpl(this);
this.publicIpPrefixes = new PublicIpPrefixesClientImpl(this);
this.routeFilters = new RouteFiltersClientImpl(this);
this.routeFilterRules = new RouteFilterRulesClientImpl(this);
this.routeTables = new RouteTablesClientImpl(this);
this.routes = new RoutesClientImpl(this);
this.securityPartnerProviders = new SecurityPartnerProvidersClientImpl(this);
this.bgpServiceCommunities = new BgpServiceCommunitiesClientImpl(this);
this.serviceEndpointPolicies = new ServiceEndpointPoliciesClientImpl(this);
this.serviceEndpointPolicyDefinitions = new ServiceEndpointPolicyDefinitionsClientImpl(this);
this.serviceTags = new ServiceTagsClientImpl(this);
this.usages = new UsagesClientImpl(this);
this.virtualNetworks = new VirtualNetworksClientImpl(this);
this.subnets = new SubnetsClientImpl(this);
this.resourceNavigationLinks = new ResourceNavigationLinksClientImpl(this);
this.serviceAssociationLinks = new ServiceAssociationLinksClientImpl(this);
this.virtualNetworkPeerings = new VirtualNetworkPeeringsClientImpl(this);
this.virtualNetworkGateways = new VirtualNetworkGatewaysClientImpl(this);
this.virtualNetworkGatewayConnections = new VirtualNetworkGatewayConnectionsClientImpl(this);
this.localNetworkGateways = new LocalNetworkGatewaysClientImpl(this);
this.virtualNetworkTaps = new VirtualNetworkTapsClientImpl(this);
this.virtualRouters = new VirtualRoutersClientImpl(this);
this.virtualRouterPeerings = new VirtualRouterPeeringsClientImpl(this);
this.virtualWans = new VirtualWansClientImpl(this);
this.vpnSites = new VpnSitesClientImpl(this);
this.vpnSiteLinks = new VpnSiteLinksClientImpl(this);
this.vpnSitesConfigurations = new VpnSitesConfigurationsClientImpl(this);
this.vpnServerConfigurations = new VpnServerConfigurationsClientImpl(this);
this.virtualHubs = new VirtualHubsClientImpl(this);
this.hubVirtualNetworkConnections = new HubVirtualNetworkConnectionsClientImpl(this);
this.vpnGateways = new VpnGatewaysClientImpl(this);
this.vpnConnections = new VpnConnectionsClientImpl(this);
this.vpnSiteLinkConnections = new VpnSiteLinkConnectionsClientImpl(this);
this.vpnLinkConnections = new VpnLinkConnectionsClientImpl(this);
this.p2SVpnGateways = new P2SVpnGatewaysClientImpl(this);
this.vpnServerConfigurationsAssociatedWithVirtualWans =
new VpnServerConfigurationsAssociatedWithVirtualWansClientImpl(this);
this.virtualHubRouteTableV2S = new VirtualHubRouteTableV2SClientImpl(this);
this.expressRouteGateways = new ExpressRouteGatewaysClientImpl(this);
this.expressRouteConnections = new ExpressRouteConnectionsClientImpl(this);
this.virtualHubBgpConnections = new VirtualHubBgpConnectionsClientImpl(this);
this.virtualHubIpConfigurations = new VirtualHubIpConfigurationsClientImpl(this);
this.hubRouteTables = new HubRouteTablesClientImpl(this);
this.webApplicationFirewallPolicies = new WebApplicationFirewallPoliciesClientImpl(this);
this.service =
RestProxy.create(NetworkManagementClientService.class, this.httpPipeline, this.getSerializerAdapter());
}
/**
* The interface defining all the services for NetworkManagementClient to be used by the proxy service to perform
* REST calls.
*/
@Host("{$host}")
@ServiceInterface(name = "NetworkManagementCli")
private interface NetworkManagementClientService {
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network"
+ "/bastionHosts/{bastionHostName}/createShareableLinks")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> putBastionShareableLink(
@HostParam("$host") String endpoint,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("bastionHostName") String bastionHostname,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
@BodyParam("application/json") BastionShareableLinkListRequest bslRequest,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network"
+ "/bastionHosts/{bastionHostName}/deleteShareableLinks")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteBastionShareableLink(
@HostParam("$host") String endpoint,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("bastionHostName") String bastionHostname,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
@BodyParam("application/json") BastionShareableLinkListRequest bslRequest,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network"
+ "/bastionHosts/{bastionHostName}/getShareableLinks")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionShareableLinkListResult>> getBastionShareableLink(
@HostParam("$host") String endpoint,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("bastionHostName") String bastionHostname,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
@BodyParam("application/json") BastionShareableLinkListRequest bslRequest,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network"
+ "/bastionHosts/{bastionHostName}/getActiveSessions")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> getActiveSessions(
@HostParam("$host") String endpoint,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("bastionHostName") String bastionHostname,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network"
+ "/bastionHosts/{bastionHostName}/disconnectActiveSessions")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionSessionDeleteResult>> disconnectActiveSessions(
@HostParam("$host") String endpoint,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("bastionHostName") String bastionHostname,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
@BodyParam("application/json") SessionIds sessionIds,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/providers/Microsoft.Network/locations/{location}/CheckDnsNameAvailability")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<DnsNameAvailabilityResultInner>> checkDnsNameAvailability(
@HostParam("$host") String endpoint,
@PathParam("location") String location,
@QueryParam("domainNameLabel") String domainNameLabel,
@QueryParam("api-version") String apiVersion,
@PathParam("subscriptionId") String subscriptionId,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/virtualWans"
+ "/{virtualWANName}/supportedSecurityProviders")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<VirtualWanSecurityProvidersInner>> supportedSecurityProviders(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("virtualWANName") String virtualWanName,
@QueryParam("api-version") String apiVersion,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Network/virtualWans"
+ "/{virtualWANName}/GenerateVpnProfile")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> generatevirtualwanvpnserverconfigurationvpnprofile(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("virtualWANName") String virtualWanName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") VirtualWanVpnProfileParameters vpnClientParams,
Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get("{nextLink}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionShareableLinkListResult>> putBastionShareableLinkNext(
@PathParam(value = "nextLink", encoded = true) String nextLink, Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get("{nextLink}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionShareableLinkListResult>> getBastionShareableLinkNext(
@PathParam(value = "nextLink", encoded = true) String nextLink, Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get("{nextLink}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionActiveSessionListResult>> getActiveSessionsNext(
@PathParam(value = "nextLink", encoded = true) String nextLink, Context context);
@Headers({"Accept: application/json", "Content-Type: application/json"})
@Get("{nextLink}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<BastionSessionDeleteResult>> disconnectActiveSessionsNext(
@PathParam(value = "nextLink", encoded = true) String nextLink, Context context);
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> putBastionShareableLinkSinglePageAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
return FluxUtil
.withContext(
context -> {
Mono<Response<Flux<ByteBuffer>>> mono =
service
.putBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context)
.cache();
return Mono
.zip(
mono,
this
.<BastionShareableLinkListResult, BastionShareableLinkListResult>getLroResult(
mono,
this.getHttpPipeline(),
BastionShareableLinkListResult.class,
BastionShareableLinkListResult.class,
Context.NONE)
.last()
.flatMap(this::getLroFinalResultOrError));
})
.<PagedResponse<BastionShareableLinkInner>>map(
res ->
new PagedResponseBase<>(
res.getT1().getRequest(),
res.getT1().getStatusCode(),
res.getT1().getHeaders(),
res.getT2().value(),
res.getT2().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> putBastionShareableLinkSinglePageAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
context = this.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
service
.putBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context)
.cache();
return Mono
.zip(
mono,
this
.<BastionShareableLinkListResult, BastionShareableLinkListResult>getLroResult(
mono,
this.getHttpPipeline(),
BastionShareableLinkListResult.class,
BastionShareableLinkListResult.class,
context)
.last()
.flatMap(this::getLroFinalResultOrError))
.map(
res ->
new PagedResponseBase<>(
res.getT1().getRequest(),
res.getT1().getStatusCode(),
res.getT1().getHeaders(),
res.getT2().value(),
res.getT2().nextLink(),
null));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionShareableLinkInner> putBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
return new PagedFlux<>(
() -> putBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms),
nextLink -> putBastionShareableLinkNextSinglePageAsync(nextLink));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionShareableLinkInner> putBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
return new PagedFlux<>(
() -> putBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms),
nextLink -> putBastionShareableLinkNextSinglePageAsync(nextLink));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<BastionShareableLinkInner> putBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return new PagedFlux<>(
() -> putBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms, context),
nextLink -> putBastionShareableLinkNextSinglePageAsync(nextLink, context));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionShareableLinkInner> putBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return new PagedIterable<>(putBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms, context));
}
/**
* Creates a Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionShareableLinkInner> putBastionShareableLink(
String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
return new PagedIterable<>(putBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms));
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteBastionShareableLinkWithResponseAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
return FluxUtil
.withContext(
context ->
service
.deleteBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteBastionShareableLinkWithResponseAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
context = this.mergeContext(context);
return service
.deleteBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteBastionShareableLinkWithResponseAsync(resourceGroupName, bastionHostname, vms);
return this.<Void, Void>getLroResult(mono, this.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
context = this.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteBastionShareableLinkWithResponseAsync(resourceGroupName, bastionHostname, vms, context);
return this.<Void, Void>getLroResult(mono, this.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
return beginDeleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms).getSyncPoller();
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return beginDeleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms, context).getSyncPoller();
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
return beginDeleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms)
.last()
.flatMap(this::getLroFinalResultOrError);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return beginDeleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms, context)
.last()
.flatMap(this::getLroFinalResultOrError);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteBastionShareableLinkAsync(String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
return beginDeleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms)
.last()
.flatMap(this::getLroFinalResultOrError);
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
deleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms).block();
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
deleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms, context).block();
}
/**
* Deletes the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteBastionShareableLink(String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
deleteBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms).block();
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> getBastionShareableLinkSinglePageAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
return FluxUtil
.withContext(
context ->
service
.getBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context))
.<PagedResponse<BastionShareableLinkInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> getBastionShareableLinkSinglePageAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (vms != null) {
vms.forEach(e -> e.validate());
}
final String apiVersion = "2020-05-01";
BastionShareableLinkListRequest bslRequest = new BastionShareableLinkListRequest();
bslRequest.withVms(vms);
context = this.mergeContext(context);
return service
.getBastionShareableLink(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
bslRequest,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionShareableLinkInner> getBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms) {
return new PagedFlux<>(
() -> getBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms),
nextLink -> getBastionShareableLinkNextSinglePageAsync(nextLink));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionShareableLinkInner> getBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
return new PagedFlux<>(
() -> getBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms),
nextLink -> getBastionShareableLinkNextSinglePageAsync(nextLink));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<BastionShareableLinkInner> getBastionShareableLinkAsync(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return new PagedFlux<>(
() -> getBastionShareableLinkSinglePageAsync(resourceGroupName, bastionHostname, vms, context),
nextLink -> getBastionShareableLinkNextSinglePageAsync(nextLink, context));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param vms List of VM references.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionShareableLinkInner> getBastionShareableLink(
String resourceGroupName, String bastionHostname, List<BastionShareableLinkInner> vms, Context context) {
return new PagedIterable<>(getBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms, context));
}
/**
* Return the Bastion Shareable Links for all the VMs specified in the request.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionShareableLinkInner> getBastionShareableLink(
String resourceGroupName, String bastionHostname) {
final List<BastionShareableLinkInner> vms = null;
return new PagedIterable<>(getBastionShareableLinkAsync(resourceGroupName, bastionHostname, vms));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionActiveSessionInner>> getActiveSessionsSinglePageAsync(
String resourceGroupName, String bastionHostname) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
return FluxUtil
.withContext(
context -> {
Mono<Response<Flux<ByteBuffer>>> mono =
service
.getActiveSessions(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
context)
.cache();
return Mono
.zip(
mono,
this
.<BastionActiveSessionListResult, BastionActiveSessionListResult>getLroResult(
mono,
this.getHttpPipeline(),
BastionActiveSessionListResult.class,
BastionActiveSessionListResult.class,
Context.NONE)
.last()
.flatMap(this::getLroFinalResultOrError));
})
.<PagedResponse<BastionActiveSessionInner>>map(
res ->
new PagedResponseBase<>(
res.getT1().getRequest(),
res.getT1().getStatusCode(),
res.getT1().getHeaders(),
res.getT2().value(),
res.getT2().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionActiveSessionInner>> getActiveSessionsSinglePageAsync(
String resourceGroupName, String bastionHostname, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
context = this.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
service
.getActiveSessions(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
context)
.cache();
return Mono
.zip(
mono,
this
.<BastionActiveSessionListResult, BastionActiveSessionListResult>getLroResult(
mono,
this.getHttpPipeline(),
BastionActiveSessionListResult.class,
BastionActiveSessionListResult.class,
context)
.last()
.flatMap(this::getLroFinalResultOrError))
.map(
res ->
new PagedResponseBase<>(
res.getT1().getRequest(),
res.getT1().getStatusCode(),
res.getT1().getHeaders(),
res.getT2().value(),
res.getT2().nextLink(),
null));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionActiveSessionInner> getActiveSessionsAsync(
String resourceGroupName, String bastionHostname) {
return new PagedFlux<>(
() -> getActiveSessionsSinglePageAsync(resourceGroupName, bastionHostname),
nextLink -> getActiveSessionsNextSinglePageAsync(nextLink));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<BastionActiveSessionInner> getActiveSessionsAsync(
String resourceGroupName, String bastionHostname, Context context) {
return new PagedFlux<>(
() -> getActiveSessionsSinglePageAsync(resourceGroupName, bastionHostname, context),
nextLink -> getActiveSessionsNextSinglePageAsync(nextLink, context));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionActiveSessionInner> getActiveSessions(
String resourceGroupName, String bastionHostname) {
return new PagedIterable<>(getActiveSessionsAsync(resourceGroupName, bastionHostname));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionActiveSessionInner> getActiveSessions(
String resourceGroupName, String bastionHostname, Context context) {
return new PagedIterable<>(getActiveSessionsAsync(resourceGroupName, bastionHostname, context));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param sessionIdsSessionIds List of session IDs.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionSessionStateInner>> disconnectActiveSessionsSinglePageAsync(
String resourceGroupName, String bastionHostname, List<String> sessionIdsSessionIds) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
SessionIds sessionIds = new SessionIds();
sessionIds.withSessionIds(sessionIdsSessionIds);
return FluxUtil
.withContext(
context ->
service
.disconnectActiveSessions(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
sessionIds,
context))
.<PagedResponse<BastionSessionStateInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param sessionIdsSessionIds List of session IDs.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionSessionStateInner>> disconnectActiveSessionsSinglePageAsync(
String resourceGroupName, String bastionHostname, List<String> sessionIdsSessionIds, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (bastionHostname == null) {
return Mono
.error(new IllegalArgumentException("Parameter bastionHostname is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
SessionIds sessionIds = new SessionIds();
sessionIds.withSessionIds(sessionIdsSessionIds);
context = this.mergeContext(context);
return service
.disconnectActiveSessions(
this.getEndpoint(),
resourceGroupName,
bastionHostname,
apiVersion,
this.getSubscriptionId(),
sessionIds,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param sessionIdsSessionIds List of session IDs.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionSessionStateInner> disconnectActiveSessionsAsync(
String resourceGroupName, String bastionHostname, List<String> sessionIdsSessionIds) {
return new PagedFlux<>(
() -> disconnectActiveSessionsSinglePageAsync(resourceGroupName, bastionHostname, sessionIdsSessionIds),
nextLink -> disconnectActiveSessionsNextSinglePageAsync(nextLink));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<BastionSessionStateInner> disconnectActiveSessionsAsync(
String resourceGroupName, String bastionHostname) {
final List<String> sessionIdsSessionIds = null;
return new PagedFlux<>(
() -> disconnectActiveSessionsSinglePageAsync(resourceGroupName, bastionHostname, sessionIdsSessionIds),
nextLink -> disconnectActiveSessionsNextSinglePageAsync(nextLink));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param sessionIdsSessionIds List of session IDs.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<BastionSessionStateInner> disconnectActiveSessionsAsync(
String resourceGroupName, String bastionHostname, List<String> sessionIdsSessionIds, Context context) {
return new PagedFlux<>(
() ->
disconnectActiveSessionsSinglePageAsync(
resourceGroupName, bastionHostname, sessionIdsSessionIds, context),
nextLink -> disconnectActiveSessionsNextSinglePageAsync(nextLink, context));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @param sessionIdsSessionIds List of session IDs.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionSessionStateInner> disconnectActiveSessions(
String resourceGroupName, String bastionHostname, List<String> sessionIdsSessionIds, Context context) {
return new PagedIterable<>(
disconnectActiveSessionsAsync(resourceGroupName, bastionHostname, sessionIdsSessionIds, context));
}
/**
* Returns the list of currently active sessions on the Bastion.
*
* @param resourceGroupName The name of the resource group.
* @param bastionHostname The name of the Bastion Host.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<BastionSessionStateInner> disconnectActiveSessions(
String resourceGroupName, String bastionHostname) {
final List<String> sessionIdsSessionIds = null;
return new PagedIterable<>(
disconnectActiveSessionsAsync(resourceGroupName, bastionHostname, sessionIdsSessionIds));
}
/**
* Checks whether a domain name in the cloudapp.azure.com zone is available for use.
*
* @param location The location of the domain name.
* @param domainNameLabel The domain name to be verified. It must conform to the following regular expression:
* ^[a-z][a-z0-9-]{1,61}[a-z0-9]$.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for the CheckDnsNameAvailability API service call.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<DnsNameAvailabilityResultInner>> checkDnsNameAvailabilityWithResponseAsync(
String location, String domainNameLabel) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (location == null) {
return Mono.error(new IllegalArgumentException("Parameter location is required and cannot be null."));
}
if (domainNameLabel == null) {
return Mono
.error(new IllegalArgumentException("Parameter domainNameLabel is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
return FluxUtil
.withContext(
context ->
service
.checkDnsNameAvailability(
this.getEndpoint(),
location,
domainNameLabel,
apiVersion,
this.getSubscriptionId(),
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Checks whether a domain name in the cloudapp.azure.com zone is available for use.
*
* @param location The location of the domain name.
* @param domainNameLabel The domain name to be verified. It must conform to the following regular expression:
* ^[a-z][a-z0-9-]{1,61}[a-z0-9]$.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for the CheckDnsNameAvailability API service call.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<DnsNameAvailabilityResultInner>> checkDnsNameAvailabilityWithResponseAsync(
String location, String domainNameLabel, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (location == null) {
return Mono.error(new IllegalArgumentException("Parameter location is required and cannot be null."));
}
if (domainNameLabel == null) {
return Mono
.error(new IllegalArgumentException("Parameter domainNameLabel is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
context = this.mergeContext(context);
return service
.checkDnsNameAvailability(
this.getEndpoint(), location, domainNameLabel, apiVersion, this.getSubscriptionId(), context);
}
/**
* Checks whether a domain name in the cloudapp.azure.com zone is available for use.
*
* @param location The location of the domain name.
* @param domainNameLabel The domain name to be verified. It must conform to the following regular expression:
* ^[a-z][a-z0-9-]{1,61}[a-z0-9]$.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for the CheckDnsNameAvailability API service call.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<DnsNameAvailabilityResultInner> checkDnsNameAvailabilityAsync(String location, String domainNameLabel) {
return checkDnsNameAvailabilityWithResponseAsync(location, domainNameLabel)
.flatMap(
(Response<DnsNameAvailabilityResultInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Checks whether a domain name in the cloudapp.azure.com zone is available for use.
*
* @param location The location of the domain name.
* @param domainNameLabel The domain name to be verified. It must conform to the following regular expression:
* ^[a-z][a-z0-9-]{1,61}[a-z0-9]$.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for the CheckDnsNameAvailability API service call.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public DnsNameAvailabilityResultInner checkDnsNameAvailability(String location, String domainNameLabel) {
return checkDnsNameAvailabilityAsync(location, domainNameLabel).block();
}
/**
* Checks whether a domain name in the cloudapp.azure.com zone is available for use.
*
* @param location The location of the domain name.
* @param domainNameLabel The domain name to be verified. It must conform to the following regular expression:
* ^[a-z][a-z0-9-]{1,61}[a-z0-9]$.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for the CheckDnsNameAvailability API service call.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<DnsNameAvailabilityResultInner> checkDnsNameAvailabilityWithResponse(
String location, String domainNameLabel, Context context) {
return checkDnsNameAvailabilityWithResponseAsync(location, domainNameLabel, context).block();
}
/**
* Gives the supported security providers for the virtual wan.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN for which supported security providers are needed.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return collection of SecurityProviders.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<VirtualWanSecurityProvidersInner>> supportedSecurityProvidersWithResponseAsync(
String resourceGroupName, String virtualWanName) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (virtualWanName == null) {
return Mono.error(new IllegalArgumentException("Parameter virtualWanName is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
return FluxUtil
.withContext(
context ->
service
.supportedSecurityProviders(
this.getEndpoint(),
this.getSubscriptionId(),
resourceGroupName,
virtualWanName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Gives the supported security providers for the virtual wan.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN for which supported security providers are needed.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return collection of SecurityProviders.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<VirtualWanSecurityProvidersInner>> supportedSecurityProvidersWithResponseAsync(
String resourceGroupName, String virtualWanName, Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (virtualWanName == null) {
return Mono.error(new IllegalArgumentException("Parameter virtualWanName is required and cannot be null."));
}
final String apiVersion = "2020-05-01";
context = this.mergeContext(context);
return service
.supportedSecurityProviders(
this.getEndpoint(), this.getSubscriptionId(), resourceGroupName, virtualWanName, apiVersion, context);
}
/**
* Gives the supported security providers for the virtual wan.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN for which supported security providers are needed.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return collection of SecurityProviders.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<VirtualWanSecurityProvidersInner> supportedSecurityProvidersAsync(
String resourceGroupName, String virtualWanName) {
return supportedSecurityProvidersWithResponseAsync(resourceGroupName, virtualWanName)
.flatMap(
(Response<VirtualWanSecurityProvidersInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gives the supported security providers for the virtual wan.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN for which supported security providers are needed.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return collection of SecurityProviders.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public VirtualWanSecurityProvidersInner supportedSecurityProviders(
String resourceGroupName, String virtualWanName) {
return supportedSecurityProvidersAsync(resourceGroupName, virtualWanName).block();
}
/**
* Gives the supported security providers for the virtual wan.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN for which supported security providers are needed.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return collection of SecurityProviders.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<VirtualWanSecurityProvidersInner> supportedSecurityProvidersWithResponse(
String resourceGroupName, String virtualWanName, Context context) {
return supportedSecurityProvidersWithResponseAsync(resourceGroupName, virtualWanName, context).block();
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> generatevirtualwanvpnserverconfigurationvpnprofileWithResponseAsync(
String resourceGroupName, String virtualWanName, VirtualWanVpnProfileParameters vpnClientParams) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (virtualWanName == null) {
return Mono.error(new IllegalArgumentException("Parameter virtualWanName is required and cannot be null."));
}
if (vpnClientParams == null) {
return Mono
.error(new IllegalArgumentException("Parameter vpnClientParams is required and cannot be null."));
} else {
vpnClientParams.validate();
}
final String apiVersion = "2020-05-01";
return FluxUtil
.withContext(
context ->
service
.generatevirtualwanvpnserverconfigurationvpnprofile(
this.getEndpoint(),
this.getSubscriptionId(),
resourceGroupName,
virtualWanName,
apiVersion,
vpnClientParams,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> generatevirtualwanvpnserverconfigurationvpnprofileWithResponseAsync(
String resourceGroupName,
String virtualWanName,
VirtualWanVpnProfileParameters vpnClientParams,
Context context) {
if (this.getEndpoint() == null) {
return Mono
.error(new IllegalArgumentException("Parameter this.getEndpoint() is required and cannot be null."));
}
if (this.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException("Parameter this.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (virtualWanName == null) {
return Mono.error(new IllegalArgumentException("Parameter virtualWanName is required and cannot be null."));
}
if (vpnClientParams == null) {
return Mono
.error(new IllegalArgumentException("Parameter vpnClientParams is required and cannot be null."));
} else {
vpnClientParams.validate();
}
final String apiVersion = "2020-05-01";
context = this.mergeContext(context);
return service
.generatevirtualwanvpnserverconfigurationvpnprofile(
this.getEndpoint(),
this.getSubscriptionId(),
resourceGroupName,
virtualWanName,
apiVersion,
vpnClientParams,
context);
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<VpnProfileResponseInner>, VpnProfileResponseInner>
beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
String resourceGroupName, String virtualWanName, VirtualWanVpnProfileParameters vpnClientParams) {
Mono<Response<Flux<ByteBuffer>>> mono =
generatevirtualwanvpnserverconfigurationvpnprofileWithResponseAsync(
resourceGroupName, virtualWanName, vpnClientParams);
return this
.<VpnProfileResponseInner, VpnProfileResponseInner>getLroResult(
mono,
this.getHttpPipeline(),
VpnProfileResponseInner.class,
VpnProfileResponseInner.class,
Context.NONE);
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<VpnProfileResponseInner>, VpnProfileResponseInner>
beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
String resourceGroupName,
String virtualWanName,
VirtualWanVpnProfileParameters vpnClientParams,
Context context) {
context = this.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
generatevirtualwanvpnserverconfigurationvpnprofileWithResponseAsync(
resourceGroupName, virtualWanName, vpnClientParams, context);
return this
.<VpnProfileResponseInner, VpnProfileResponseInner>getLroResult(
mono, this.getHttpPipeline(), VpnProfileResponseInner.class, VpnProfileResponseInner.class, context);
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<VpnProfileResponseInner>, VpnProfileResponseInner>
beginGeneratevirtualwanvpnserverconfigurationvpnprofile(
String resourceGroupName, String virtualWanName, VirtualWanVpnProfileParameters vpnClientParams) {
return beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams)
.getSyncPoller();
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<VpnProfileResponseInner>, VpnProfileResponseInner>
beginGeneratevirtualwanvpnserverconfigurationvpnprofile(
String resourceGroupName,
String virtualWanName,
VirtualWanVpnProfileParameters vpnClientParams,
Context context) {
return beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams, context)
.getSyncPoller();
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<VpnProfileResponseInner> generatevirtualwanvpnserverconfigurationvpnprofileAsync(
String resourceGroupName, String virtualWanName, VirtualWanVpnProfileParameters vpnClientParams) {
return beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams)
.last()
.flatMap(this::getLroFinalResultOrError);
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<VpnProfileResponseInner> generatevirtualwanvpnserverconfigurationvpnprofileAsync(
String resourceGroupName,
String virtualWanName,
VirtualWanVpnProfileParameters vpnClientParams,
Context context) {
return beginGeneratevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams, context)
.last()
.flatMap(this::getLroFinalResultOrError);
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public VpnProfileResponseInner generatevirtualwanvpnserverconfigurationvpnprofile(
String resourceGroupName, String virtualWanName, VirtualWanVpnProfileParameters vpnClientParams) {
return generatevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams)
.block();
}
/**
* Generates a unique VPN profile for P2S clients for VirtualWan and associated VpnServerConfiguration combination
* in the specified resource group.
*
* @param resourceGroupName The resource group name.
* @param virtualWanName The name of the VirtualWAN whose associated VpnServerConfigurations is needed.
* @param vpnClientParams Virtual Wan Vpn profile parameters Vpn profile generation.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return vpn Profile Response for package generation.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public VpnProfileResponseInner generatevirtualwanvpnserverconfigurationvpnprofile(
String resourceGroupName,
String virtualWanName,
VirtualWanVpnProfileParameters vpnClientParams,
Context context) {
return generatevirtualwanvpnserverconfigurationvpnprofileAsync(
resourceGroupName, virtualWanName, vpnClientParams, context)
.block();
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> putBastionShareableLinkNextSinglePageAsync(String nextLink) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
return FluxUtil
.withContext(context -> service.putBastionShareableLinkNext(nextLink, context))
.<PagedResponse<BastionShareableLinkInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> putBastionShareableLinkNextSinglePageAsync(
String nextLink, Context context) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
context = this.mergeContext(context);
return service
.putBastionShareableLinkNext(nextLink, context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> getBastionShareableLinkNextSinglePageAsync(String nextLink) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
return FluxUtil
.withContext(context -> service.getBastionShareableLinkNext(nextLink, context))
.<PagedResponse<BastionShareableLinkInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for all the Bastion Shareable Link endpoints.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionShareableLinkInner>> getBastionShareableLinkNextSinglePageAsync(
String nextLink, Context context) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
context = this.mergeContext(context);
return service
.getBastionShareableLinkNext(nextLink, context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionActiveSessionInner>> getActiveSessionsNextSinglePageAsync(String nextLink) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
return FluxUtil
.withContext(context -> service.getActiveSessionsNext(nextLink, context))
.<PagedResponse<BastionActiveSessionInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for GetActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionActiveSessionInner>> getActiveSessionsNextSinglePageAsync(
String nextLink, Context context) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
context = this.mergeContext(context);
return service
.getActiveSessionsNext(nextLink, context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionSessionStateInner>> disconnectActiveSessionsNextSinglePageAsync(String nextLink) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
return FluxUtil
.withContext(context -> service.disconnectActiveSessionsNext(nextLink, context))
.<PagedResponse<BastionSessionStateInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.getContext())));
}
/**
* Get the next page of items.
*
* @param nextLink The nextLink parameter.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return response for DisconnectActiveSessions.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<BastionSessionStateInner>> disconnectActiveSessionsNextSinglePageAsync(
String nextLink, Context context) {
if (nextLink == null) {
return Mono.error(new IllegalArgumentException("Parameter nextLink is required and cannot be null."));
}
context = this.mergeContext(context);
return service
.disconnectActiveSessionsNext(nextLink, context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(),
res.getStatusCode(),
res.getHeaders(),
res.getValue().value(),
res.getValue().nextLink(),
null));
}
}