gcm

Documentation

Index

• Constants
• func CreateGCMSink(_ string, _ map[string][]string) ([]sink_api.ExternalSink, error)
• 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
• type Timeseries

Constants

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

Functions

func CreateGCMSink

func CreateGCMSink(_ string, _ map[string][]string) ([]sink_api.ExternalSink, error)

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

type Timeseries

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