pusher

Documentation

Index

• Constants
• func ClientFromRemoteInfo(remote *sm.RemoteInfo) (*prom.ClientConfig, error)
• func GetLocalAndRegionIDs(id int64) (localID int64, regionID int)
• 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 TenantManager
  • func NewTenantManager(ctx context.Context, tenantsClient sm.TenantsClient, tenantCh <-chan sm.Tenant, ...) *TenantManager
  • func (tm *TenantManager) GetTenant(ctx context.Context, req *sm.TenantInfo) (*sm.Tenant, error)
• type TenantProvider

Constants

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

Functions

func ClientFromRemoteInfo

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

func GetLocalAndRegionIDs

func GetLocalAndRegionIDs(id int64) (localID int64, regionID int)

func NewRegistry

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

Types

type AlreadyRegisteredError

type AlreadyRegisteredError string

func (AlreadyRegisteredError) Error

func (e AlreadyRegisteredError) Error() string

type Factory

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

type Metrics

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
}

Metrics contains the prometheus Metrics for a publisher.

func NewMetrics

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

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

func (Metrics) WithTenant

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

func (m Metrics) WithType(t string) Metrics

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

type NotFoundError

type NotFoundError struct {
	Requested string
	Accepted  []string
}

func (NotFoundError) Error

func (e NotFoundError) Error() string

type Payload

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

type Publisher

type Publisher interface {
	Publish(Payload)
}

type TenantManager

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

func NewTenantManager

func NewTenantManager(ctx context.Context, tenantsClient sm.TenantsClient, tenantCh <-chan sm.Tenant, timeout time.Duration) *TenantManager

NewTenantManager creates a new tenant manager that is able to retrieve tenants from the remote API using the specified tenantsClient or receive them over the provided tenantCh channel. It will keep them for a duration no longer than `timeout`.

A new goroutine is started which stops when the provided context is cancelled.

func (*TenantManager) GetTenant

func (tm *TenantManager) GetTenant(ctx context.Context, req *sm.TenantInfo) (*sm.Tenant, error)

GetTenant retrieves the tenant specified by `req`, either from a local cache or by making a request to the API.

type TenantProvider

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