pusher

package

v0.24.1 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 15 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/grafana/synthetic-monitoring-agent

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ClientFromRemoteInfo(remote *sm.RemoteInfo) (*prom.ClientConfig, error)
func NewRegistry[T any]() *registry[T]
type AlreadyRegisteredError
- func (e AlreadyRegisteredError) Error() string
type Factory
type Metrics
- func NewMetrics(promRegisterer prometheus.Registerer) (m Metrics)
- func (m Metrics) WithTenant(localID int64, regionID int) Metrics
- func (m Metrics) WithType(t string) Metrics
type NotFoundError
- func (e NotFoundError) Error() string
type Payload
type Publisher
type TenantProvider

Constants ¶

View Source

const (
	LabelValueMetrics        = "metrics"
	LabelValueLogs           = "logs"
	LabelValueClient         = "client"
	LabelValueRetryExhausted = "retry_exhausted"
	LabelValueTenant         = "tenant"
)

Variables ¶

This section is empty.

Functions ¶

func ClientFromRemoteInfo ¶ added in v0.17.0

func ClientFromRemoteInfo(remote *sm.RemoteInfo) (*prom.ClientConfig, error)

func NewRegistry ¶ added in v0.17.0

func NewRegistry[T any]() *registry[T]

Types ¶

type AlreadyRegisteredError ¶ added in v0.17.0

type AlreadyRegisteredError string

func (AlreadyRegisteredError) Error ¶ added in v0.17.0

func (e AlreadyRegisteredError) Error() string

type Factory ¶ added in v0.17.0

type Factory func(ctx context.Context, tm TenantProvider, logger zerolog.Logger, promRegisterer prometheus.Registerer) Publisher

type Metrics ¶ added in v0.17.0

type Metrics struct {
	PushCounter    *prometheus.CounterVec
	ErrorCounter   *prometheus.CounterVec
	BytesOut       *prometheus.CounterVec
	FailedCounter  *prometheus.CounterVec
	RetriesCounter *prometheus.CounterVec

	// For experimental publisher only
	DroppedCounter  *prometheus.CounterVec
	ResponseCounter *prometheus.CounterVec

	InstalledHandlers prometheus.Gauge
}

Metrics contains the prometheus Metrics for a publisher.

func NewMetrics ¶ added in v0.17.0

func NewMetrics(promRegisterer prometheus.Registerer) (m Metrics)

NewMetrics returns a new set of publisher metrics registered in the given registerer.

func (Metrics) WithTenant ¶ added in v0.17.0

func (m Metrics) WithTenant(localID int64, regionID int) Metrics

WithTenant returns a new set of Metrics with the local and region ID labels already included.

func (Metrics) WithType ¶ added in v0.17.0

func (m Metrics) WithType(t string) Metrics

WithType returns a new set of Metrics with the given type label.

type NotFoundError ¶ added in v0.17.0

type NotFoundError struct {
	Requested string
	Accepted  []string
}

func (NotFoundError) Error ¶ added in v0.17.0

func (e NotFoundError) Error() string

type Payload ¶

type Payload interface {
	Tenant() model.GlobalID
	Metrics() []prompb.TimeSeries
	Streams() []logproto.Stream
}

type Publisher ¶

type Publisher interface {
	Publish(Payload)
}

type TenantProvider ¶ added in v0.17.0

type TenantProvider interface {
	GetTenant(context.Context, *sm.TenantInfo) (*sm.Tenant, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
v1
v2

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