2263621768

Build Type

push

github

Committed by Lukas Holecek

Commit Message

Add stomp consumers

Run Details

547 of 664 branches covered (82.38%)

Branch coverage included in aggregate %.

251 of 261 new or added lines in 5 files covered. (96.17%)

4 existing lines in 2 files now uncovered.

1715 of 1989 relevant lines covered (86.22%)

0.86 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

84.38

/greenwave/monitor.py

# SPDX-License-Identifier: GPL-2.0+

# For an up-to-date version of this module, see:
#   https://pagure.io/monitor-flask-sqlalchemy

import os
import tempfile

from flask import Blueprint, Response
from prometheus_client import (  # noqa: F401
    ProcessCollector, CollectorRegistry, Counter, multiprocess,
    Histogram, generate_latest, start_http_server, CONTENT_TYPE_LATEST)

# Service-specific imports


if not os.environ.get('prometheus_multiproc_dir'):
    os.environ.setdefault('prometheus_multiproc_dir', tempfile.mkdtemp())
registry = CollectorRegistry()
ProcessCollector(registry=registry)
multiprocess.MultiProcessCollector(registry)
if os.getenv('MONITOR_STANDALONE_METRICS_SERVER_ENABLE', 'false') == 'true':
    port = os.getenv('MONITOR_STANDALONE_METRICS_SERVER_PORT', '10040')
    start_http_server(int(port), registry=registry)


# Generic metrics
messaging_rx_counter = Counter(
    'messaging_rx',
    'Total number of messages received',
    labelnames=['handler'],
    registry=registry)
messaging_rx_ignored_counter = Counter(
    'messaging_rx_ignored',
    'Number of received messages, which were ignored',
    labelnames=['handler'],
    registry=registry)
messaging_rx_processed_ok_counter = Counter(
    'messaging_rx_processed_ok',
    'Number of received messages, which were processed successfully',
    labelnames=['handler'],
    registry=registry)
messaging_rx_failed_counter = Counter(
    'messaging_rx_failed',
    'Number of received messages, which failed during processing',
    labelnames=['handler'],
    registry=registry)

messaging_tx_to_send_counter = Counter(
    'messaging_tx_to_send',
    'Total number of messages to send',
    labelnames=['handler'],
    registry=registry)
messaging_tx_stopped_counter = Counter(
    'messaging_tx_stopped',
    'Number of messages, which were eventually stopped before sending',
    labelnames=['handler'],
    registry=registry)
messaging_tx_sent_ok_counter = Counter(
    'messaging_tx_sent_ok',
    'Number of messages, which were sent successfully',
    labelnames=['handler'],
    registry=registry)
messaging_tx_failed_counter = Counter(
    'messaging_tx_failed',
    'Number of messages, for which the sender failed',
    labelnames=['handler'],
    registry=registry)

# Service-specific metrics
# https://github.com/prometheus/client_python/issues/210
# pylint: disable-msg=unexpected-keyword-arg,no-value-for-parameter
decision_exception_counter = Counter(
    'total_decision_exceptions',
    'All exceptions occurred in Greenwave "decision" API',
    registry=registry)
decision_request_duration_seconds = Histogram(
    'decision_request_duration_seconds',
    'Decision latency',
    registry=registry)
publish_decision_exceptions_waiver_counter = Counter(
    'publish_decision_exceptions_new_waiver',
    'All exceptions occurred in publishing a message after a new waiver',
    registry=registry)
publish_decision_exceptions_result_counter = Counter(
    'publish_decision_exceptions_new_result',
    'All exceptions occurred in publishing a message after a new result',
    registry=registry)


monitor_api = Blueprint(
    'monitor', __name__,
    url_prefix='')


@monitor_api.route('/metrics')
def metrics():
    return Response(generate_latest(registry),
                    content_type=CONTENT_TYPE_LATEST)

