Documentation
¶
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GenerateTags ¶
func (*MetricImp) GetAggregatedItems ¶
func (*MetricImp) GetLatestTimestamp ¶
GetLatestTimestamp returns the latest metric timestamp in milliseconds.
func (*MetricImp) GetSeriesItems ¶
func (*MetricImp) MergeAggregatedMetric ¶
func (a *MetricImp) MergeAggregatedMetric(as *types.AggregatedMetric)
Source Files
Click to show internal directories.
Click to hide internal directories.