Mirroristas/planetmint-go
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint-go.git synced 2025-11-24 06:25:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed linter issues

Browse Source 
Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
This commit is contained in:
Jürgen Eckel 2024-05-15 11:19:17 +02:00
parent f68d0df98b
commit 1082d43cce
No known key found for this signature in database
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
monitor/mqtt_monitor.go
View File

@ -19,12 +19,11 @@ import (
var MonitorMQTTClient util.MQTTClientI var MonitorMQTTClient util.MQTTClientI
var clientMutex sync.Mutex var clientMutex sync.Mutex
var localMqttClient util.MQTTClientI = nil var localMqttClient util.MQTTClientI
type MqttMonitor struct { type MqttMonitor struct {
db *leveldb.DB db *leveldb.DB
dbMutex sync.Mutex // Mutex to synchronize write operations dbMutex sync.Mutex // Mutex to synchronize write operations
ticker *time.Ticker
CleanupPeriodicityInMinutes time.Duration CleanupPeriodicityInMinutes time.Duration
config config.Config config config.Config
numberOfElements int64 numberOfElements int64
@ -93,7 +92,6 @@ func (mms *MqttMonitor) runPeriodicTasks() {
go mms.CleanupDB() go mms.CleanupDB()
} }
} }
} }
func (mms *MqttMonitor) Start() (err error) { func (mms *MqttMonitor) Start() (err error) {
@ -244,7 +242,6 @@ func (mms *MqttMonitor) Log(msg string) {
if localContext != nil { if localContext != nil {
util.GetAppLogger().Info(*localContext, msg) util.GetAppLogger().Info(*localContext, msg)
} }
} }
func (mms *MqttMonitor) SetContext(ctx sdk.Context) { func (mms *MqttMonitor) SetContext(ctx sdk.Context) {