Name	Size	Mode	Actions
bridge/	-	0755	rm
openmetrics/	-	0755	rm
twisted/	-	0755	rm
__pycache__/	-	0755	rm
asgi.py	1185	0644	editdlrm
context_managers.py	1691	0644	editdlrm
core.py	895	0644	editdlrm
decorator.py	15802	0644	editdlrm
exposition.py	15283	0644	editdlrm
gc_collector.py	1458	0644	editdlrm
metrics.py	22184	0644	editdlrm
metrics_core.py	11881	0644	editdlrm
mmap_dict.py	5264	0644	editdlrm
multiprocess.py	6474	0644	editdlrm
parser.py	7256	0644	editdlrm
platform_collector.py	1735	0644	editdlrm
process_collector.py	3654	0644	editdlrm
registry.py	5357	0644	editdlrm
samples.py	1358	0644	editdlrm
utils.py	621	0644	editdlrm
values.py	3836	0644	editdlrm
__init__.py	1817	0644	editdlrm

from urllib.parse import parse_qs from .exposition import _bake_output from .registry import REGISTRY def make_asgi_app(registry=REGISTRY): """Create a ASGI app which serves the metrics from a registry.""" async def prometheus_app(scope, receive, send): assert scope.get("type") == "http" # Prepare parameters params = parse_qs(scope.get('query_string', b'')) accept_header = "Accept: " + ",".join([ value.decode("utf8") for (name, value) in scope.get('headers') if name.decode("utf8") == 'accept' ]) # Bake output status, header, output = _bake_output(registry, accept_header, params) # Return output payload = await receive() if payload.get("type") == "http.request": await send( { "type": "http.response.start", "status": int(status.split(' ')[0]), "headers": [ tuple(x.encode('utf8') for x in header) ] } ) await send({"type": "http.response.body", "body": output}) return prometheus_app