redisdedupe

Documentation

Overview

Package redisdedupe implements event deduplication using Redis.

Index

• type Deduplicator
  • 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 {
	Redis      *redis.Client
	Expiration time.Duration
}

Deduplicator implements event deduplication using Redis.

func (Deduplicator) CheckUnique

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

CheckUnique checks if the event is unique based on the key

func (Deduplicator) Close

func (d Deduplicator) Close() error

Close closes underlying redis client

func (Deduplicator) IsUnique

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

IsUnique checks if an event is unique AND adds it to the deduplication index.

func (Deduplicator) Set

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

Set sets events into redis