Additional observability related changes
This commit is contained in:
@@ -57,7 +57,7 @@ enum FunctionObservation implements DocumentedObservation {
|
|||||||
*/
|
*/
|
||||||
FUNCTION_NAME {
|
FUNCTION_NAME {
|
||||||
public String asString() {
|
public String asString() {
|
||||||
return "spring.cloud.function.name";
|
return "spring.cloud.function.definition";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -68,7 +68,6 @@ public class ObservationFunctionAroundWrapper extends FunctionAroundWrapper {
|
|||||||
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())
|
||||||
//.keyValuesProvider(tagsProvider)
|
|
||||||
.observe(() -> {
|
.observe(() -> {
|
||||||
Object r = message == null ? targetFunction.get() : targetFunction.apply(invocationMessage);
|
Object r = message == null ? targetFunction.get() : targetFunction.apply(invocationMessage);
|
||||||
context.setModifiedOutput(r);
|
context.setModifiedOutput(r);
|
||||||
|
|||||||
Reference in New Issue
Block a user