prometheus

Documentation

Index

• func NewFactory() metrics.ProviderFactory
• func NewPointBuilder(src *prometheusMetricsSource, filtered gometrics.Counter) *pointBuilder
• func NewPrometheusMetricsSource(metricsURL, prefix, source, discovered string, tags map[string]string, ...) (metrics.Source, error)
• func NewPrometheusProvider(cfg configuration.PrometheusSourceConfig, lookupInstances LookupInstances) (metrics.SourceProvider, error)
• type HTTPError
  • func (e *HTTPError) Error() string
• type Instance
  • func InstanceFromHost(instance string) ([]Instance, error)
• type LookaheadReader
  • func NewLookaheadReader(reader io.Reader) *LookaheadReader
  • func (laReader *LookaheadReader) Done() bool
  • func (laReader *LookaheadReader) Peek() []byte
  • func (laReader *LookaheadReader) Read() []byte
• type LookupInstances
  • func InstancesFromEndpoints(client corev1.EndpointsGetter) LookupInstances
• type MetricReader
  • func NewMetricReader(reader io.Reader) *MetricReader
  • func (mReader *MetricReader) Done() bool
  • func (mReader *MetricReader) Read() []byte

Functions

func NewFactory

func NewFactory() metrics.ProviderFactory

Returns a new prometheus provider factory

func NewPointBuilder

func NewPointBuilder(src *prometheusMetricsSource, filtered gometrics.Counter) *pointBuilder

func NewPrometheusMetricsSource

func NewPrometheusMetricsSource(metricsURL, prefix, source, discovered string, tags map[string]string, filters filter.Filter, httpCfg httputil.ClientConfig) (metrics.Source, error)

func NewPrometheusProvider

func NewPrometheusProvider(cfg configuration.PrometheusSourceConfig, lookupInstances LookupInstances) (metrics.SourceProvider, error)

Types

type HTTPError

type HTTPError struct {
	MetricsURL string
	Status     string
	StatusCode int
}

func (*HTTPError) Error

func (e *HTTPError) Error() string

type Instance

type Instance struct {
	Host string
	Tags map[string]string
}

func InstanceFromHost

func InstanceFromHost(instance string) ([]Instance, error)

type LookaheadReader

type LookaheadReader struct {
	// contains filtered or unexported fields
}

func NewLookaheadReader

func NewLookaheadReader(reader io.Reader) *LookaheadReader

func (*LookaheadReader) Done

func (laReader *LookaheadReader) Done() bool

func (*LookaheadReader) Peek

func (laReader *LookaheadReader) Peek() []byte

func (*LookaheadReader) Read

func (laReader *LookaheadReader) Read() []byte

type LookupInstances

type LookupInstances func(host string) ([]Instance, error)

func InstancesFromEndpoints

func InstancesFromEndpoints(client corev1.EndpointsGetter) LookupInstances

type MetricReader

type MetricReader struct {
	// contains filtered or unexported fields
}

func NewMetricReader

func NewMetricReader(reader io.Reader) *MetricReader

func (*MetricReader) Done

func (mReader *MetricReader) Done() bool

Done tells us if there is anything left to read

func (*MetricReader) Read

func (mReader *MetricReader) Read() []byte