asynkron / akka.opentelemetry Goto Github PK

Old thread from Akka.NET on this topic:
akkadotnet/akka.net#2027

This library uses a custom ActorRefProvider to allow decorating actors with middleware.
This works but is problematic in a few ways:

In Proto.Actor, messages can have headers, just like in HTTP etc.
Akka.NET does not have this. therefore I'm using an envelope type for the payload.
This means that when sending a message, we either need to know up front if the target actorref belongs to a tracable actor.
so that we don't send envelopes to non-traced actors.

Or, we just make it so that all local actors are decorated with the tracing middleware, and get around this issue that way.

Another issue is likely Akka.Remote, e.g. if a remote node does not have tracing enabled, then sending envelopes to those would fail.

Therefore, I think the naive but pragmatic way would be to enforce that all nodes in the Akka.NET system/cluster all have this extension enabled.

If someone has any other ideas, shoot

Ask<T> uses the FutureRef<T> which is sealed. making it hard to intercept Tell operations to it.
What is worse is that the methods on ActorRefProvider returns this concrete type directly with no option to wrap the ref.

I can intercept the completion of the task. but currently I don't quite know how I can set up the spans properly here