aws

Documentation

Index

• Variables
• type ApiGateway
  • func (agw *ApiGateway) Dimension(arn arn.ARN) (types.Dimension, error)
  • func (agw *ApiGateway) GetErrorRateMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (agw *ApiGateway) GetLatencyAboveThresholdPerMin(arn arn.ARN, from, to time.Time, threshold float64) (*cloudwatch.GetMetricDataInput, error)
  • func (agw *ApiGateway) GetLatencyMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (agw *ApiGateway) Namespace() string
• type AwsCloudWatch
  • func NewAwsCloudWatch() (cw *AwsCloudWatch, err error)
  • func (cw *AwsCloudWatch) Close() error
  • func (cw *AwsCloudWatch) Get99PercentLatencyMetricForResource(resourceID string, from, to time.Time) (float64, error)
  • func (cw *AwsCloudWatch) GetAvailabilityPercentage(resourceID string, from, to time.Time) (float64, error)
  • func (cw *AwsCloudWatch) GetErrorPercentageMetricForResource(resourceID string, from, to time.Time) (float64, error)
  • func (cw *AwsCloudWatch) GetLatencyAboveThresholdPercentage(resourceID string, from, to time.Time, threshold int) (float64, error)
  • func (cw *AwsCloudWatch) ResourceFromSelector(s entities.Selector) string
• type AwsCloudWatchClient
• type AwsMetricsProvider
• type AwsResource
  • func (r *AwsResource) IsSupportedService() bool
  • func (r *AwsResource) MetricProvider() (provider AwsMetricsProvider, err error)
• type ElasticLoadBalancer
  • func (elb *ElasticLoadBalancer) Dimension(arn arn.ARN) (types.Dimension, error)
  • func (elb *ElasticLoadBalancer) GetErrorRateMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (elb *ElasticLoadBalancer) GetLatencyAboveThresholdPerMin(arn arn.ARN, from, to time.Time, threshold float64) (*cloudwatch.GetMetricDataInput, error)
  • func (elb *ElasticLoadBalancer) GetLatencyMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (elb *ElasticLoadBalancer) Namespace() string

Variables

var SelectorKeys = []string{
	"aws_arn",
}

SelectorKeys - a list of all supported AWS specific selector keys

Types

type ApiGateway

type ApiGateway struct{}

func (*ApiGateway) Dimension

func (agw *ApiGateway) Dimension(arn arn.ARN) (types.Dimension, error)

func (*ApiGateway) GetErrorRateMetricDataInput

func (agw *ApiGateway) GetErrorRateMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

func (*ApiGateway) GetLatencyAboveThresholdPerMin

func (agw *ApiGateway) GetLatencyAboveThresholdPerMin(
	arn arn.ARN, from, to time.Time, threshold float64) (*cloudwatch.GetMetricDataInput, error)

func (*ApiGateway) GetLatencyMetricDataInput

func (agw *ApiGateway) GetLatencyMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

func (*ApiGateway) Namespace

func (agw *ApiGateway) Namespace() string

type AwsCloudWatch

type AwsCloudWatch struct{}

func NewAwsCloudWatch

func NewAwsCloudWatch() (cw *AwsCloudWatch, err error)

NewAwsCloudWatch is the factory function for AWS cloud watch metric provider

func (*AwsCloudWatch) Close

func (cw *AwsCloudWatch) Close() error

Nothing to do for AWS... We don't want to close anything as providers are cached.

func (*AwsCloudWatch) Get99PercentLatencyMetricForResource

func (cw *AwsCloudWatch) Get99PercentLatencyMetricForResource(resourceID string, from, to time.Time) (float64, error)

func (*AwsCloudWatch) GetAvailabilityPercentage

func (cw *AwsCloudWatch) GetAvailabilityPercentage(resourceID string, from, to time.Time) (float64, error)

func (*AwsCloudWatch) GetErrorPercentageMetricForResource

func (cw *AwsCloudWatch) GetErrorPercentageMetricForResource(resourceID string, from, to time.Time) (float64, error)

func (*AwsCloudWatch) GetLatencyAboveThresholdPercentage

func (cw *AwsCloudWatch) GetLatencyAboveThresholdPercentage(resourceID string, from, to time.Time, threshold int) (float64, error)

func (*AwsCloudWatch) ResourceFromSelector

func (cw *AwsCloudWatch) ResourceFromSelector(s entities.Selector) string

ResourceFromSelector - identifies the resource ID given a selector.

type AwsCloudWatchClient

type AwsCloudWatchClient interface {
	GetMetricData(ctx context.Context, params *cloudwatch.GetMetricDataInput,
		optFns ...func(*cloudwatch.Options)) (*cloudwatch.GetMetricDataOutput, error)
}

type AwsMetricsProvider

type AwsMetricsProvider interface {
	Namespace() string
	Dimension(arn.ARN) (types.Dimension, error)
	GetErrorRateMetricDataInput(arn.ARN, time.Time, time.Time) (*cloudwatch.GetMetricDataInput, error)
	GetLatencyMetricDataInput(arn.ARN, time.Time, time.Time) (*cloudwatch.GetMetricDataInput, error)
	GetLatencyAboveThresholdPerMin(arn.ARN, time.Time, time.Time, float64) (*cloudwatch.GetMetricDataInput, error)
}

type AwsResource

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

func (*AwsResource) IsSupportedService

func (r *AwsResource) IsSupportedService() bool

IsSupportedService indicates wether the resource is supported for metrics retrieval

func (*AwsResource) MetricProvider

func (r *AwsResource) MetricProvider() (provider AwsMetricsProvider, err error)

type ElasticLoadBalancer

type ElasticLoadBalancer struct{}

func (*ElasticLoadBalancer) Dimension

func (elb *ElasticLoadBalancer) Dimension(arn arn.ARN) (types.Dimension, error)

func (*ElasticLoadBalancer) GetErrorRateMetricDataInput

func (elb *ElasticLoadBalancer) GetErrorRateMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

func (*ElasticLoadBalancer) GetLatencyAboveThresholdPerMin

func (elb *ElasticLoadBalancer) GetLatencyAboveThresholdPerMin(
	arn arn.ARN, from, to time.Time, threshold float64) (*cloudwatch.GetMetricDataInput, error)

func (*ElasticLoadBalancer) GetLatencyMetricDataInput

func (elb *ElasticLoadBalancer) GetLatencyMetricDataInput(arn arn.ARN, from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

func (*ElasticLoadBalancer) Namespace

func (elb *ElasticLoadBalancer) Namespace() string