cloudwatch

Documentation

Index

• func New(cfg iaws.Config) *cloudwatch.CloudWatch
• type API
  • func (a *API) IsEnabled() bool
  • func (a *API) Setup(cfg iaws.Config)
  • func (a *API) UpdateKinesisAlarmState(ctx aws.Context, name, reason string) error
  • func (a *API) UpdateKinesisDownscaleAlarm(ctx aws.Context, name, stream, topic string, shards int64) error
  • func (a *API) UpdateKinesisUpscaleAlarm(ctx aws.Context, name, stream, topic string, shards int64) error

Functions

func New

func New(cfg iaws.Config) *cloudwatch.CloudWatch

New returns a configured CloudWatch client.

Types

type API

type API struct {
	Client cloudwatchiface.CloudWatchAPI
}

API wraps the CloudWatch API interface.

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled returns true if the client is enabled and ready for use.

func (*API) Setup

func (a *API) Setup(cfg iaws.Config)

Setup creates a new CloudWatch client.

func (*API) UpdateKinesisAlarmState

func (a *API) UpdateKinesisAlarmState(ctx aws.Context, name, reason string) error

func (*API) UpdateKinesisDownscaleAlarm

func (a *API) UpdateKinesisDownscaleAlarm(ctx aws.Context, name, stream, topic string, shards int64) error

UpdateKinesisDownscaleAlarm updates CloudWatch alarms that manage the scale down tracking for Kinesis streams.

func (*API) UpdateKinesisUpscaleAlarm

func (a *API) UpdateKinesisUpscaleAlarm(ctx aws.Context, name, stream, topic string, shards int64) error

UpdateKinesisUpscaleAlarm updates CloudWatch alarms that manage the scale up tracking for Kinesis streams.