Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultRudderPath ¶
func DefaultRudderPath() string
Types ¶
type DedupHandleT ¶
type DedupHandleT struct {
// contains filtered or unexported fields
}
func New ¶
func New(path string, fns ...OptFn) *DedupHandleT
func (*DedupHandleT) Close ¶
func (d *DedupHandleT) Close()
func (*DedupHandleT) FindDuplicates ¶
func (d *DedupHandleT) FindDuplicates(messageIDs []string, allMessageIDsSet map[string]struct{}) (duplicateIndexes []int)
func (*DedupHandleT) MarkProcessed ¶
func (d *DedupHandleT) MarkProcessed(messageIDs []string)
MarkProcessed persist messageIDs in Disk, with expiry time of dedupWindow Any message mark here will appear in FindDuplicates() if queried inside the dedupWindow
func (*DedupHandleT) PrintHistogram ¶
func (d *DedupHandleT) PrintHistogram()
type DedupI ¶
type OptFn ¶
type OptFn func(*DedupHandleT)
func FromConfig ¶
func FromConfig() OptFn
func WithClearDB ¶
func WithClearDB() OptFn
func WithWindow ¶
Click to show internal directories.
Click to hide internal directories.