Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JMXService ¶
type JMXService struct {
// contains filtered or unexported fields
}
JMXService collects JMX metrics from Kafka brokers via Jolokia
func NewJMXService ¶
func NewJMXService(endpoints []string, opts ...client.JolokiaOption) *JMXService
NewJMXService creates a new JMX service with Jolokia clients for each broker endpoint
func (*JMXService) CollectOverDuration ¶
func (s *JMXService) CollectOverDuration(ctx context.Context, duration, interval time.Duration) (*types.ProcessedClusterMetrics, error)
CollectOverDuration collects JMX metrics over a specified duration at regular intervals and returns them in ProcessedClusterMetrics format for direct use by the UI.
Source Files
Click to show internal directories.
Click to hide internal directories.