Documentation
¶
Overview ¶
This package implements the various storage backends supported by heapster.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.11.0
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 ¶ added in v0.17.0
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.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.