stackdriver

Documentation

Index

• func NewTelemetrySink(logger lager.Logger, client MetricClient, ...) telemetry.Sink
• type LogAdapter
  • func NewLogAdapter(projectID string, batchCount int, batchDuration time.Duration, inFlight int) (LogAdapter, <-chan error)
• type MetricAdapter
  • func NewMetricAdapter(projectID string, client MetricClient, batchSize int, logger lager.Logger) (MetricAdapter, error)
• type MetricClient
  • func NewMetricClient() (MetricClient, error)

Functions

func NewTelemetrySink

func NewTelemetrySink(logger lager.Logger, client MetricClient, projectID, subscriptionID, foundation string) telemetry.Sink

NewTelemetrySink provides a telemetry.Sink that writes metrics to Stackdriver Monitoring

Types

type LogAdapter

type LogAdapter interface {
	PostLog(*messages.Log)
	Flush() error
}

func NewLogAdapter

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

NewLogAdapter returns a LogAdapter that can post to Stackdriver Logging.

type MetricAdapter

type MetricAdapter interface {
	PostMetrics([]*messages.Metric)
}

func NewMetricAdapter

func NewMetricAdapter(projectID string, client MetricClient, batchSize int, logger lager.Logger) (MetricAdapter, error)

NewMetricAdapter returns a MetricAdapater that can write to Stackdriver Monitoring

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)