Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PrometheusListener ¶
type PrometheusListener struct {
*actor.Mailbox
*actor.BasicServerOuter
// contains filtered or unexported fields
}
func NewPrometheusListener ¶
func NewPrometheusListener(mux *ghttp.HttpListenerWithMux, rmId common.RMId, cm connectionmanager.ConnectionManager, router *router.Router, logger log.Logger) *PrometheusListener
func (*PrometheusListener) TopologyChanged ¶
func (pl *PrometheusListener) TopologyChanged(topology *configuration.Topology, done func(bool))
type StatsPublisher ¶
type StatsPublisher struct {
*actor.Mailbox
*actor.BasicServerOuter
// contains filtered or unexported fields
}
func NewStatsPublisher ¶
func NewStatsPublisher(cm connectionmanager.ConnectionManager, lc *localconnection.LocalConnection, logger log.Logger) *StatsPublisher
func (*StatsPublisher) TopologyChanged ¶
func (cp *StatsPublisher) TopologyChanged(topology *configuration.Topology, done func(bool))
Source Files
Click to show internal directories.
Click to hide internal directories.