internal

Documentation

Index

• type MetricImp
  • func NewInternalMetric(m types.MetricMetaImp, o types.ObjectMetaImp) *MetricImp
  • func (a *MetricImp) AddSeriesMetric(is *types.SeriesMetric) []*types.SeriesItem
  • func (a *MetricImp) AggregateMetric()
  • func (a *MetricImp) Empty() bool
  • func (a *MetricImp) GC(expiredTimestamp int64)
  • func (a *MetricImp) GenerateTags() []metrics.MetricTag
  • func (a *MetricImp) GetAggregatedItems(metricSelector labels.Selector, agg string) ([]types.Metric, bool)
  • func (a *MetricImp) GetLatestTimestamp() int64
  • func (a *MetricImp) GetSeriesItems(metricSelector labels.Selector, latest bool) ([]*types.SeriesMetric, bool)
  • func (a *MetricImp) Len() int
  • func (a *MetricImp) MergeAggregatedMetric(as *types.AggregatedMetric)

Types

type MetricImp

type MetricImp struct {
	// those unified fields is only kept for one replica in MetricImp,
	// and we will try to copy into types.Metric when corresponding functions are called.
	types.MetricMetaImp
	types.ObjectMetaImp

	sync.RWMutex
	// contains filtered or unexported fields
}

MetricImp is used as an internal version of metricItem.

func NewInternalMetric

func NewInternalMetric(m types.MetricMetaImp, o types.ObjectMetaImp) *MetricImp

func (*MetricImp) AddSeriesMetric

func (a *MetricImp) AddSeriesMetric(is *types.SeriesMetric) []*types.SeriesItem

func (*MetricImp) AggregateMetric

func (a *MetricImp) AggregateMetric()

AggregateMetric calculate the aggregated metric based on snapshot of current store

func (*MetricImp) Empty

func (a *MetricImp) Empty() bool

func (*MetricImp) GC

func (a *MetricImp) GC(expiredTimestamp int64)

func (*MetricImp) GenerateTags

func (a *MetricImp) GenerateTags() []metrics.MetricTag

func (*MetricImp) GetAggregatedItems

func (a *MetricImp) GetAggregatedItems(metricSelector labels.Selector, agg string) ([]types.Metric, bool)

func (*MetricImp) GetLatestTimestamp

func (a *MetricImp) GetLatestTimestamp() int64

GetLatestTimestamp returns the latest metric timestamp in milliseconds.

func (*MetricImp) GetSeriesItems

func (a *MetricImp) GetSeriesItems(metricSelector labels.Selector, latest bool) ([]*types.SeriesMetric, bool)

func (*MetricImp) Len

func (a *MetricImp) Len() int

func (*MetricImp) MergeAggregatedMetric

func (a *MetricImp) MergeAggregatedMetric(as *types.AggregatedMetric)