sink

Documentation

Overview

Package that implements event sink logic.

Index

• func NewClickhouseStorage(config ClickHouseStorageConfig) *sink.ClickHouseStorage
• func NewSink(config SinkConfig) (*sink.Sink, error)
• type ClickHouseStorage
• type ClickHouseStorageConfig
• type FlushEventHandler
• type FlushSuccessEvent
• type Sink
• type SinkConfig
• type Storage

Functions

func NewClickhouseStorage

func NewClickhouseStorage(config ClickHouseStorageConfig) *sink.ClickHouseStorage

NewClickhouseStorage returns a ClickHouse Storage.

func NewSink

func NewSink(config SinkConfig) (*sink.Sink, error)

NewSink returns a sink processor.

Types

type ClickHouseStorage

type ClickHouseStorage = sink.ClickHouseStorage

type ClickHouseStorageConfig

type ClickHouseStorageConfig = sink.ClickHouseStorageConfig

type FlushEventHandler

type FlushEventHandler = sink.FlushEventHandler

type FlushSuccessEvent

type FlushSuccessEvent = sink.FlushSuccessEvent

type Sink

type Sink = sink.Sink

Sink is a streaming sink processor.

type SinkConfig

type SinkConfig = sink.SinkConfig

type Storage

type Storage = sink.Storage