Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Deduplicator ¶
type Deduplicator struct {
// contains filtered or unexported fields
}
Deduplicator represents a filter to avoid duplicate messages
func New ¶
func New(cache cache.CacheInterface[bool], logger *zap.Logger, opts ...Option) *Deduplicator
New creates a deduplicator instance
type Option ¶
type Option func(*Deduplicator)
Option represents a deduplicator option function.
func WithExpiration ¶
WithExpiration allows to specify an expiration time when setting a value.
Source Files
Click to show internal directories.
Click to hide internal directories.