File tree Expand file tree Collapse file tree 8 files changed +13
-13
lines changed
azure-storage-blob-stress-v2/src/main/java/com/azure/v2/storage/blob/stress
azure-storage-stress-v2/src/main/java/com/azure/v2/storage/stress Expand file tree Collapse file tree 8 files changed +13
-13
lines changed Original file line number Diff line number Diff line change 1212import com .azure .v2 .storage .stress .StorageStressOptions ;
1313import com .azure .v2 .storage .stress .TelemetryHelper ;
1414import io .clientcore .core .http .models .HttpHeaderName ;
15- import io .clientcore .core .http .models .HttpInstrumentationOptions ;
16- import io .clientcore .core .util .Context ;
15+ import io .clientcore .core .http .pipeline .HttpInstrumentationOptions ;
16+ import io .clientcore .core .utils .Context ;
1717import reactor .core .publisher .Mono ;
1818
1919import java .time .Instant ;
@@ -112,7 +112,7 @@ protected String generateBlobName() {
112112
113113 protected static HttpInstrumentationOptions getInstrumentationOptions () {
114114 return new HttpInstrumentationOptions ()
115- .setHttpLogLevel (HttpInstrumentationOptions .HttpLogDetailLevel .HEADERS )
115+ .setHttpLogLevel (HttpInstrumentationOptions .HttpLogLevel .HEADERS )
116116 .addAllowedHeaderName (HttpHeaderName .fromString ("x-ms-faultinjector-response-option" ))
117117 .addAllowedHeaderName (HttpHeaderName .CONTENT_RANGE )
118118 .addAllowedHeaderName (HttpHeaderName .ACCEPT_RANGES )
Original file line number Diff line number Diff line change 77import com .azure .v2 .storage .blob .BlockBlobClient ;
88import com .azure .v2 .storage .blob .stress .utils .OriginalContentV2 ;
99import com .azure .v2 .storage .stress .StorageStressOptions ;
10- import io .clientcore .core .util . Context ;
11- import io .clientcore .core .util . binarydata . BinaryData ;
10+ import io .clientcore .core .models . binarydata . BinaryData ;
11+ import io .clientcore .core .utils . Context ;
1212import reactor .core .publisher .Mono ;
1313
1414public class DownloadContentV2 extends BlobScenarioBaseV2 <StorageStressOptions > {
Original file line number Diff line number Diff line change 1010import com .azure .v2 .storage .stress .ContentMismatchException ;
1111import com .azure .v2 .storage .stress .CrcInputStream ;
1212import io .clientcore .core .instrumentation .logging .ClientLogger ;
13- import io .clientcore .core .util . Context ;
14- import io .clientcore .core .util . binarydata . BinaryData ;
13+ import io .clientcore .core .models . binarydata . BinaryData ;
14+ import io .clientcore .core .utils . Context ;
1515
1616import java .nio .ByteBuffer ;
1717import java .util .Base64 ;
Original file line number Diff line number Diff line change 33
44package com .azure .v2 .storage .stress ;
55
6- import io .clientcore .core .util .binarydata .BinaryData ;
6+ import io .clientcore .core .models .binarydata .BinaryData ;
77import reactor .core .publisher .Flux ;
88import reactor .core .publisher .Mono ;
99
Original file line number Diff line number Diff line change 66import com .azure .core .exception .UnexpectedLengthException ;
77import com .azure .core .util .FluxUtil ;
88import io .clientcore .core .instrumentation .logging .ClientLogger ;
9- import io .clientcore .core .util .binarydata .BinaryData ;
9+ import io .clientcore .core .models .binarydata .BinaryData ;
1010import reactor .core .publisher .Flux ;
1111import reactor .core .publisher .Mono ;
1212import reactor .core .publisher .Sinks ;
Original file line number Diff line number Diff line change 55
66import io .clientcore .core .http .models .HttpHeaderName ;
77import io .clientcore .core .http .models .HttpRequest ;
8- import io .clientcore .core .http .models .HttpResponse ;
98import io .clientcore .core .http .models .Response ;
109import io .clientcore .core .http .pipeline .HttpPipelineNextPolicy ;
1110import io .clientcore .core .http .pipeline .HttpPipelinePolicy ;
11+ import io .clientcore .core .implementation .http .HttpResponse ;
1212import io .clientcore .core .instrumentation .logging .ClientLogger ;
13- import io .clientcore .core .util .UriBuilder ;
13+ import io .clientcore .core .utils .UriBuilder ;
1414import reactor .util .function .Tuple2 ;
1515import reactor .util .function .Tuples ;
1616
Original file line number Diff line number Diff line change 33
44package com .azure .v2 .storage .stress ;
55
6- import io .clientcore .core .util .binarydata .BinaryData ;
6+ import io .clientcore .core .models .binarydata .BinaryData ;
77
88import java .io .IOException ;
99import java .io .InputStream ;
Original file line number Diff line number Diff line change 55
66import com .azure .perf .test .core .PerfStressOptions ;
77import com .beust .jcommander .Parameter ;
8- import io .clientcore .core .util .configuration .Configuration ;
8+ import io .clientcore .core .utils .configuration .Configuration ;
99
1010public class StorageStressOptions extends PerfStressOptions {
1111 @ Parameter (names = { "--downloadFaults" }, description = "Enable fault injection for downloads" )
You can’t perform that action at this time.
0 commit comments