diff options
| -rw-r--r-- | einterfaces/metrics.go | 3 | ||||
| -rw-r--r-- | store/sql_user_store.go | 8 |
2 files changed, 11 insertions, 0 deletions
diff --git a/einterfaces/metrics.go b/einterfaces/metrics.go index c4ec9dccf..f7d660da3 100644 --- a/einterfaces/metrics.go +++ b/einterfaces/metrics.go @@ -25,6 +25,9 @@ type MetricsInterface interface { IncrementMemCacheHitCounter(cacheName string) IncrementMemCacheMissCounter(cacheName string) + + AddMemCacheHitCounter(cacheName string, amount float64) + AddMemCacheMissCounter(cacheName string, amount float64) } var theMetricsInterface MetricsInterface diff --git a/store/sql_user_store.go b/store/sql_user_store.go index 8db0e9624..2ce1e6eab 100644 --- a/store/sql_user_store.go +++ b/store/sql_user_store.go @@ -804,6 +804,7 @@ func (us SqlUserStore) GetProfileByIds(userIds []string, allowFromCache bool) St go func() { result := StoreResult{} + metrics := einterfaces.GetMetricsInterface() var users []*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) } } + if metrics != nil { + metrics.AddMemCacheHitCounter("Profile By Ids", float64(len(userMap))) + metrics.AddMemCacheMissCounter("Profile By Ids", float64(len(remainingUserIds))) + } } else { remainingUserIds = userIds + if metrics != nil { + metrics.AddMemCacheMissCounter("Profile By Ids", float64(len(remainingUserIds))) + } } // If everything came from the cache then just return |