Skip to content

Attach TransactionID in Net Core logs #94

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
kbond-stackify merged 7 commits into from
Mar 6, 2020
Merged

Attach TransactionID in Net Core logs #94

Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
554f77c
get stackify.agent callcontext via reflection
rakista112 Jan 23, 2020
ae92b3c
- get RequestID via reflection and put in msg.TransID
rakista112 Jan 24, 2020
7a3b0b2
Get types without LINQ extensions
rakista112 Jan 24, 2020
31cd5ea
- check everything if null
rakista112 Jan 27, 2020
c4b0c9d
-check RequestId property and the value before turning it into a string
rakista112 Jan 27, 2020
29b9d00
- make code more concise with coalesce chains
rakista112 Jan 28, 2020
9e5cf98
- remove unused variable
rakista112 Jan 28, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 32 additions & 0 deletions Src/StackifyLib/Internal/Logs/LogQueue.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,10 @@
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;

#if NETFULL
Expand Down Expand Up @@ -99,6 +102,7 @@ public void QueueLogMessage(Models.LogMsg msg)
// ignore
}


#if NETFULL
try
{
Expand Down Expand Up @@ -177,6 +181,34 @@ public void QueueLogMessage(Models.LogMsg msg)
}
}
}
#else
// else if .Net Core
// get RequestID
if (string.IsNullOrEmpty(msg.TransID))
{
var assemblies = AppDomain.CurrentDomain.GetAssemblies();

var agentAssemblyQry = assemblies.Where(assembly => assembly.FullName.Contains("Stackify.Agent"));
if(agentAssemblyQry.Count() > 0)
{
var middleware = agentAssemblyQry.First();
var callContextType = middleware.GetType("Stackify.Agent.Threading.StackifyCallContext");
if (callContextType != null)
{
var traceCtxType = middleware.GetType("Stackify.Agent.Tracing.ITraceContext");
if(traceCtxType != null)
{
var traceContextProp = callContextType.GetProperty("TraceContext")?.GetValue(null);
if (traceContextProp != null)
{
var reqIdProp = traceCtxType.GetProperty("RequestId")?.GetValue(traceContextProp)?.ToString();
if(!string.IsNullOrEmpty(reqIdProp))
msg.TransID = reqIdProp;
}
}
}
}
}
#endif

_MessageBuffer.Enqueue(msg);
Expand Down