Home
last modified time | relevance | path

Searched refs:rateLimiter (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRateLimiterTest.java21 try(final RateLimiter rateLimiter = in bytesPerSecond() argument
24 assertThat(rateLimiter.getBytesPerSecond()).isGreaterThan(0); in bytesPerSecond()
25 rateLimiter.setBytesPerSecond(2000); in bytesPerSecond()
26 assertThat(rateLimiter.getBytesPerSecond()).isGreaterThan(0); in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes() argument
35 assertThat(rateLimiter.getSingleBurstBytes()).isEqualTo(100); in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough() argument
44 assertThat(rateLimiter.getTotalBytesThrough()).isEqualTo(0); in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests() argument
53 assertThat(rateLimiter.getTotalRequests()).isEqualTo(0); in getTotalRequests()
[all …]
DEnvOptionsTest.java133 public void rateLimiter() { in rateLimiter() method in EnvOptionsTest
137 assertThat(envOptions.rateLimiter()).isEqualTo(rateLimiter1); in rateLimiter()
141 assertThat(envOptions.rateLimiter()).isEqualTo(rateLimiter2); in rateLimiter()
DDBOptionsTest.java780 public void rateLimiter() { in rateLimiter() method in DBOptionsTest
783 final RateLimiter rateLimiter = new RateLimiter(1000, 100 * 1000, 1)) { in rateLimiter()
784 options.setRateLimiter(rateLimiter); in rateLimiter()
DOptionsTest.java1148 public void rateLimiter() { in rateLimiter() method in OptionsTest
1151 final RateLimiter rateLimiter = in rateLimiter()
1153 options.setRateLimiter(rateLimiter); in rateLimiter()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DEnvOptions.java310 public EnvOptions setRateLimiter(final RateLimiter rateLimiter) { in setRateLimiter() argument
311 this.rateLimiter = rateLimiter; in setRateLimiter()
312 setRateLimiter(nativeHandle_, rateLimiter.nativeHandle_); in setRateLimiter()
321 public RateLimiter rateLimiter() { in rateLimiter() method in EnvOptions
323 return rateLimiter; in rateLimiter()
365 private RateLimiter rateLimiter; field in EnvOptions
DDBOptions.java186 public DBOptions setRateLimiter(final RateLimiter rateLimiter) { in setRateLimiter() argument
188 rateLimiter_ = rateLimiter; in setRateLimiter()
189 setRateLimiter(nativeHandle_, rateLimiter.nativeHandle_); in setRateLimiter()
DDBOptionsInterface.java158 T setRateLimiter(RateLimiter rateLimiter); in setRateLimiter() argument
DOptions.java1211 public Options setRateLimiter(final RateLimiter rateLimiter) { in setRateLimiter() argument
1213 rateLimiter_ = rateLimiter; in setRateLimiter()
1214 setRateLimiter(nativeHandle_, rateLimiter.nativeHandle_); in setRateLimiter()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java35 final RateLimiter rateLimiter = new RateLimiter(10000000,10000, 10)) { in main()
87 options.setRateLimiter(rateLimiter); in main()