sinks

Documentation

Overview

This package implements the various storage backends supported by heapster.

Index

• type ExternalSinkManager
  • func NewExternalSinkManager(externalSinks []sink_api.ExternalSink, cache cache.Cache, ...) (ExternalSinkManager, error)
• type Sink

Types

type ExternalSinkManager

type ExternalSinkManager interface {
	Sink
	// SetSinks changes the sinks to be used and registers/unregisters
	// them accordingly.
	SetSinks([]v1.ExternalSink) error
}

func NewExternalSinkManager

func NewExternalSinkManager(externalSinks []sink_api.ExternalSink, cache cache.Cache, syncFrequency time.Duration) (ExternalSinkManager, error)

NewExternalSinkManager returns an external sink manager that will manage pushing data to all the sinks in 'externalSinks', which is a map of sink name to ExternalSink object.

type Sink

type Sink interface {
	// Sync starts exporting stats periodically to backends.
	// Returns a channel that can be used to stop syncing.
	Sync() chan<- struct{}
	DebugInfo() string
}

TODO: Once in-memory storage is implemented, make the manager extract data from the in-memory store periodically.