memorydedupe

Documentation

Index

• type Collector
  • func NewCollector(config CollectorConfig) (*Collector, error)
  • func (c Collector) Close()
  • func (c Collector) Ingest(ev event.Event, namespace string) error
  • func (c Collector) IsUnique(ctx context.Context, namespace string, ev event.Event) (bool, error)
• type CollectorConfig

Types

type Collector

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

func NewCollector

func NewCollector(config CollectorConfig) (*Collector, error)

func (Collector) Close

func (c Collector) Close()

func (Collector) Ingest

func (c Collector) Ingest(ev event.Event, namespace string) error

TODO: pass contect to Ingest

func (Collector) IsUnique

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

type CollectorConfig

type CollectorConfig struct {
	Collector ingest.Collector
	Size      int
}