package sinks

import "k8s.io/heapster/metrics/sinks"

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)

Source Files ¶

factory.go manager.go

Directories ¶