|
|
|
@ -18,7 +18,6 @@ package org.springframework.boot.actuate.autoconfigure.metrics.export.atlas; |
|
|
|
|
|
|
|
|
|
|
|
import java.time.Duration; |
|
|
|
import java.time.Duration; |
|
|
|
|
|
|
|
|
|
|
|
import org.springframework.boot.actuate.autoconfigure.metrics.export.properties.StepRegistryProperties; |
|
|
|
|
|
|
|
import org.springframework.boot.context.properties.ConfigurationProperties; |
|
|
|
import org.springframework.boot.context.properties.ConfigurationProperties; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
@ -30,13 +29,39 @@ import org.springframework.boot.context.properties.ConfigurationProperties; |
|
|
|
* @since 2.0.0 |
|
|
|
* @since 2.0.0 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
@ConfigurationProperties(prefix = "management.metrics.export.atlas") |
|
|
|
@ConfigurationProperties(prefix = "management.metrics.export.atlas") |
|
|
|
public class AtlasProperties extends StepRegistryProperties { |
|
|
|
public class AtlasProperties { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
|
|
* Step size (i.e. reporting frequency) to use. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
private Duration step = Duration.ofMinutes(1); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
|
|
* Whether exporting of metrics to this backend is enabled. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
private boolean enabled = true; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
|
|
* Connection timeout for requests to this backend. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
private Duration connectTimeout = Duration.ofSeconds(1); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
|
|
* Read timeout for requests to this backend. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
private Duration readTimeout = Duration.ofSeconds(10); |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
* Number of threads to use with the metrics publishing scheduler. |
|
|
|
* Number of threads to use with the metrics publishing scheduler. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
private Integer numThreads = 4; |
|
|
|
private Integer numThreads = 4; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
|
|
* Number of measurements per request to use for this backend. If more measurements |
|
|
|
|
|
|
|
* are found, then multiple requests will be made. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
private Integer batchSize = 10000; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
* URI of the Atlas server. |
|
|
|
* URI of the Atlas server. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
@ -73,16 +98,54 @@ public class AtlasProperties extends StepRegistryProperties { |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
private String evalUri = "http://localhost:7101/lwc/api/v1/evaluate"; |
|
|
|
private String evalUri = "http://localhost:7101/lwc/api/v1/evaluate"; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public Duration getStep() { |
|
|
|
|
|
|
|
return this.step; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setStep(Duration step) { |
|
|
|
|
|
|
|
this.step = step; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public boolean isEnabled() { |
|
|
|
|
|
|
|
return this.enabled; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setEnabled(boolean enabled) { |
|
|
|
|
|
|
|
this.enabled = enabled; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public Duration getConnectTimeout() { |
|
|
|
|
|
|
|
return this.connectTimeout; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setConnectTimeout(Duration connectTimeout) { |
|
|
|
|
|
|
|
this.connectTimeout = connectTimeout; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public Duration getReadTimeout() { |
|
|
|
|
|
|
|
return this.readTimeout; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setReadTimeout(Duration readTimeout) { |
|
|
|
|
|
|
|
this.readTimeout = readTimeout; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Integer getNumThreads() { |
|
|
|
public Integer getNumThreads() { |
|
|
|
return this.numThreads; |
|
|
|
return this.numThreads; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
|
|
public void setNumThreads(Integer numThreads) { |
|
|
|
public void setNumThreads(Integer numThreads) { |
|
|
|
this.numThreads = numThreads; |
|
|
|
this.numThreads = numThreads; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public Integer getBatchSize() { |
|
|
|
|
|
|
|
return this.batchSize; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setBatchSize(Integer batchSize) { |
|
|
|
|
|
|
|
this.batchSize = batchSize; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public String getUri() { |
|
|
|
public String getUri() { |
|
|
|
return this.uri; |
|
|
|
return this.uri; |
|
|
|
} |
|
|
|
} |
|
|
|
|