stackdriver

Documentation

Index

• type Heartbeater
• type Log
• type LogAdapter
  • func NewLogAdapter(projectID string, batchCount int, batchDuration time.Duration, ...) (LogAdapter, <-chan error)
• type Metric
  • func (m *Metric) Hash() string
• type MetricAdapter
  • func NewMetricAdapter(projectID string, client MetricClient, heartbeater Heartbeater) (MetricAdapter, error)
• type MetricClient
  • func NewMetricClient() (MetricClient, error)
• type MetricsBuffer
  • func NewAutoCulledMetricsBuffer(ctx context.Context, logger lager.Logger, frequency time.Duration, size int, ...) (MetricsBuffer, <-chan error)
  • func NewMetricsBuffer(size int, adapter MetricAdapter) (MetricsBuffer, <-chan error)

Types

type Heartbeater

type Heartbeater interface {
	Start()
	Increment(string)
	Stop()
}

type Log

type Log struct {
	Payload  interface{}
	Labels   map[string]string
	Severity logging.Severity
}

type LogAdapter

type LogAdapter interface {
	PostLog(*Log)
	Flush()
}

func NewLogAdapter

func NewLogAdapter(projectID string, batchCount int, batchDuration time.Duration, heartbeater Heartbeater) (LogAdapter, <-chan error)

type Metric

type Metric struct {
	Name      string
	Value     float64
	Labels    map[string]string
	EventTime time.Time
	Unit      string // TODO Should this be "1" if it's empty?
}

func (*Metric) Hash

func (m *Metric) Hash() string

type MetricAdapter

type MetricAdapter interface {
	PostMetrics([]Metric) error
}

func NewMetricAdapter

func NewMetricAdapter(projectID string, client MetricClient, heartbeater Heartbeater) (MetricAdapter, error)

type MetricClient

type MetricClient interface {
	Post(*monitoringpb.CreateTimeSeriesRequest) error
	CreateMetricDescriptor(*monitoringpb.CreateMetricDescriptorRequest) error
	ListMetricDescriptors(*monitoringpb.ListMetricDescriptorsRequest) ([]*metricpb.MetricDescriptor, error)
}

func NewMetricClient

func NewMetricClient() (MetricClient, error)

type MetricsBuffer

type MetricsBuffer interface {
	PostMetric(*Metric)
	IsEmpty() bool
}

func NewAutoCulledMetricsBuffer

func NewAutoCulledMetricsBuffer(ctx context.Context, logger lager.Logger, frequency time.Duration,
	size int, adapter MetricAdapter) (MetricsBuffer, <-chan error)

func NewMetricsBuffer

func NewMetricsBuffer(size int, adapter MetricAdapter) (MetricsBuffer, <-chan error)