cwmessagebatch

Documentation

Index

• func GZipBody(req *request.Request)
• type Aggregator
  • func (c *Aggregator) PutMetricData(input *cloudwatch.PutMetricDataInput) (*cloudwatch.PutMetricDataOutput, error)
  • func (c *Aggregator) PutMetricDataWithContext(ctx aws.Context, input *cloudwatch.PutMetricDataInput, reqs ...request.Option) (*cloudwatch.PutMetricDataOutput, error)
• type CloudwatchClient
• type Config

Functions

func GZipBody

func GZipBody(req *request.Request)

Types

type Aggregator

type Aggregator struct {
	Client *cloudwatch.CloudWatch
	Config Config
}

func (*Aggregator) PutMetricData

func (c *Aggregator) PutMetricData(input *cloudwatch.PutMetricDataInput) (*cloudwatch.PutMetricDataOutput, error)

func (*Aggregator) PutMetricDataWithContext

func (c *Aggregator) PutMetricDataWithContext(ctx aws.Context, input *cloudwatch.PutMetricDataInput, reqs ...request.Option) (*cloudwatch.PutMetricDataOutput, error)

Match API of cloudwatch interface

type CloudwatchClient

type CloudwatchClient interface {
	PutMetricDataWithContext(aws.Context, *cloudwatch.PutMetricDataInput, ...request.Option) (*cloudwatch.PutMetricDataOutput, error)
}

type Config

type Config struct {
	SkipResetUTC          bool
	SkipClearInvalidUnits bool
	SerialSends           bool
	OnDroppedDatum        func(datum *cloudwatch.MetricDatum)
}