sinks

Documentation

Index

• Constants
• func NewDataSinkManager(sinks []core.DataSink, exportDataTimeout, stopTimeout time.Duration) (core.DataSink, error)
• type SinkFactory
  • func NewSinkFactory() *SinkFactory
  • func (this *SinkFactory) Build(uri flags.Uri) (core.DataSink, error)
  • func (this *SinkFactory) BuildAll(uris flags.Uris, historicalUri string, disableMetricSink bool) (*metricsink.MetricSink, []core.DataSink, core.HistoricalSource)

Constants

const (
	DefaultSinkStopTimeout = 60 * time.Second
)

Functions

func NewDataSinkManager

func NewDataSinkManager(sinks []core.DataSink, exportDataTimeout, stopTimeout time.Duration) (core.DataSink, error)

Types

type SinkFactory

type SinkFactory struct {
}

func NewSinkFactory

func NewSinkFactory() *SinkFactory

func (*SinkFactory) Build

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

func (*SinkFactory) BuildAll

func (this *SinkFactory) BuildAll(uris flags.Uris, historicalUri string, disableMetricSink bool) (*metricsink.MetricSink, []core.DataSink, core.HistoricalSource)