1
0

test_event_metrics.py 3.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. # Copyright 2019 The Matrix.org Foundation C.I.C.
  2. #
  3. # Licensed under the Apache License, Version 2.0 (the 'License');
  4. # you may not use this file except in compliance with the License.
  5. # You may obtain a copy of the License at
  6. #
  7. # http://www.apache.org/licenses/LICENSE-2.0
  8. #
  9. # Unless required by applicable law or agreed to in writing, software
  10. # distributed under the License is distributed on an 'AS IS' BASIS,
  11. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. # See the License for the specific language governing permissions and
  13. # limitations under the License.
  14. from synapse.metrics import REGISTRY, generate_latest
  15. from synapse.types import UserID, create_requester
  16. from tests.unittest import HomeserverTestCase
  17. class ExtremStatisticsTestCase(HomeserverTestCase):
  18. def test_exposed_to_prometheus(self):
  19. """
  20. Forward extremity counts are exposed via Prometheus.
  21. """
  22. room_creator = self.hs.get_room_creation_handler()
  23. user = UserID("alice", "test")
  24. requester = create_requester(user)
  25. # Real events, forward extremities
  26. events = [(3, 2), (6, 2), (4, 6)]
  27. for event_count, extrems in events:
  28. info, _ = self.get_success(room_creator.create_room(requester, {}))
  29. room_id = info["room_id"]
  30. last_event = None
  31. # Make a real event chain
  32. for _ in range(event_count):
  33. ev = self.create_and_send_event(room_id, user, False, last_event)
  34. last_event = [ev]
  35. # Sprinkle in some extremities
  36. for _ in range(extrems):
  37. ev = self.create_and_send_event(room_id, user, False, last_event)
  38. # Let it run for a while, then pull out the statistics from the
  39. # Prometheus client registry
  40. self.reactor.advance(60 * 60 * 1000)
  41. self.pump(1)
  42. items = list(
  43. filter(
  44. lambda x: b"synapse_forward_extremities_" in x,
  45. generate_latest(REGISTRY, emit_help=False).split(b"\n"),
  46. )
  47. )
  48. expected = [
  49. b'synapse_forward_extremities_bucket{le="1.0"} 0.0',
  50. b'synapse_forward_extremities_bucket{le="2.0"} 2.0',
  51. b'synapse_forward_extremities_bucket{le="3.0"} 2.0',
  52. b'synapse_forward_extremities_bucket{le="5.0"} 2.0',
  53. b'synapse_forward_extremities_bucket{le="7.0"} 3.0',
  54. b'synapse_forward_extremities_bucket{le="10.0"} 3.0',
  55. b'synapse_forward_extremities_bucket{le="15.0"} 3.0',
  56. b'synapse_forward_extremities_bucket{le="20.0"} 3.0',
  57. b'synapse_forward_extremities_bucket{le="50.0"} 3.0',
  58. b'synapse_forward_extremities_bucket{le="100.0"} 3.0',
  59. b'synapse_forward_extremities_bucket{le="200.0"} 3.0',
  60. b'synapse_forward_extremities_bucket{le="500.0"} 3.0',
  61. # per https://docs.google.com/document/d/1KwV0mAXwwbvvifBvDKH_LU1YjyXE_wxCkHNoCGq1GX0/edit#heading=h.wghdjzzh72j9,
  62. # "inf" is valid: "this includes variants such as inf"
  63. b'synapse_forward_extremities_bucket{le="inf"} 3.0',
  64. b"# TYPE synapse_forward_extremities_gcount gauge",
  65. b"synapse_forward_extremities_gcount 3.0",
  66. b"# TYPE synapse_forward_extremities_gsum gauge",
  67. b"synapse_forward_extremities_gsum 10.0",
  68. ]
  69. self.assertEqual(items, expected)