sinks

Documentation

Overview

This package implements the various storage backends supported by heapster.

Index

• type ExternalSinkManager
  • func NewExternalSinkManager(externalSinks []sink_api.ExternalSink) (ExternalSinkManager, error)
• type MemorySink
  • func (self *MemorySink) DebugInfo() string
  • func (self *MemorySink) Store(data interface{}) error
• type Sink
  • func NewBigQuerySink() (Sink, error)
  • func NewMemorySink() 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) (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 MemorySink

type MemorySink struct {
	// contains filtered or unexported fields
}

func (*MemorySink) DebugInfo

func (self *MemorySink) DebugInfo() string

func (*MemorySink) Store

func (self *MemorySink) Store(data interface{}) error

type Sink

type Sink interface {
	Store(input interface{}) error
	DebugInfo() string
}

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

func NewBigQuerySink

func NewBigQuerySink() (Sink, error)

Create a new bigquery storage driver.

func NewMemorySink

func NewMemorySink() Sink