Make Micrometer batch size configurable.
This commit is contained in:
parent
68150b640e
commit
251e1b51c5
|
@ -231,6 +231,11 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
|
||||||
public String uri() {
|
public String uri() {
|
||||||
return config.getMicrometerConfiguration().getUri();
|
return config.getMicrometerConfiguration().getUri();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int batchSize() {
|
||||||
|
return config.getMicrometerConfiguration().getBatchSize();
|
||||||
|
}
|
||||||
}, Clock.SYSTEM) {
|
}, Clock.SYSTEM) {
|
||||||
@Override
|
@Override
|
||||||
protected DistributionStatisticConfig defaultHistogramConfig() {
|
protected DistributionStatisticConfig defaultHistogramConfig() {
|
||||||
|
|
|
@ -8,13 +8,22 @@ package org.whispersystems.textsecuregcm.configuration;
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
|
||||||
import javax.validation.constraints.NotEmpty;
|
import javax.validation.constraints.NotEmpty;
|
||||||
|
import javax.validation.constraints.Positive;
|
||||||
|
|
||||||
public class MicrometerConfiguration {
|
public class MicrometerConfiguration {
|
||||||
|
|
||||||
@JsonProperty
|
@JsonProperty
|
||||||
private String uri;
|
private String uri;
|
||||||
|
|
||||||
|
@JsonProperty
|
||||||
|
@Positive
|
||||||
|
private int batchSize = 10_000;
|
||||||
|
|
||||||
public String getUri() {
|
public String getUri() {
|
||||||
return uri;
|
return uri;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public int getBatchSize() {
|
||||||
|
return batchSize;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue