manager

Documentation

Index

• type Manager
  • func NewManager(sources []source_api.Source, sinkManager sinks.ExternalSinkManager, ...) (Manager, error)
• type Uri
  • func (u *Uri) Set(value string) error
  • func (u *Uri) String() string
• type Uris
  • func (us *Uris) Set(value string) error
  • func (us *Uris) String() string

Types

type Manager

type Manager interface {
	// Housekeep collects data from all the configured sources and
	// stores the data to all the configured sinks.
	Housekeep()

	// HousekeepModel performs housekeeping for the Model entity
	HousekeepModel()

	// Export the latest data point of all metrics.
	ExportMetrics() ([]*sink_api.Point, error)

	// Set the sinks to use
	SetSinkUris(Uris) error

	// Get the sinks currently in use
	SinkUris() Uris

	// Get a reference to the cluster entity of the model, if it exists.
	GetCluster() model.Cluster
}

Manager provides an interface to control the core of heapster. Implementations are not required to be thread safe.

func NewManager

func NewManager(sources []source_api.Source, sinkManager sinks.ExternalSinkManager, res, bufferDuration time.Duration, useModel bool, modelRes time.Duration, align bool) (Manager, error)

type Uri

type Uri struct {
	Key string
	Val url.URL
}

func (*Uri) Set

func (u *Uri) Set(value string) error

func (*Uri) String

func (u *Uri) String() string

type Uris

type Uris []Uri

func (*Uris) Set

func (us *Uris) Set(value string) error

func (*Uris) String

func (us *Uris) String() string