Documentation
¶
Index ¶
- func AddMetricsEventHandler(handler MessageHandler)
- func ConfigureGoroutinesPoolMetrics(config *goroutines.PoolConfig, registry metrics.Registry, poolType string)
- func GoroutinesPoolMetricsConfigF(registry metrics.Registry, poolType string) func(config *goroutines.PoolConfig)
- func InitMetricHandlers(cfg *metrics.Config)
- func RemoveMetricsEventHandler(handler MessageHandler)
- type MessageHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddMetricsEventHandler ¶
func AddMetricsEventHandler(handler MessageHandler)
func ConfigureGoroutinesPoolMetrics ¶ added in v0.17.134
func ConfigureGoroutinesPoolMetrics(config *goroutines.PoolConfig, registry metrics.Registry, poolType string)
func GoroutinesPoolMetricsConfigF ¶ added in v0.17.136
func GoroutinesPoolMetricsConfigF(registry metrics.Registry, poolType string) func(config *goroutines.PoolConfig)
func InitMetricHandlers ¶
func RemoveMetricsEventHandler ¶
func RemoveMetricsEventHandler(handler MessageHandler)
Types ¶
type MessageHandler ¶
type MessageHandler interface {
// AcceptMetrics is called when new metrics become available
AcceptMetrics(message *metrics_pb.MetricsMessage)
}
MessageHandler represents a sink for metric events
func NewChannelReporter ¶
func NewChannelReporter(ch channel.Channel) MessageHandler
NewChannelReporter creates a metrics handler which sends metrics messages out on the given channel
func NewDispatchWrapper ¶
func NewDispatchWrapper(delegate func(event event.Event)) MessageHandler
Source Files
Click to show internal directories.
Click to hide internal directories.