mirror of
https://github.com/corda/corda.git
synced 2025-05-03 17:23:03 +00:00
[CORDA-1809]: Some improvements in logging context information. (#3755)
This commit is contained in:
parent
0c7e0f6dbb
commit
59dd39b069
@ -1,28 +1,42 @@
|
|||||||
package net.corda.node.services.logging
|
package net.corda.node.services.logging
|
||||||
|
|
||||||
|
import net.corda.core.context.Actor
|
||||||
import net.corda.core.context.InvocationContext
|
import net.corda.core.context.InvocationContext
|
||||||
|
import net.corda.core.context.InvocationOrigin
|
||||||
|
import net.corda.core.context.Trace
|
||||||
import org.slf4j.MDC
|
import org.slf4j.MDC
|
||||||
|
|
||||||
internal fun InvocationContext.pushToLoggingContext() {
|
internal fun InvocationContext.pushToLoggingContext() {
|
||||||
|
|
||||||
MDC.put("invocation_id", trace.invocationId.value)
|
trace.pushToLoggingContext()
|
||||||
MDC.put("invocation_timestamp", trace.invocationId.timestamp.toString())
|
actor?.pushToLoggingContext()
|
||||||
MDC.put("session_id", trace.sessionId.value)
|
origin.pushToLoggingContext()
|
||||||
MDC.put("session_timestamp", trace.sessionId.timestamp.toString())
|
externalTrace?.pushToLoggingContext("external_")
|
||||||
actor?.let {
|
impersonatedActor?.pushToLoggingContext("impersonating_")
|
||||||
MDC.put("actor_id", it.id.value)
|
}
|
||||||
MDC.put("actor_store_id", it.serviceId.value)
|
|
||||||
MDC.put("actor_owningIdentity", it.owningLegalIdentity.toString())
|
internal fun Trace.pushToLoggingContext(prefix: String = "") {
|
||||||
}
|
|
||||||
externalTrace?.let {
|
MDC.getMDCAdapter().apply {
|
||||||
MDC.put("external_invocation_id", it.invocationId.value)
|
put("${prefix}invocation_id", invocationId.value)
|
||||||
MDC.put("external_invocation_timestamp", it.invocationId.timestamp.toString())
|
put("${prefix}invocation_timestamp", invocationId.timestamp.toString())
|
||||||
MDC.put("external_session_id", it.sessionId.value)
|
put("${prefix}session_id", sessionId.value)
|
||||||
MDC.put("external_session_timestamp", it.sessionId.timestamp.toString())
|
put("${prefix}session_timestamp", sessionId.timestamp.toString())
|
||||||
}
|
}
|
||||||
impersonatedActor?.let {
|
}
|
||||||
MDC.put("impersonating_actor_id", it.id.value)
|
|
||||||
MDC.put("impersonating_actor_store_id", it.serviceId.value)
|
internal fun Actor.pushToLoggingContext(prefix: String = "") {
|
||||||
MDC.put("impersonating_actor_owningIdentity", it.owningLegalIdentity.toString())
|
|
||||||
|
MDC.getMDCAdapter().apply {
|
||||||
|
put("${prefix}actor_id", id.value)
|
||||||
|
put("${prefix}actor_store_id", serviceId.value)
|
||||||
|
put("${prefix}actor_owning_identity", owningLegalIdentity.toString())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
internal fun InvocationOrigin.pushToLoggingContext(prefix: String = "") {
|
||||||
|
|
||||||
|
MDC.getMDCAdapter().apply {
|
||||||
|
put("${prefix}origin", principal().name)
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
x
Reference in New Issue
Block a user