1	# SPDX-License-Identifier: GPL-2.0+
2
3	# For an up-to-date version of this module, see:
4	# https://pagure.io/monitor-flask-sqlalchemy
5
6	import os	1✔
7	import tempfile	1✔
8
9	from flask import Blueprint, Response	1✔
10	from prometheus_client import ( # noqa: F401	1✔
11	ProcessCollector, CollectorRegistry, Counter, multiprocess,
12	Histogram, generate_latest, start_http_server, CONTENT_TYPE_LATEST)
13
14	# Service-specific imports
15
16
17	if not os.environ.get('prometheus_multiproc_dir'):	1!
18	os.environ.setdefault('prometheus_multiproc_dir', tempfile.mkdtemp())	1✔
19	registry = CollectorRegistry()	1✔
20	ProcessCollector(registry=registry)	1✔
21	multiprocess.MultiProcessCollector(registry)	1✔
22	if os.getenv('MONITOR_STANDALONE_METRICS_SERVER_ENABLE', 'false') == 'true':	1!
23	port = os.getenv('MONITOR_STANDALONE_METRICS_SERVER_PORT', '10040')	×
24	start_http_server(int(port), registry=registry)	×
25
26
27	# Generic metrics
28	messaging_rx_counter = Counter(	1✔
29	'messaging_rx',
30	'Total number of messages received',
31	labelnames=['handler'],
32	registry=registry)
33	messaging_rx_ignored_counter = Counter(	1✔
34	'messaging_rx_ignored',
35	'Number of received messages, which were ignored',
36	labelnames=['handler'],
37	registry=registry)
38	messaging_rx_processed_ok_counter = Counter(	1✔
39	'messaging_rx_processed_ok',
40	'Number of received messages, which were processed successfully',
41	labelnames=['handler'],
42	registry=registry)
43	messaging_rx_failed_counter = Counter(	1✔
44	'messaging_rx_failed',
45	'Number of received messages, which failed during processing',
46	labelnames=['handler'],
47	registry=registry)
48
49	messaging_tx_to_send_counter = Counter(	1✔
50	'messaging_tx_to_send',
51	'Total number of messages to send',
52	labelnames=['handler'],
53	registry=registry)
54	messaging_tx_stopped_counter = Counter(	1✔
55	'messaging_tx_stopped',
56	'Number of messages, which were eventually stopped before sending',
57	labelnames=['handler'],
58	registry=registry)
59	messaging_tx_sent_ok_counter = Counter(	1✔
60	'messaging_tx_sent_ok',
61	'Number of messages, which were sent successfully',
62	labelnames=['handler'],
63	registry=registry)
64	messaging_tx_failed_counter = Counter(	1✔
65	'messaging_tx_failed',
66	'Number of messages, for which the sender failed',
67	labelnames=['handler'],
68	registry=registry)
69
70	# Service-specific metrics
71	# https://github.com/prometheus/client_python/issues/210
72	# pylint: disable-msg=unexpected-keyword-arg,no-value-for-parameter
73	decision_exception_counter = Counter(	1✔
74	'total_decision_exceptions',
75	'All exceptions occurred in Greenwave "decision" API',
76	registry=registry)
77	decision_request_duration_seconds = Histogram(	1✔
78	'decision_request_duration_seconds',
79	'Decision latency',
80	registry=registry)
81	publish_decision_exceptions_waiver_counter = Counter(	1✔
82	'publish_decision_exceptions_new_waiver',
83	'All exceptions occurred in publishing a message after a new waiver',
84	registry=registry)
85	publish_decision_exceptions_result_counter = Counter(	1✔
86	'publish_decision_exceptions_new_result',
87	'All exceptions occurred in publishing a message after a new result',
88	registry=registry)
89
90
91	monitor_api = Blueprint(	1✔
92	'monitor', __name__,
93	url_prefix='')
94
95
96	@monitor_api.route('/metrics')	1✔
97	def metrics():	1✔
UNCOV 98	return Response(generate_latest(registry),	×
99	content_type=CONTENT_TYPE_LATEST)

release-engineering / greenwave / 2263621768

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous