Adding metrics to cache for profile by ids api (#4925)
Этот коммит содержится в:
коммит произвёл
enahum
родитель
4bca74d5c1
Коммит
96b4e0ed87
@@ -25,6 +25,9 @@ type MetricsInterface interface {
|
|||||||
|
|
||||||
IncrementMemCacheHitCounter(cacheName string)
|
IncrementMemCacheHitCounter(cacheName string)
|
||||||
IncrementMemCacheMissCounter(cacheName string)
|
IncrementMemCacheMissCounter(cacheName string)
|
||||||
|
|
||||||
|
AddMemCacheHitCounter(cacheName string, amount float64)
|
||||||
|
AddMemCacheMissCounter(cacheName string, amount float64)
|
||||||
}
|
}
|
||||||
|
|
||||||
var theMetricsInterface MetricsInterface
|
var theMetricsInterface MetricsInterface
|
||||||
|
|||||||
@@ -804,6 +804,7 @@ func (us SqlUserStore) GetProfileByIds(userIds []string, allowFromCache bool) St
|
|||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
result := StoreResult{}
|
result := StoreResult{}
|
||||||
|
metrics := einterfaces.GetMetricsInterface()
|
||||||
|
|
||||||
var users []*model.User
|
var users []*model.User
|
||||||
userMap := make(map[string]*model.User)
|
userMap := make(map[string]*model.User)
|
||||||
@@ -820,8 +821,15 @@ func (us SqlUserStore) GetProfileByIds(userIds []string, allowFromCache bool) St
|
|||||||
remainingUserIds = append(remainingUserIds, userId)
|
remainingUserIds = append(remainingUserIds, userId)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if metrics != nil {
|
||||||
|
metrics.AddMemCacheHitCounter("Profile By Ids", float64(len(userMap)))
|
||||||
|
metrics.AddMemCacheMissCounter("Profile By Ids", float64(len(remainingUserIds)))
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
remainingUserIds = userIds
|
remainingUserIds = userIds
|
||||||
|
if metrics != nil {
|
||||||
|
metrics.AddMemCacheMissCounter("Profile By Ids", float64(len(remainingUserIds)))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// If everything came from the cache then just return
|
// If everything came from the cache then just return
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user