cloudwatch

Documentation

Index

• func New() *cloudwatch.CloudWatch
• type API
  • func (a *API) IsEnabled() bool
  • func (a *API) Setup()
  • 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() *cloudwatch.CloudWatch

New returns a new session connection to Cloudwatch

Types

type API

type API struct {
	Client cloudwatchiface.CloudWatchAPI
}

API wraps a CloudWatch client interface

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled returns the boolean on whether the client is enabled

func (*API) Setup

func (a *API) Setup()

Setup creates a cloudwtach client

func (*API) UpdateKinesisDownscaleAlarm

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

UpdateKinesisDownscaleAlarm is the function that is responsible for downscaling the metrics which trigger the shard counts on Kinesis streams

func (*API) UpdateKinesisUpscaleAlarm

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

UpdateKinesisUpscaleAlarm is the function that is responsible for upscaling the metrics which trigger the shard counts change on Kinesis streams