Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
# Release History

## 1.0.0-beta.2 (Unreleased)
## 1.0.0-beta.1 (2021-12-08)

- Azure Resource Manager StoragePool client library for Java. This package contains Microsoft Azure SDK for StoragePool Management SDK. Package tag package-2021-08-01. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).

### Features Added

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ Various documentation is available to help you get started
<dependency>
<groupId>com.azure.resourcemanager</groupId>
<artifactId>azure-resourcemanager-storagepool</artifactId>
<version>1.0.0-beta.1</version>
<version>1.0.0-beta.2</version>
</dependency>
```
[//]: # ({x-version-update-end})
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import com.azure.core.http.HttpClient;
import com.azure.core.http.HttpPipeline;
import com.azure.core.http.HttpPipelineBuilder;
import com.azure.core.http.HttpPipelinePosition;
import com.azure.core.http.policy.AddDatePolicy;
import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpLoggingPolicy;
Expand Down Expand Up @@ -37,6 +38,7 @@
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/** Entry point to StoragePoolManager. */
public final class StoragePoolManager {
Expand Down Expand Up @@ -209,11 +211,24 @@ public StoragePoolManager authenticate(TokenCredential credential, AzureProfile
List<HttpPipelinePolicy> policies = new ArrayList<>();
policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
policies.add(new RequestIdPolicy());
policies
.addAll(
this
.policies
.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
.collect(Collectors.toList()));
HttpPolicyProviders.addBeforeRetryPolicies(policies);
policies.add(retryPolicy);
policies.add(new AddDatePolicy());
policies.add(new ArmChallengeAuthenticationPolicy(credential, scopes.toArray(new String[0])));
policies.addAll(this.policies);
policies
.addAll(
this
.policies
.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
.collect(Collectors.toList()));
HttpPolicyProviders.addAfterRetryPolicies(policies);
policies.add(new HttpLoggingPolicy(httpLogOptions));
HttpPipeline httpPipeline =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -687,7 +687,11 @@ private PollerFlux<PollResult<DiskPoolInner>, DiskPoolInner> beginCreateOrUpdate
return this
.client
.<DiskPoolInner, DiskPoolInner>getLroResult(
mono, this.client.getHttpPipeline(), DiskPoolInner.class, DiskPoolInner.class, Context.NONE);
mono,
this.client.getHttpPipeline(),
DiskPoolInner.class,
DiskPoolInner.class,
this.client.getContext());
}

/**
Expand Down Expand Up @@ -960,7 +964,11 @@ private PollerFlux<PollResult<DiskPoolInner>, DiskPoolInner> beginUpdateAsync(
return this
.client
.<DiskPoolInner, DiskPoolInner>getLroResult(
mono, this.client.getHttpPipeline(), DiskPoolInner.class, DiskPoolInner.class, Context.NONE);
mono,
this.client.getHttpPipeline(),
DiskPoolInner.class,
DiskPoolInner.class,
this.client.getContext());
}

/**
Expand Down Expand Up @@ -1206,7 +1214,8 @@ private PollerFlux<PollResult<Void>, Void> beginDeleteAsync(String resourceGroup
Mono<Response<Flux<ByteBuffer>>> mono = deleteWithResponseAsync(resourceGroupName, diskPoolName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
.<Void, Void>getLroResult(
mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
}

/**
Expand Down Expand Up @@ -1775,7 +1784,8 @@ private PollerFlux<PollResult<Void>, Void> beginStartAsync(String resourceGroupN
Mono<Response<Flux<ByteBuffer>>> mono = startWithResponseAsync(resourceGroupName, diskPoolName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
.<Void, Void>getLroResult(
mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
}

/**
Expand Down Expand Up @@ -2012,7 +2022,8 @@ private PollerFlux<PollResult<Void>, Void> beginDeallocateAsync(String resourceG
Mono<Response<Flux<ByteBuffer>>> mono = deallocateWithResponseAsync(resourceGroupName, diskPoolName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
.<Void, Void>getLroResult(
mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
}

/**
Expand Down Expand Up @@ -2250,7 +2261,8 @@ private PollerFlux<PollResult<Void>, Void> beginUpgradeAsync(String resourceGrou
Mono<Response<Flux<ByteBuffer>>> mono = upgradeWithResponseAsync(resourceGroupName, diskPoolName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
.<Void, Void>getLroResult(
mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -496,7 +496,11 @@ private PollerFlux<PollResult<IscsiTargetInner>, IscsiTargetInner> beginCreateOr
return this
.client
.<IscsiTargetInner, IscsiTargetInner>getLroResult(
mono, this.client.getHttpPipeline(), IscsiTargetInner.class, IscsiTargetInner.class, Context.NONE);
mono,
this.client.getHttpPipeline(),
IscsiTargetInner.class,
IscsiTargetInner.class,
this.client.getContext());
}

/**
Expand Down Expand Up @@ -824,7 +828,11 @@ private PollerFlux<PollResult<IscsiTargetInner>, IscsiTargetInner> beginUpdateAs
return this
.client
.<IscsiTargetInner, IscsiTargetInner>getLroResult(
mono, this.client.getHttpPipeline(), IscsiTargetInner.class, IscsiTargetInner.class, Context.NONE);
mono,
this.client.getHttpPipeline(),
IscsiTargetInner.class,
IscsiTargetInner.class,
this.client.getContext());
}

/**
Expand Down Expand Up @@ -1119,7 +1127,8 @@ private PollerFlux<PollResult<Void>, Void> beginDeleteAsync(
deleteWithResponseAsync(resourceGroupName, diskPoolName, iscsiTargetName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
.<Void, Void>getLroResult(
mono, this.client.getHttpPipeline(), Void.class, Void.class, this.client.getContext());
}

/**
Expand Down