sink

Documentation

Index

• func ListRegisteredSinkTypes() []string
• func Register(item SinkRegItem)
• type Configuration
• type Sink
  • func CreateSink(config Configuration) (Sink, error)
• type SinkConstructor
  • func GetConstructor(sinkName string) SinkConstructor
• type SinkRegItem
• type Stats

Functions

func ListRegisteredSinkTypes

func ListRegisteredSinkTypes() []string

func Register

func Register(item SinkRegItem)

The sink will register itself in `init`. During that the the logger may not be inited. So here we'd better not log anything

Types

type Configuration

type Configuration struct {
	Type       string                 `json:"type"`
	Properties map[string]interface{} `json:"properties"`
}

type Sink

type Sink interface {
	Write(headers []string, rows [][]interface{}, index int) error
	Init(name string, fields []common.Field) error
	GetStats() *Stats
}

func CreateSink

func CreateSink(config Configuration) (Sink, error)

type SinkConstructor

type SinkConstructor func(properties map[string]interface{}) (Sink, error)

func GetConstructor

func GetConstructor(sinkName string) SinkConstructor

type SinkRegItem

type SinkRegItem struct {
	Name        string
	Constructor SinkConstructor
}

type Stats

type Stats struct {
	SuccessWrite int
	FailedWrite  int
}