Skip to content

Instantly share code, notes, and snippets.

View freeart's full-sized avatar

Nekrasov Pavel freeart

View GitHub Profile
// AlarmStatusChanged queue handler
AlarmStatusChanged(func (payload) {
var alarmKey := "{{.payload.UserID}}:{{.payload.AlarmID}}"
// Get last record from Redis
var lastInMemory := redis.HMGet(alarmKey, ["ChangedAt"])
// If new record is coming
if (!lastInMemory || ChangedAt > lastInMemory.ChangedAt) {
// AlarmId is unique, there is updating each new status coming
redis.HMSet(alarmKey, [
"AlarmID", payload.AlarmID,