2259617033

Build Type

github

Committed by GitHub

Commit Message

Merge aa6723918 into 0b55d99b7

Pull Request Pull Request #10: Add stomp consumers

Run Details

539 of 664 branches covered (81.17%)

Branch coverage included in aggregate %.

215 of 261 new or added lines in 5 files covered. (82.38%)

1 existing line in 1 file now uncovered.

1679 of 1989 relevant lines covered (84.41%)

0.84 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',
    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	registry=registry)
37	messaging_rx_processed_ok_counter = Counter(	1✔
38	'messaging_rx_processed_ok',
39	'Number of received messages, which were processed successfully',
40	labelnames=['handler'],
41	registry=registry)
42	messaging_rx_failed_counter = Counter(	1✔
43	'messaging_rx_failed',
44	'Number of received messages, which failed during processing',
45	labelnames=['handler'],
46	registry=registry)
47
48	messaging_tx_to_send_counter = Counter(	1✔
49	'messaging_tx_to_send',
50	'Total number of messages to send',
51	labelnames=['handler'],
52	registry=registry)
53	messaging_tx_stopped_counter = Counter(	1✔
54	'messaging_tx_stopped',
55	'Number of messages, which were eventually stopped before sending',
56	labelnames=['handler'],
57	registry=registry)
58	messaging_tx_sent_ok_counter = Counter(	1✔
59	'messaging_tx_sent_ok',
60	'Number of messages, which were sent successfully',
61	labelnames=['handler'],
62	registry=registry)
63	messaging_tx_failed_counter = Counter(	1✔
64	'messaging_tx_failed',
65	'Number of messages, for which the sender failed',
66	labelnames=['handler'],
67	registry=registry)
68
69	# Service-specific metrics
70	# https://github.com/prometheus/client_python/issues/210
71	# pylint: disable-msg=unexpected-keyword-arg,no-value-for-parameter
72	decision_exception_counter = Counter(	1✔
73	'total_decision_exceptions',
74	'All exceptions occurred in Greenwave "decision" API',
75	registry=registry)
76	decision_request_duration_seconds = Histogram(	1✔
77	'decision_request_duration_seconds',
78	'Decision latency',
79	registry=registry)
80	publish_decision_exceptions_waiver_counter = Counter(	1✔
81	'publish_decision_exceptions_new_waiver',
82	'All exceptions occurred in publishing a message after a new waiver',
83	registry=registry)
84	publish_decision_exceptions_result_counter = Counter(	1✔
85	'publish_decision_exceptions_new_result',
86	'All exceptions occurred in publishing a message after a new result',
87	registry=registry)
88
89
90	monitor_api = Blueprint(	1✔
91	'monitor', __name__,
92	url_prefix='')
93
94
95	@monitor_api.route('/metrics')	1✔
96	def metrics():	1✔
UNCOV 97	return Response(generate_latest(registry),	×
98	content_type=CONTENT_TYPE_LATEST)

release-engineering / greenwave / 2259617033

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