cache

package
v3.5.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NewEndpoints *list.SafeListLimited

Functions

func GetAllCounter 

func GetAllCounter(tags []*TagPair) []string

GetAllCounter returns all possible tags combination. But not all of them will be in the CounterMaps.

func IndexList 

func IndexList() []*models.Instance

func InitDB 

func InitDB(cfg CacheSection)

func OverMaxLimit 

func OverMaxLimit(tagMap map[string][]string, limit int) bool

OverMaxLimit check whether it can over limit or not.

func Persist 

func Persist(mode string) error

func Rebuild 

func Rebuild(persistenceDir string, concurrency int)

func RebuildFromDisk 

func RebuildFromDisk(indexDB *EndpointIndexMap, indexFileDir string, concurrency int) error

func StartCleaner 

func StartCleaner(interval int, cacheDuration int)

func StartPersist 

func StartPersist(interval int)

func TagPairToMap 

func TagPairToMap(tagPairs []*TagPair) map[string][]string

func WriteIndexToFile 

func WriteIndexToFile(mod, indexDir, endpoint string) error

Types

type CacheSection 

type CacheSection struct {
	CacheDuration   int    `yaml:"cacheDuration"`
	CleanInterval   int    `yaml:"cleanInterval"`
	PersistInterval int    `yaml:"persistInterval"`
	PersistDir      string `yaml:"persistDir"`
	RebuildWorker   int    `yaml:"rebuildWorker"`
	MaxQueryCount   int    `yaml:"maxQueryCount"`
	ReportEndpoint  bool   `yaml:"reportEndpoint"`
	HbsMod          string `yaml:"hbsMod"`
}
var Config CacheSection

type CounterTsMap 

type CounterTsMap struct {
	sync.RWMutex
	M map[string]int64 `json:"counters"` // map[counter]ts
}

Counter: sorted tags

func NewCounterTsMap 

func NewCounterTsMap() *CounterTsMap

func (*CounterTsMap) Clean 

func (c *CounterTsMap) Clean(now, timeDuration int64, endpoint, metric string)

func (*CounterTsMap) GetCounters 

func (c *CounterTsMap) GetCounters() map[string]int64

func (*CounterTsMap) Len 

func (c *CounterTsMap) Len() int

func (*CounterTsMap) Set 

func (c *CounterTsMap) Set(counter string, ts int64)

type EndpointIndexMap 

type EndpointIndexMap struct {
	sync.RWMutex
	M map[string]*MetricIndexMap `json:"endpoint_index"` //map[endpoint]metricMap{map[metric]Index}
}
var IndexDB *EndpointIndexMap
var NidIndexDB *EndpointIndexMap

func (*EndpointIndexMap) Clean 

func (e *EndpointIndexMap) Clean(timeDuration int64)

func (*EndpointIndexMap) DelByEndpoint 

func (e *EndpointIndexMap) DelByEndpoint(endpoint string)

func (*EndpointIndexMap) GetEndpoints 

func (e *EndpointIndexMap) GetEndpoints() []string

func (*EndpointIndexMap) GetIndexByClude 

func (e *EndpointIndexMap) GetIndexByClude(endpoint, metric string, include, exclude []*TagPair) ([]string, error)

func (*EndpointIndexMap) GetMetricIndex 

func (e *EndpointIndexMap) GetMetricIndex(endpoint, metric string) (*MetricIndex, bool)

func (*EndpointIndexMap) GetMetricIndexMap 

func (e *EndpointIndexMap) GetMetricIndexMap(endpoint string) (*MetricIndexMap, bool)

func (*EndpointIndexMap) GetMetricsBy 

func (e *EndpointIndexMap) GetMetricsBy(endpoint string) []string

func (*EndpointIndexMap) Push 

func (e *EndpointIndexMap) Push(item dataobj.IndexModel, now int64)

Push 索引数据

func (*EndpointIndexMap) SetMetricIndexMap 

func (e *EndpointIndexMap) SetMetricIndexMap(endpoint string, metricIndex *MetricIndexMap)

type MetricIndex 

type MetricIndex struct {
	sync.RWMutex
	Metric     string        `json:"metric"`
	Step       int           `json:"step"`
	DsType     string        `json:"dstype"`
	TagkvMap   *TagkvIndex   `json:"tags"`
	CounterMap *CounterTsMap `json:"counters"`
	Ts         int64         `json:"ts"`
}

func NewMetricIndex 

func NewMetricIndex(item dataobj.IndexModel, counter string, now int64) *MetricIndex

func (*MetricIndex) Set 

func (m *MetricIndex) Set(item dataobj.IndexModel, counter string, now int64)

type MetricIndexMap 

type MetricIndexMap struct {
	sync.RWMutex
	Reported bool // 用于判断 endpoint 是否已成功上报给 monapi
	Data     map[string]*MetricIndex
}

func ReadIndexFromFile 

func ReadIndexFromFile(indexDir, endpoint string) (*MetricIndexMap, error)

func (*MetricIndexMap) Clean 

func (m *MetricIndexMap) Clean(now, timeDuration int64, endpoint string)

func (*MetricIndexMap) DelMetric 

func (m *MetricIndexMap) DelMetric(metric string)

func (*MetricIndexMap) GetMetricIndex 

func (m *MetricIndexMap) GetMetricIndex(metric string) (*MetricIndex, bool)

func (*MetricIndexMap) GetMetrics 

func (m *MetricIndexMap) GetMetrics() []string

func (*MetricIndexMap) IsReported 

func (m *MetricIndexMap) IsReported() bool

func (*MetricIndexMap) Len 

func (m *MetricIndexMap) Len() int

func (*MetricIndexMap) SetMetricIndex 

func (m *MetricIndexMap) SetMetricIndex(metric string, metricIndex *MetricIndex)

func (*MetricIndexMap) SetReported 

func (m *MetricIndexMap) SetReported()

type TagPair 

type TagPair struct {
	Key    string   `json:"tagk"` // json 和变量不一致为了兼容前端
	Values []string `json:"tagv"`
}

func GetSortTags 

func GetSortTags(tagMap map[string][]string) []*TagPair

type TagPairs 

type TagPairs []*TagPair

func (TagPairs) Len 

func (t TagPairs) Len() int

func (TagPairs) Less 

func (t TagPairs) Less(i, j int) bool

func (TagPairs) Swap 

func (t TagPairs) Swap(i, j int)

type TagkvIndex 

type TagkvIndex struct {
	sync.RWMutex
	Tagkv map[string]map[string]int64 `json:"tagkv"` // map[tagk]map[tagv]ts
}

TagKeys

func NewTagkvIndex 

func NewTagkvIndex() *TagkvIndex

func (*TagkvIndex) Clean 

func (t *TagkvIndex) Clean(now, timeDuration int64)

func (*TagkvIndex) DelTag 

func (t *TagkvIndex) DelTag(tagk, tagv string)

func (*TagkvIndex) GetTagkv 

func (t *TagkvIndex) GetTagkv() []*TagPair

func (*TagkvIndex) GetTagkvMap 

func (t *TagkvIndex) GetTagkvMap() map[string][]string

func (*TagkvIndex) Len 

func (t *TagkvIndex) Len() int

func (*TagkvIndex) Set 

func (t *TagkvIndex) Set(tagk, tagv string, now int64)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.