prometheus

package

v0.0.0-...-1d907cd Latest Latest Go to latest Published: Jan 11, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wavefronthq/observability-for-kubernetes

Links

Open Source Insights

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
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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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, convertHistograms bool, 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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL