GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-12 21:09:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: concurrent writes to map

Browse Source
This commit is contained in:
Ankit Nayan 2023-01-06 16:10:13 +05:30
parent e8f341b850
commit cab9e04cdd
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/query-service/telemetry/telemetry.go
View File

@ -45,9 +45,9 @@ const ph_api_key = "H-htDCae7CR3RV57gUzmol6IAKtm5IMCvbcm_fwnL-w"
const IP_NOT_FOUND_PLACEHOLDER = "NA" const IP_NOT_FOUND_PLACEHOLDER = "NA"
const DEFAULT_NUMBER_OF_SERVICES = 6 const DEFAULT_NUMBER_OF_SERVICES = 6
const HEART_BEAT_DURATION = 6 * time.Hour // const HEART_BEAT_DURATION = 6 * time.Hour
// const HEART_BEAT_DURATION = 10 * time.Second const HEART_BEAT_DURATION = 30 * time.Second
const RATE_LIMIT_CHECK_DURATION = 1 * time.Minute const RATE_LIMIT_CHECK_DURATION = 1 * time.Minute
const RATE_LIMIT_VALUE = 2 const RATE_LIMIT_VALUE = 2
@ -88,13 +88,19 @@ func (telemetry *Telemetry) CheckSigNozMetrics(compositeMetricQueryMap map[strin
} }
func (telemetry *Telemetry) AddActiveTracesUser() { func (telemetry *Telemetry) AddActiveTracesUser() {
telemetry.mutex.Lock()
telemetry.activeUser["traces"] = 1 telemetry.activeUser["traces"] = 1
telemetry.mutex.Unlock()
} }
func (telemetry *Telemetry) AddActiveMetricsUser() { func (telemetry *Telemetry) AddActiveMetricsUser() {
telemetry.mutex.Lock()
telemetry.activeUser["metrics"] = 1 telemetry.activeUser["metrics"] = 1
telemetry.mutex.Unlock()
} }
func (telemetry *Telemetry) AddActiveLogsUser() { func (telemetry *Telemetry) AddActiveLogsUser() {
telemetry.mutex.Lock()
telemetry.activeUser["logs"] = 1 telemetry.activeUser["logs"] = 1
telemetry.mutex.Unlock()
} }
type Telemetry struct { type Telemetry struct {
@ -111,6 +117,7 @@ type Telemetry struct {
rateLimits map[string]int8 rateLimits map[string]int8
activeUser map[string]int8 activeUser map[string]int8
countUsers int8 countUsers int8
mutex sync.RWMutex
} }
func createTelemetry() { func createTelemetry() {