Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + func Noop(_ interface{}) + type MessageStore interface + Add func(msg interface{}) bool + CheckValid func(msg interface{}) bool + Get func() []interface{} + Purge func(func(interface{}) bool) + Size func() int + Stop func() + func NewMessageStore(pol common.MessageReplacingPolicy, trigger invalidationTrigger) MessageStore + func NewMessageStoreExpirable(pol common.MessageReplacingPolicy, trigger invalidationTrigger, ...) MessageStore