File tree Expand file tree Collapse file tree
module/spring-boot-micrometer-metrics/src
main/java/org/springframework/boot/micrometer/metrics/autoconfigure/export/otlp
test/java/org/springframework/boot/micrometer/metrics/autoconfigure/export/otlp
platform/spring-boot-dependencies Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -40,6 +40,7 @@ subprojects {
4040 }
4141 }
4242 spring. mavenRepositories()
43+ maven { url = ' https://repo.spring.io/snapshot' }
4344 }
4445
4546 configurations. all {
Original file line number Diff line number Diff line change 2121import java .util .concurrent .TimeUnit ;
2222
2323import io .micrometer .registry .otlp .AggregationTemporality ;
24+ import io .micrometer .registry .otlp .CompressionMode ;
2425import io .micrometer .registry .otlp .HistogramFlavor ;
2526import org .jspecify .annotations .Nullable ;
2627
@@ -49,6 +50,11 @@ public class OtlpMetricsProperties extends StepRegistryProperties {
4950 */
5051 private AggregationTemporality aggregationTemporality = AggregationTemporality .CUMULATIVE ;
5152
53+ /**
54+ * Compression mode for metric data sender.
55+ */
56+ private CompressionMode compressionMode = CompressionMode .NONE ;
57+
5258 /**
5359 * Headers for the exported metrics.
5460 */
@@ -96,6 +102,14 @@ public void setAggregationTemporality(AggregationTemporality aggregationTemporal
96102 this .aggregationTemporality = aggregationTemporality ;
97103 }
98104
105+ public CompressionMode getCompressionMode () {
106+ return this .compressionMode ;
107+ }
108+
109+ public void setCompressionMode (CompressionMode compressionMode ) {
110+ this .compressionMode = compressionMode ;
111+ }
112+
99113 public @ Nullable Map <String , String > getHeaders () {
100114 return this .headers ;
101115 }
Original file line number Diff line number Diff line change 2222import java .util .concurrent .TimeUnit ;
2323
2424import io .micrometer .registry .otlp .AggregationTemporality ;
25+ import io .micrometer .registry .otlp .CompressionMode ;
2526import io .micrometer .registry .otlp .HistogramFlavor ;
2627import io .micrometer .registry .otlp .OtlpConfig ;
2728
@@ -72,6 +73,11 @@ public AggregationTemporality aggregationTemporality() {
7273 return obtain (OtlpMetricsProperties ::getAggregationTemporality , OtlpConfig .super ::aggregationTemporality );
7374 }
7475
76+ @ Override
77+ public CompressionMode compressionMode () {
78+ return obtain (OtlpMetricsProperties ::getCompressionMode , OtlpConfig .super ::compressionMode );
79+ }
80+
7581 @ Override
7682 public Map <String , String > resourceAttributes () {
7783 Map <String , String > resourceAttributes = new LinkedHashMap <>();
Original file line number Diff line number Diff line change 2020import java .util .concurrent .TimeUnit ;
2121
2222import io .micrometer .registry .otlp .AggregationTemporality ;
23+ import io .micrometer .registry .otlp .CompressionMode ;
2324import io .micrometer .registry .otlp .HistogramFlavor ;
2425import org .junit .jupiter .api .BeforeEach ;
2526import org .junit .jupiter .api .Test ;
@@ -88,6 +89,17 @@ void whenPropertiesAggregationTemporalityIsSetAdapterAggregationTemporalityRetur
8889 assertThat (createAdapter ().aggregationTemporality ()).isSameAs (AggregationTemporality .DELTA );
8990 }
9091
92+ @ Test
93+ void whenPropertiesCompressionModeIsNotSetAdapterCompressionModeReturnsNone () {
94+ assertThat (createAdapter ().compressionMode ()).isSameAs (CompressionMode .NONE );
95+ }
96+
97+ @ Test
98+ void whenPropertiesCompressionModeIsSetAdapterCompressionModeReturnsIt () {
99+ this .properties .setCompressionMode (CompressionMode .GZIP );
100+ assertThat (createAdapter ().compressionMode ()).isSameAs (CompressionMode .GZIP );
101+ }
102+
91103 @ Test
92104 void whenOpenTelemetryPropertiesResourceAttributesIsSetAdapterResourceAttributesReturnsIt () {
93105 this .openTelemetryProperties .setResourceAttributes (Map .of ("service.name" , "boot-service" ));
Original file line number Diff line number Diff line change @@ -36,6 +36,7 @@ void defaultValuesAreConsistent() {
3636 OtlpConfig config = OtlpConfig .DEFAULT ;
3737 assertStepRegistryDefaultValues (properties , config );
3838 assertThat (properties .getAggregationTemporality ()).isSameAs (config .aggregationTemporality ());
39+ assertThat (properties .getCompressionMode ()).isSameAs (config .compressionMode ());
3940 assertThat (properties .getHistogramFlavor ()).isSameAs (config .histogramFlavor ());
4041 assertThat (properties .getMaxScale ()).isEqualTo (config .maxScale ());
4142 assertThat (properties .getMaxBucketCount ()).isEqualTo (config .maxBucketCount ());
Original file line number Diff line number Diff line change @@ -1537,7 +1537,7 @@ bom {
15371537 releaseNotes(" https://github.com/apache/maven-war-plugin/releases/tag/maven-war-plugin-{version}" )
15381538 }
15391539 }
1540- library(" Micrometer" , " 1.17.0-M1 " ) {
1540+ library(" Micrometer" , " 1.17.0-SNAPSHOT " ) {
15411541 considerSnapshots()
15421542 group(" io.micrometer" ) {
15431543 modules = [
You can’t perform that action at this time.
0 commit comments