cloudwatch

Documentation

Index

• type CloudWatch
• type CloudWatchClient
  • func NewCloudWatchClient(queue string, region string) *CloudWatchClient
  • func (s *CloudWatchClient) Age() (float64, error)
  • func (s *CloudWatchClient) GetQueueMetric(metric string, statistic string) (*cloudwatch.Datapoint, error)
  • func (s *CloudWatchClient) NumDeleted() (float64, error)
  • func (s *CloudWatchClient) NumEmpty() (float64, error)
  • func (s *CloudWatchClient) NumSent() (float64, error)

Types

type CloudWatch

type CloudWatch interface {
	GetMetricStatistics(*cloudwatch.GetMetricStatisticsInput) (*cloudwatch.GetMetricStatisticsOutput, error)
}

type CloudWatchClient

type CloudWatchClient struct {
	Client CloudWatch
	Queue  string
}

func NewCloudWatchClient

func NewCloudWatchClient(queue string, region string) *CloudWatchClient

func (*CloudWatchClient) Age

func (s *CloudWatchClient) Age() (float64, error)

func (*CloudWatchClient) GetQueueMetric

func (s *CloudWatchClient) GetQueueMetric(metric string, statistic string) (*cloudwatch.Datapoint, error)

func (*CloudWatchClient) NumDeleted

func (s *CloudWatchClient) NumDeleted() (float64, error)

func (*CloudWatchClient) NumEmpty

func (s *CloudWatchClient) NumEmpty() (float64, error)

func (*CloudWatchClient) NumSent

func (s *CloudWatchClient) NumSent() (float64, error)