cloudwatch

Documentation

Overview

Package cloudwatch implements a surfacer to export metrics to AWS Cloudwatch.

Index

• type CWSurfacer
  • func New(ctx context.Context, config *configpb.SurfacerConf, opts *options.Options, ...) (*CWSurfacer, error)
  • func (cw *CWSurfacer) Write(ctx context.Context, em *metrics.EventMetrics)

Types

type CWSurfacer

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

CWSurfacer implements AWS Cloudwatch surfacer.

func New

func New(ctx context.Context, config *configpb.SurfacerConf, opts *options.Options, l *logger.Logger) (*CWSurfacer, error)

New creates a new instance of a cloudwatch surfacer, based on the config passed in. It then hands off to a goroutine to surface metrics to cloudwatch across a buffered channel.

func (*CWSurfacer) Write

func (cw *CWSurfacer) Write(ctx context.Context, em *metrics.EventMetrics)

Write is a function defined to comply with the surfacer interface, and enables the cloudwatch surfacer to receive EventMetrics over the buffered channel.