cache

Documentation

Index

• type MatchedMetricsCache
• type Metric
• type MetricCache
  • func GetCache(id string, cacheTtl time.Duration, metricGroups []common.MetricGroup, ...) MetricCache
• type MetricGroup
  • func (mg *MetricGroup) GetMatchedMetricsCache(id string) *MatchedMetricsCache
  • func (mg *MetricGroup) HasMatchedMetrics(id string) bool
  • func (mg *MetricGroup) SetMetric(id string, name string, data *pmetric.NumberDataPoint)

Types

type MatchedMetricsCache

type MatchedMetricsCache struct {
	// map key is the metric name
	Metrics map[string]*Metric
	Mutex   sync.RWMutex
}

type Metric

type Metric struct {
	DataPoint *pmetric.NumberDataPoint
	// contains filtered or unexported fields
}

type MetricCache

type MetricCache struct {
	// map key is the metric group name
	MetricGroups map[string]*MetricGroup
	// contains filtered or unexported fields
}

func GetCache

func GetCache(id string, cacheTtl time.Duration, metricGroups []common.MetricGroup, logger *zap.Logger) MetricCache

type MetricGroup

type MetricGroup struct {
	Mutex sync.RWMutex
	// contains filtered or unexported fields
}

func (*MetricGroup) GetMatchedMetricsCache

func (mg *MetricGroup) GetMatchedMetricsCache(id string) *MatchedMetricsCache

func (*MetricGroup) HasMatchedMetrics

func (mg *MetricGroup) HasMatchedMetrics(id string) bool

func (*MetricGroup) SetMetric

func (mg *MetricGroup) SetMetric(id string, name string, data *pmetric.NumberDataPoint)