Look at the InternalRelay class. This thing is supposed to be distributing events to the streaming API. We should first add Prometheus metrics to it. Let's add a metric to track the number of active subscriptions and add a graph for it.