Skip to content

Conversation

@ASKozienko
Copy link
Member

@ASKozienko ASKozienko commented Nov 1, 2018

This could be used to send stats to Grafana or a real time tool.

Here's an example of grafana dashboard.

dq110o3xcaebr4v

@makasim makasim changed the title Metrics Queue monitoring. Nov 1, 2018
@ASKozienko ASKozienko force-pushed the metrics branch 2 times, most recently from b2ca1ae to df11f07 Compare November 2, 2018 15:54

interface StatsStorage
{
public function pushConsumerStats(ConsumerStats $event): void;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

add a method to track send messages stats.

@makasim
Copy link
Member

makasim commented Nov 6, 2018

@ASKozienko some additions

  • ConsumeMessageStats should have a redelivered field
  • SentMessageStats should have messageId field (could be null)
  • SentMessageStats should have correlationId field (could be null)
  • Could you add Client extension to track sent messages.

@makasim
Copy link
Member

makasim commented Nov 7, 2018

MessageStats obj should allow setting exception details too.

@makasim
Copy link
Member

makasim commented Nov 7, 2018

  • Splint Client Extension Interface, (look at Consumption Extension for reference).
  • Add StorageFactory (and interface) that accept string dsn and return monitoring storage, (for now you could hard code influxdb and wamp in the factory).

@makasim makasim merged commit 062f0a8 into master Nov 7, 2018
@makasim makasim deleted the metrics branch November 7, 2018 18:24
@makasim makasim added this to the 0.9 milestone Nov 15, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants