sink

func NewSink ¶

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

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

func NewSinkManager ¶

func NewSinkManager(
	stateStorageManager statestorage.Manager, sink sink.Sink,
) sink.Manager

func RegisterSink ¶

func RegisterSink(
	name config.SinkType, factory sink.Factory,
) bool

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