sinks

Documentation

Index

• Constants
• func NewEventSinkManager(sinks []core.EventSink, exportEventsTimeout, stopTimeout time.Duration) (core.EventSink, error)
• type SinkFactory
  • func NewSinkFactory() *SinkFactory
  • func (this *SinkFactory) Build(uri flags.Uri) (core.EventSink, error)
  • func (this *SinkFactory) BuildAll(uris flags.Uris) []core.EventSink

Constants

const (
	DefaultSinkExportEventsTimeout = 20 * time.Second
	DefaultSinkStopTimeout         = 60 * time.Second
)

Functions

func NewEventSinkManager

func NewEventSinkManager(sinks []core.EventSink, exportEventsTimeout, stopTimeout time.Duration) (core.EventSink, error)

Types

type SinkFactory

type SinkFactory struct {
}

func NewSinkFactory

func NewSinkFactory() *SinkFactory

func (*SinkFactory) Build

func (this *SinkFactory) Build(uri flags.Uri) (core.EventSink, error)

func (*SinkFactory) BuildAll

func (this *SinkFactory) BuildAll(uris flags.Uris) []core.EventSink