Comments (6)
Let me check with the customer and see if this matches what they're seeing
from phobos-issues.
Do we have any specs in Phobos for PubSub scenario? Or I will need to implement this? PubSub can be created between several nodes in same OS process, right? Just on different ports?
Did not work with that before, but will be happy to try it out 👍
from phobos-issues.
Do we have any specs in Phobos for PubSub scenario? Or I will need to implement this? PubSub can be created between several nodes in same OS process, right? Just on different ports?
We do not.
How I strongly recommend doing this:
- https://phobos.petabridge.com/articles/quickstart.html - follow the quickstart tutorial first, so you can see what Phobos metrics look like in a normal application
- https://github.com/petabridge/akkadotnet-cluster-workshop - try to update Phobos to 1.0.4 in this sample and see what the
DistributedPubSub
message metrics look like here. If they're weird or missing, that sample should help you work backwards to be able to create a reproducible unit test.
from phobos-issues.
Thanks!
from phobos-issues.
P.S. Latest version of phobos is 1.0.3 so far: https://sdkbin.com/publisher/petabridge/product/phobos
from phobos-issues.
@Aaronontheweb So, currently, I have added very simple DistriburedPubSub usage to Phobos.Web sample:
petabridge/Petabridge.Phobos.Web#18
I can see publish-subscribe trace:
And I can see published message info in akka_net_akka_messages_recv_total
metrics:
I seems like messages are captured by Phobos metrics. Does not look like messages are lost, nor locally nor between nodes.
from phobos-issues.
Related Issues (20)
- How to prevent incoming messages from forming an endless span hierarchy? HOT 7
- Serializer exception when using Phobos and Akka.Hosting HOT 16
- Custom span creation with Phobos 2.0.3-beta1 HOT 16
- Lots of noise in logging when using cluster sharding HOT 6
- Span is created for akka.actor.ask even when create-trace-upon-receive is set to off HOT 5
- UsableContext value becomes NULL in the middle of processing chain HOT 2
- Stashing message may result in reset UsableContext HOT 16
- Create a gauge for all alive actors of each type in any given `ActorSystem` HOT 1
- How to filter `Ask<T>` out of traces? HOT 6
- Manually created trace spans don't seem to flow across the cluster HOT 14
- When spans are created manually messages from cluster singleton break trace transactions HOT 19
- Does sending a message to sender from Persist/PersistAsync break trace transaction? HOT 10
- Can auto-generated shard messages be omitted from a trace transaction with manual span management? HOT 18
- Need to make all Akka.Cluster.Sharding infrastructure transparent in traces HOT 12
- Missing `unit` for all metrics received from Phobos in Prometheus HOT 16
- `Tracer.CurrentSpan` and `PhobosActorContext.ActiveSpan` should be the same when actor is processing message, but currently are not
- Add support for tracking Akka.Cluster.Sharding `ShardRegion` metrics HOT 1
- Phobos `DeadLetter` logging HOT 1
- `Ask<T>` tracing does not properly follow `Tracer.ActiveSpan` HOT 1
- Bug: System.InvalidOperationException: ValueFactory attempted to access the Value property of this instance.
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from phobos-issues.