sink

Documentation

Index

• func RegisterSink(name config.SinkType, provider Provider) bool
• type Context
• type Provider
• type Sink
  • func NewSink(name config.SinkType, config *config.Config) (Sink, error)
• type SinkFunc
  • func (sf SinkFunc) Emit(context Context, timestamp time.Time, topicName string, ...) error
  • func (sf SinkFunc) Start() error
  • func (sf SinkFunc) Stop() error

Functions

func RegisterSink

func RegisterSink(name config.SinkType, provider Provider) bool

RegisterSink registers a config.SinkType to a Provider implementation which creates the Sink when requested

Types

type Context

type Context interface {
	SetTransientAttribute(key string, value string)
	TransientAttribute(key string) (value string, present bool)
	SetAttribute(key string, value string)
	Attribute(key string) (value string, present bool)
}

type Provider

type Provider = func(config *config.Config) (Sink, error)

type Sink

type Sink interface {
	Start() error
	Stop() error
	Emit(context Context, timestamp time.Time, topicName string, key, envelope schema.Struct) error
}

func NewSink

func NewSink(name config.SinkType, config *config.Config) (Sink, error)

NewSink instantiates a new instance of the requested Sink when available, otherwise returns an error.

type SinkFunc

type SinkFunc func(context Context, timestamp time.Time, topicName string, key, envelope schema.Struct) error

func (SinkFunc) Emit

func (sf SinkFunc) Emit(context Context, timestamp time.Time, topicName string, key, envelope schema.Struct) error

func (SinkFunc) Start

func (sf SinkFunc) Start() error

func (SinkFunc) Stop

func (sf SinkFunc) Stop() error