Versions in this module Expand all Collapse all v0 v0.2.0 Jun 18, 2017 Changes in this version + const ConcurrentOfUpdateIndexAll + const DefaultCacheProcUpdateTaskSleepInterval + const DefaultMaxCacheSize + const DefaultUpdateStepInSec + const IndexUpdateIncrTaskSleepInterval + var IndexedItemCache = NewIndexCacheBase(DefaultMaxCacheSize) + func GetConcurrentOfUpdateIndexAll() int + func GetCounterFromCache(endpointId int64, counter string) (dsType string, step int, found bool) + func GetEndpointFromCache(endpoint string) (int64, bool) + func GetTypeAndStep(endpoint string, counter string) (dsType string, step int, found bool) + func InitCache() + func ReceiveItem(item *cmodel.GraphItem, md5 string) + func RemoveItem(item *cmodel.GraphItem) + func Start() + func StartIndexUpdateIncrTask() + func UpdateIndexAll(updateStepInSec int64) + func UpdateIndexAllByDefaultStep() + func UpdateIndexOne(endpoint string, metric string, tags map[string]string, dstype string, ...) error + type IndexCacheBase struct + func NewIndexCacheBase(max int) *IndexCacheBase + func (this *IndexCacheBase) ContainsKey(key string) bool + func (this *IndexCacheBase) Get(key string) interface{} + func (this *IndexCacheBase) GetMaxSize() int + func (this *IndexCacheBase) Keys() []string + func (this *IndexCacheBase) Put(key string, item interface{}) + func (this *IndexCacheBase) Remove(key string) + func (this *IndexCacheBase) Size() int + type IndexCacheItem struct + Item *cmodel.GraphItem + UUID string + func NewIndexCacheItem(uuid string, item *cmodel.GraphItem) *IndexCacheItem
Go to main page