ingest

Documentation

Overview

Package ingest implements event ingestion.

Index

• type Collector
• type DeduplicatingCollector
• type Deduplicator
• type InMemoryCollector
• type IngestEventsRequest
• type Service

Types

type Collector

type Collector = ingest.Collector

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

type DeduplicatingCollector

type DeduplicatingCollector = ingest.DeduplicatingCollector

DeduplicatingCollector implements event deduplication at event ingestion.

type Deduplicator

type Deduplicator = dedupe.Deduplicator

Deduplicator checks if an event is unique.

type InMemoryCollector

type InMemoryCollector = ingest.InMemoryCollector

InMemoryCollector is a {Collector} backed by in-memory storage.

type IngestEventsRequest

type IngestEventsRequest = ingest.IngestEventsRequest

type Service

type Service = ingest.Service

Service implements the ingestion service.