ingest

Documentation

Index

• func GetEventKey(namespace string, ev event.Event) string
• type Collector
• type Deduplicator

Functions

func GetEventKey

func GetEventKey(namespace string, ev event.Event) string

CloudEvents are unique based on the source and id

Types

type Collector

type Collector interface {
	Ingest(ev event.Event, namespace string) error
	Close()
}

Collector is a receiver of events that handles sending those events to some downstream broker.

type Deduplicator

type Deduplicator interface {
	IsUnique(ctx context.Context, namespace string, ev event.Event) (bool, error)
	Set(ctx context.Context, namespace string, ev event.Event) (bool, error)
}