kafkametrics

README

Documentation

Overview

Package kafkametrics fetches Kafka broker metrics and posts events to supported metrics backends.

Index

• type APIError
  • func (e *APIError) Error() string
• type Broker
• type BrokerMetrics
• type Event
• type Handler
• type Mock
  • func (k *Mock) GetMetrics() (BrokerMetrics, []error)
  • func (k *Mock) PostEvent(e *Event) error
• type NoResults
  • func (e *NoResults) Error() string
• type PartialResults
  • func (e *PartialResults) Error() string

Types

type APIError

type APIError struct {
	Request string
	Message string
}

APIError wraps backend metric system errors.

func (*APIError) Error

func (e *APIError) Error() string

Error implements the error interface for APIError.

type Broker

type Broker struct {
	ID           int
	Host         string
	InstanceType string
	NetTX        float64
}

Broker holds metrics and metadata for a Kafka broker.

type BrokerMetrics

type BrokerMetrics map[int]*Broker

BrokerMetrics is a map of broker IDs to *Broker structs.

type Event

type Event struct {
	Title string
	Text  string
	Tags  []string
}

Event is used to post autothrottle events to the backend metrics system.

type Handler

type Handler interface {
	GetMetrics() (BrokerMetrics, []error)
	PostEvent(*Event) error
}

Handler requests broker metrics and posts events.

type Mock

type Mock struct{}

Mock mocks tshe Handler interface.

func (*Mock) GetMetrics

func (k *Mock) GetMetrics() (BrokerMetrics, []error)

GetMetrics mocks the GetMetrics function.

func (*Mock) PostEvent

func (k *Mock) PostEvent(e *Event) error

PostEvent mocks the PostEvent function.

type NoResults

type NoResults struct {
	Message string
}

NoResults types are returned when incomplete broker metrics or metadata is returned.

func (*NoResults) Error

func (e *NoResults) Error() string

Error implements the error interface for PartialResults.

type PartialResults

type PartialResults struct {
	Message string
}

PartialResults types are returned when incomplete broker metrics or metadata is returned.

func (*PartialResults) Error

func (e *PartialResults) Error() string

Error implements the error interface for PartialResults.