gcm

Documentation

Index

• Constants
• func CreateGCMSink(uri *url.URL, _ extpoints.HeapsterConf) ([]sink_api.ExternalSink, error)
• func FullLabelName(name string) string
• func FullMetricName(name string) string
• type GcmCore
  • func NewCore() (*GcmCore, error)
  • func (self *GcmCore) GetEquivalentRateMetric(metric *sink_api.Point) (*Timeseries, error)
  • func (self *GcmCore) GetMetric(metric *sink_api.Point) (*Timeseries, error)
  • func (self *GcmCore) Register(name, description, metricType, valueType string, ...) error
  • func (self *GcmCore) StoreTimeseries(metrics map[string][]Timeseries) error
  • func (self *GcmCore) Unregister(name string) error
• type Timeseries

Constants

const GCMAuthScope = "https://www.googleapis.com/auth/monitoring"

Functions

func CreateGCMSink

func CreateGCMSink(uri *url.URL, _ extpoints.HeapsterConf) ([]sink_api.ExternalSink, error)

func FullLabelName

func FullLabelName(name string) string

func FullMetricName

func FullMetricName(name string) string

Types

type GcmCore

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

func NewCore

func NewCore() (*GcmCore, error)

Returns a thread-compatible implementation of GCM interactions.

func (*GcmCore) GetEquivalentRateMetric

func (self *GcmCore) GetEquivalentRateMetric(metric *sink_api.Point) (*Timeseries, error)

func (*GcmCore) GetMetric

func (self *GcmCore) GetMetric(metric *sink_api.Point) (*Timeseries, error)

func (*GcmCore) Register

func (self *GcmCore) Register(name, description, metricType, valueType string, labels []sink_api.LabelDescriptor) error

func (*GcmCore) StoreTimeseries

func (self *GcmCore) StoreTimeseries(metrics map[string][]Timeseries) error

func (*GcmCore) Unregister

func (self *GcmCore) Unregister(name string) error

type Timeseries

type Timeseries struct {
	TimeseriesDescriptor timeseriesDescriptor `json:"timeseriesDesc,omitempty"`
	Point                point                `json:"point,omitempty"`
}