redisdedupe

Documentation

Overview

Package redisdedupe implements event deduplication using Redis.

Index

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

Types

type Deduplicator

type Deduplicator struct {
	Redis      *redis.Client
	Expiration time.Duration
}

Deduplicator implements event deduplication using Redis.

func (Deduplicator) IsUnique

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