(msgId string)
| 17 | var msgService *MsgService |
| 18 | |
| 19 | func (u MsgService) IfProcessed(msgId string) bool { |
| 20 | _, found := u.cache.Get(msgId) |
| 21 | return found |
| 22 | } |
| 23 | func (u MsgService) TagProcessed(msgId string) { |
| 24 | u.cache.Set(msgId, true, time.Minute*30) |
| 25 | } |
nothing calls this directly
no outgoing calls
no test coverage detected