sink

Documentation

Index

• type ProcessEventBatchFunc
• type Sink
  • func Init(name string, v *viper.Viper) (s Sink, err error)

Types

type ProcessEventBatchFunc

type ProcessEventBatchFunc func([]event.Event) error

ProcessEventBatchFunc processess event batches

type Sink

type Sink interface {
	ProcessEventsBatch([]event.Event) error
	common.Common
}

Sink represent a generic sink that handles events

func Init

func Init(name string, v *viper.Viper) (s Sink, err error)

Init initializes a sink from a viper subtree