aws

Documentation

Index

• type AwsCloudWatch
  • func NewAwsCloudWatch() (cw *AwsCloudWatch, err error)
  • func (cw *AwsCloudWatch) Get99PercentLatencyMetricForResource(resourceID string, from, to time.Time) (float64, error)
  • func (cw *AwsCloudWatch) GetErrorPercentageMetricForResource(resourceID string, from, to time.Time) (float64, error)
• type AwsCloudWatchClient
• type AwsResource
  • func (r *AwsResource) GetErrorRateMetricDataInput(from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (r *AwsResource) GetLatencyMetricDataInput(from, to time.Time) (*cloudwatch.GetMetricDataInput, error)
  • func (r *AwsResource) IsSupportedService() bool
  • func (r *AwsResource) MetricNamespace() string

Types

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) Get99PercentLatencyMetricForResource

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

func (*AwsCloudWatch) GetErrorPercentageMetricForResource

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

type AwsCloudWatchClient

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

type AwsResource

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

func (*AwsResource) GetErrorRateMetricDataInput

func (r *AwsResource) GetErrorRateMetricDataInput(from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

GetErrorRateMetricDataInput retuns the MetricDataInput struct for querying with cloud watch API. It must ONLY return a single value for the required 'error_rate_percent' metric ID This function handles data input depending on different targeted AWS Service

func (*AwsResource) GetLatencyMetricDataInput

func (r *AwsResource) GetLatencyMetricDataInput(from, to time.Time) (*cloudwatch.GetMetricDataInput, error)

func (*AwsResource) IsSupportedService

func (r *AwsResource) IsSupportedService() bool

IsSupportedService indicates wether the resource is supported for metrics retrieval

func (*AwsResource) MetricNamespace

func (r *AwsResource) MetricNamespace() string