costattribution

Documentation

Index

• type ActiveSeriesTracker
  • func (at *ActiveSeriesTracker) Collect(out chan<- prometheus.Metric)
  • func (at *ActiveSeriesTracker) Decrement(lbls labels.Labels)
  • func (at *ActiveSeriesTracker) Increment(lbls labels.Labels, now time.Time)
• type Manager
  • func NewManager(cleanupInterval, inactiveTimeout time.Duration, logger log.Logger, ...) (*Manager, error)
  • func (m *Manager) ActiveSeriesTracker(userID string) *ActiveSeriesTracker
  • func (m *Manager) Collect(out chan<- prometheus.Metric)
  • func (m *Manager) Describe(chan<- *prometheus.Desc)
  • func (m *Manager) SampleTracker(userID string) *SampleTracker
• type SampleTracker
  • func (st *SampleTracker) Collect(out chan<- prometheus.Metric)
  • func (st *SampleTracker) IncrementDiscardedSamples(lbls []mimirpb.LabelAdapter, value float64, reason string, now time.Time)
  • func (st *SampleTracker) IncrementReceivedSamples(req *mimirpb.WriteRequest, now time.Time)

Types

type ActiveSeriesTracker

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

func (*ActiveSeriesTracker) Collect

func (at *ActiveSeriesTracker) Collect(out chan<- prometheus.Metric)

func (*ActiveSeriesTracker) Decrement

func (at *ActiveSeriesTracker) Decrement(lbls labels.Labels)

func (*ActiveSeriesTracker) Increment

func (at *ActiveSeriesTracker) Increment(lbls labels.Labels, now time.Time)

type Manager

type Manager struct {
	services.Service
	// contains filtered or unexported fields
}

func NewManager

func NewManager(cleanupInterval, inactiveTimeout time.Duration, logger log.Logger, limits *validation.Overrides, reg *prometheus.Registry) (*Manager, error)

func (*Manager) ActiveSeriesTracker

func (m *Manager) ActiveSeriesTracker(userID string) *ActiveSeriesTracker

func (*Manager) Collect

func (m *Manager) Collect(out chan<- prometheus.Metric)

func (*Manager) Describe

func (m *Manager) Describe(chan<- *prometheus.Desc)

func (*Manager) SampleTracker

func (m *Manager) SampleTracker(userID string) *SampleTracker

type SampleTracker

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

func (*SampleTracker) Collect

func (st *SampleTracker) Collect(out chan<- prometheus.Metric)

func (*SampleTracker) IncrementDiscardedSamples

func (st *SampleTracker) IncrementDiscardedSamples(lbls []mimirpb.LabelAdapter, value float64, reason string, now time.Time)

func (*SampleTracker) IncrementReceivedSamples

func (st *SampleTracker) IncrementReceivedSamples(req *mimirpb.WriteRequest, now time.Time)