sinks

Documentation

Overview

This package implements the various storage backends supported by heapster.

Index

• type ExternalSinkManager
  • func NewBigQuerySink() (ExternalSinkManager, error)
  • func NewExternalSinkManager(externalSinks []sink_api.ExternalSink) (ExternalSinkManager, error)
  • func NewMemorySink() ExternalSinkManager
• type MemorySink
  • func (self *MemorySink) DebugInfo() string
  • func (self *MemorySink) Store(data interface{}) error

Types

type ExternalSinkManager

type ExternalSinkManager 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() (ExternalSinkManager, error)

Create a new bigquery storage driver.

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.

func NewMemorySink

func NewMemorySink() ExternalSinkManager

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