apitech
/
Jitsi-Prometheus-Exporter
mirror of https://github.com/engesin/Jitsi-Prometheus-Exporter
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

new metrics added to JPE!! Suitable with stable/Jitsi-5076 version!

Browse Source 
+ Stress_level
+ dtls_failed_endpoints
-  videostreams
feture/jpe-5076
ENGIN ESIN 5 years ago
parent 12f0827f30
commit 608ca78769
4 changed files with 68 additions and 65 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 2
      pom.xml
  2. 3
      src/main/java/com/ttech/jpe/metric/prometheus/type/GaugeMetric.java
  3. 3
      src/main/java/com/ttech/jpe/service/mapper/JvbPromExporter.java
  4. 125
      src/main/java/com/ttech/jpe/types/statTypes/JvbStats.java

2
pom.xml
Unescape View File

@ -10,7 +10,7 @@
</parent>
<groupId>com.ttech</groupId>
<artifactId>jpe</artifactId>
<version>0.0.4-SNAPSHOT</version>
<version>0.0.5-SNAPSHOT</version>
<name>jpe</name>
<description>Jitsi Prometheus Exporter</description>

3
src/main/java/com/ttech/jpe/metric/prometheus/type/GaugeMetric.java
Unescape View File

@ -32,7 +32,7 @@ public enum GaugeMetric implements IMetric {
JITSI_JVB_ENDPOINTS_SENDING_VIDEO("jitsi_jvb_endpoints_sending_video", "jitsi_jvb_endpoints_sending_video", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_PACKET_RATE_DOWNLOAD("jitsi_jvb_packet_rate_download", "jitsi_jvb_packet_rate_download", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_MUC_CLIENTS_CONFIGURED("jitsi_jvb_muc_clients_configured", "jitsi_jvb_muc_clients_configured", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_VIDEOSTREAMS("jitsi_jvb_videostreams", "jitsi_jvb_videostreams", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_STRESS_LEVEL("jitsi_jvb_stress_level", "jitsi_jvb_stress_level", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_JITTER_AGGREGATE("jitsi_jvb_jitter_aggregate", "jitsi_jvb_jitter_aggregate", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_OCTO_ENDPOINTS("jitsi_jvb_octo_endpoints", "jitsi_jvb_octo_endpoints", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_CURRENT_TIMESTAMP("jitsi_jvb_current_timestamp", "jitsi_jvb_current_timestamp", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
@ -45,6 +45,7 @@ public enum GaugeMetric implements IMetric {
JITSI_JVB_OCTO_RECEIVE_PACKET_RATE("jitsi_jvb_octo_receive_packet_rate", "jitsi_jvb_octo_receive_packet_rate", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_RTP_LOSS("jitsi_jvb_rtp_loss", "jitsi_jvb_rtp_loss", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_ENDPOINTS_SENDING_AUDIO("jitsi_jvb_endpoints_sending_audio", "jitsi_jvb_endpoints_sending_audio", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_DTLS_FAILED_ENDPOINTS("jitsi_jvb_dtls_failed_endpoints", "jitsi_jvb_dtls_failed_endpoints", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_MUCS_CONFIGURED("jitsi_jvb_mucs_configured", "jitsi_jvb_mucs_configured", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),
JITSI_JVB_MUCS_JOINED("jitsi_jvb_mucs_joined", "jitsi_jvb_mucs_joined", MetricLabels.getCommaSeperated(MetricLabels.Names.host)),

3
src/main/java/com/ttech/jpe/service/mapper/JvbPromExporter.java
Unescape View File

@ -111,7 +111,7 @@ public class JvbPromExporter extends PromExporterAbstract<JvbStats> {
metricsRegistry.observe(GaugeMetric.JITSI_JVB_ENDPOINTS_SENDING_VIDEO, jvbStats.getEndpoints_sending_video(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_PACKET_RATE_DOWNLOAD, jvbStats.getPacket_rate_download(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_MUC_CLIENTS_CONFIGURED, jvbStats.getMuc_clients_configured(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_VIDEOSTREAMS, jvbStats.getVideostreams(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_STRESS_LEVEL, jvbStats.getStress_level(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_JITTER_AGGREGATE, jvbStats.getJitter_aggregate(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_OCTO_ENDPOINTS, jvbStats.getOcto_endpoints(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_CONFERENCES, jvbStats.getConferences(), jvbStats.getHost());
@ -123,6 +123,7 @@ public class JvbPromExporter extends PromExporterAbstract<JvbStats> {
metricsRegistry.observe(GaugeMetric.JITSI_JVB_OCTO_RECEIVE_PACKET_RATE, jvbStats.getOcto_receive_packet_rate(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_RTP_LOSS, jvbStats.getRtp_loss(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_ENDPOINTS_SENDING_AUDIO, jvbStats.getEndpoints_sending_audio(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_DTLS_FAILED_ENDPOINTS, jvbStats.getDtls_failed_endpoints(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_MUCS_CONFIGURED, jvbStats.getMucs_configured(), jvbStats.getHost());
metricsRegistry.observe(GaugeMetric.JITSI_JVB_MUCS_JOINED, jvbStats.getMucs_joined(), jvbStats.getHost());

125
src/main/java/com/ttech/jpe/types/statTypes/JvbStats.java
Unescape View File

@ -16,71 +16,72 @@ public class JvbStats {
private String host = "";
private boolean health = false;
private long inactive_endpoints = 0L;
private long inactive_conferences = 0L;
private long total_ice_succeeded_relayed = 0L;
private long total_loss_degraded_participant_seconds = 0L;
private long bit_rate_download = 0L;
private long muc_clients_connected = 0L;
private long total_participants = 0L;
private long total_packets_received = 0L;
private long rtt_aggregate = 0L;
private long packet_rate_upload = 0L;
private long p2p_conferences = 0L;
private long total_loss_limited_participant_seconds = 0L;
private long octo_send_bitrate = 0L;
private long total_dominant_speaker_changes = 0L;
private long receive_only_endpoints = 0L;
private long total_colibri_web_socket_messages_received = 0L;
private long octo_receive_bitrate = 0L;
private long loss_rate_upload = 0L;
private String version = "";
private long total_ice_succeeded = 0L;
private long total_colibri_web_socket_messages_sent = 0L;
private long total_bytes_sent_octo = 0L;
private long total_data_channel_messages_received = 0L;
private long loss_rate_download = 0L;
private long total_conference_seconds = 0L;
private long bit_rate_upload = 0L;
private long total_conferences_completed = 0L;
private long octo_conferences = 0L;
private long num_eps_no_msg_transport_after_delay = 0L;
private long endpoints_sending_video = 0L;
private long packet_rate_download = 0L;
private long muc_clients_configured = 0L;
private long inactive_endpoints;
private long inactive_conferences;
private long total_ice_succeeded_relayed;
private long total_loss_degraded_participant_seconds;
private long bit_rate_download;
private long muc_clients_connected;
private long total_participants;
private long total_packets_received;
private double rtt_aggregate;
private long packet_rate_upload;
private long p2p_conferences;
private long total_loss_limited_participant_seconds;
private long octo_send_bitrate;
private long total_dominant_speaker_changes;
private long receive_only_endpoints;
private long total_colibri_web_socket_messages_received;
private long octo_receive_bitrate;
private double loss_rate_upload;
private String version;
private long total_ice_succeeded;
private long total_colibri_web_socket_messages_sent;
private long total_bytes_sent_octo;
private long total_data_channel_messages_received;
private double loss_rate_download;
private long total_conference_seconds;
private long bit_rate_upload;
private long total_conferences_completed;
private long octo_conferences;
private long num_eps_no_msg_transport_after_delay;
private long endpoints_sending_video;
private long packet_rate_download;
private long muc_clients_configured;
private List<Integer> conference_sizes = new ArrayList<>(Collections.nCopies(22, 0));
private long total_packets_sent_octo = 0L;
private long total_packets_sent_octo;
private List<Integer> conferences_by_video_senders = new ArrayList<>(Collections.nCopies(22, 0));
private long videostreams = 0L;
private long jitter_aggregate = 0L;
private long total_ice_succeeded_tcp = 0L;
private long octo_endpoints = 0L;
private String current_timestamp = "";
private long total_packets_dropped_octo = 0L;
private long conferences = 0L;
private long participants = 0L;
private long largest_conference = 0L;
private long total_packets_sent = 0L;
private long total_data_channel_messages_sent = 0L;
private long total_bytes_received_octo = 0L;
private long octo_send_packet_rate = 0L;
private double stress_level;
private double jitter_aggregate;
private long total_ice_succeeded_tcp;
private long octo_endpoints;
private String current_timestamp;
private long total_packets_dropped_octo;
private long conferences;
private long participants;
private long largest_conference;
private long total_packets_sent;
private long total_data_channel_messages_sent;
private long total_bytes_received_octo;
private long octo_send_packet_rate;
private List<Integer> conferences_by_audio_senders = new ArrayList<>(Collections.nCopies(22, 0));
private long total_conferences_created = 0L;
private long total_ice_failed = 0L;
private long threads = 0L;
private long videochannels = 0L;
private long total_packets_received_octo = 0L;
private boolean graceful_shutdown = false;
private long octo_receive_packet_rate = 0L;
private long total_bytes_received = 0L;
private long rtp_loss = 0L;
private long total_loss_controlled_participant_seconds = 0L;
private long total_partially_failed_conferences = 0L;
private long endpoints_sending_audio = 0L;
private long total_bytes_sent = 0L;
private long mucs_configured = 0L;
private long total_failed_conferences = 0L;
private long mucs_joined = 0L;
private long total_conferences_created;
private long total_ice_failed;
private long threads;
private long videochannels;
private long total_packets_received_octo;
private boolean graceful_shutdown;
private long octo_receive_packet_rate;
private long total_bytes_received;
private double rtp_loss;
private long total_loss_controlled_participant_seconds;
private long total_partially_failed_conferences;
private long endpoints_sending_audio;
private long dtls_failed_endpoints;
private long total_bytes_sent;
private long mucs_configured;
private long total_failed_conferences;
private long mucs_joined;
public void setConference_sizes(Object value) {

Write Preview
Loading…
Cancel
Save