memorydedupe

Documentation

Overview

Package memorydedupe implements in-memory event deduplication.

Index

• type Deduplicator
  • func NewDeduplicator(size int) (*Deduplicator, error)
  • func (d *Deduplicator) CheckUnique(ctx context.Context, item dedupe.Item) (bool, error)
  • func (d *Deduplicator) Close() error
  • func (d *Deduplicator) IsUnique(ctx context.Context, namespace string, ev event.Event) (bool, error)
  • func (d *Deduplicator) Set(ctx context.Context, items ...dedupe.Item) error

Types

type Deduplicator

type Deduplicator struct {
	// contains filtered or unexported fields
}

Deduplicator implements in-memory event deduplication.

func NewDeduplicator

func NewDeduplicator(size int) (*Deduplicator, error)

NewDeduplicator returns a new {Deduplicator}.

func (*Deduplicator) CheckUnique

func (d *Deduplicator) CheckUnique(ctx context.Context, item dedupe.Item) (bool, error)

func (*Deduplicator) Close

func (d *Deduplicator) Close() error

func (*Deduplicator) IsUnique

func (d *Deduplicator) IsUnique(ctx context.Context, namespace string, ev event.Event) (bool, error)

func (*Deduplicator) Set

func (d *Deduplicator) Set(ctx context.Context, items ...dedupe.Item) error