Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReceiveCache ¶
type ReceiveCache struct {
*stdmap.Backend[flow.Identifier, struct{}]
}
ReceiveCache implements an LRU cache of the received eventIDs that delivered to their engines. Each key in this cache is the event ID represented as a flow.Identifier.
func NewHeroReceiveCache ¶ added in v0.25.2
func NewHeroReceiveCache(sizeLimit uint32, logger zerolog.Logger, collector module.HeroCacheMetrics, ) *ReceiveCache
NewHeroReceiveCache returns a new HeroCache-based receive cache.
func NewReceiveCache ¶
func NewReceiveCache(sizeLimit uint, opts ...func(cache *ReceiveCache)) *ReceiveCache
NewReceiveCache creates and returns a new ReceiveCache
func (*ReceiveCache) Add ¶
func (r *ReceiveCache) Add(eventID []byte) bool
Add adds a new message to the cache if not already present. Returns true if the message is new and unseen, and false if message is duplicate, and already has been seen by the node.
Source Files
Click to show internal directories.
Click to hide internal directories.