SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adjust code and POM to accomodate for micrometer/observability changes

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-10-11 16:08:45 +02:00
parent 7a280f9399
commit 4a58eb75ef
3 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pom.xml
View File

@@ -29,6 +29,14 @@
</maven-checkstyle-plugin.includeTestSourceDirectory> </maven-checkstyle-plugin.includeTestSourceDirectory>
</properties> </properties>
<dependencies>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>context-propagation</artifactId>
<version>1.0.0-RC1</version>
</dependency>
</dependencies>
<dependencyManagement> <dependencyManagement>
<dependencies> <dependencies>
<dependency> <dependency>

4
spring-cloud-function-observability/src/main/java/org/springframework/cloud/function/observability/FunctionObservation.java
View File

@@ -17,14 +17,14 @@
package org.springframework.cloud.function.observability; package org.springframework.cloud.function.observability;
import io.micrometer.common.docs.KeyName; import io.micrometer.common.docs.KeyName;
import io.micrometer.observation.docs.DocumentedObservation; import io.micrometer.observation.docs.ObservationDocumentation;
/** /**
* @author Marcin Grzejszczak * @author Marcin Grzejszczak
* @author Oleg Zhurakousky * @author Oleg Zhurakousky
* @since 4.0.0 * @since 4.0.0
*/ */
enum FunctionObservation implements DocumentedObservation { enum FunctionObservation implements ObservationDocumentation {
/** /**
* Observation created around a function execution. * Observation created around a function execution.
*/ */

2
spring-cloud-function-observability/src/main/java/org/springframework/cloud/function/observability/ObservationFunctionAroundWrapper.java
View File

@@ -66,7 +66,7 @@ public class ObservationFunctionAroundWrapper extends FunctionAroundWrapper {
FunctionContext context = new FunctionContext(targetFunction).withInput(message); FunctionContext context = new FunctionContext(targetFunction).withInput(message);
Object invocationMessage = context.getModifiedInput(); Object invocationMessage = context.getModifiedInput();
Object result = Observation Object result = Observation
.createNotStarted(FunctionObservation.FUNCTION_OBSERVATION.getName(), context, this.observationRegistry) .createNotStarted(FunctionObservation.FUNCTION_OBSERVATION.getName(), () -> context, this.observationRegistry)
.contextualName(FunctionObservation.FUNCTION_OBSERVATION.getContextualName()) .contextualName(FunctionObservation.FUNCTION_OBSERVATION.getContextualName())
.observe(() -> { .observe(() -> {
Object r = message == null ? targetFunction.get() : targetFunction.apply(invocationMessage); Object r = message == null ? targetFunction.get() : targetFunction.apply(invocationMessage);