Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsServer ¶
type MetricsServer struct {
// contains filtered or unexported fields
}
The MetricsServer Struct
func NewMetricsServer ¶
func NewMetricsServer(logger *zap.Logger, httpPort string, path string) *MetricsServer
MetricsServer Constructor
func (*MetricsServer) Observe ¶
func (m *MetricsServer) Observe(stats string)
Observe librdkafka Metrics
func (*MetricsServer) Start ¶
func (m *MetricsServer) Start()
Start The Metrics HTTP Server Listening For Requests
func (*MetricsServer) Stop ¶
func (m *MetricsServer) Stop()
Stop The Metrics HTTP Server Listening For Requests
Click to show internal directories.
Click to hide internal directories.