cloudwatch

Documentation

Index

• Constants
• type CloudWatchClient
  • func (c *CloudWatchClient) Query(interval time.Duration, query []types.MetricDataQuery) (*cloudwatch.GetMetricDataOutput, error)
• type CloudWatchClientAPI
  • func NewCloudWatchAPIClient(metric v1alpha1.Metric, opts ...func(*cloudwatch.Options)) (CloudWatchClientAPI, error)
• type Provider
  • func NewCloudWatchProvider(api CloudWatchClientAPI, logCtx log.Entry) *Provider
  • func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, i int) error
  • func (p *Provider) GetMetadata(metric v1alpha1.Metric) map[string]string
  • func (p *Provider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *Provider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement
  • func (p *Provider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *Provider) Type() string

Constants

const (
	//ProviderType indicates the provider is cloudwatch
	ProviderType = "CloudWatch"
)

Types

type CloudWatchClient

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

func (*CloudWatchClient) Query

func (c *CloudWatchClient) Query(interval time.Duration, query []types.MetricDataQuery) (*cloudwatch.GetMetricDataOutput, error)

type CloudWatchClientAPI

type CloudWatchClientAPI interface {
	Query(interval time.Duration, query []types.MetricDataQuery) (*cloudwatch.GetMetricDataOutput, error)
}

func NewCloudWatchAPIClient

func NewCloudWatchAPIClient(metric v1alpha1.Metric, opts ...func(*cloudwatch.Options)) (CloudWatchClientAPI, error)

type Provider

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

Provider contains all the required components to run a CloudWatch query Implements the Provider Interface

func NewCloudWatchProvider

func NewCloudWatchProvider(api CloudWatchClientAPI, logCtx log.Entry) *Provider

NewCloudWatchProvider creates a new CloudWatch provider

func (*Provider) GarbageCollect

func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, i int) error

func (*Provider) GetMetadata

func (p *Provider) GetMetadata(metric v1alpha1.Metric) map[string]string

GetMetadata returns any additional metadata which needs to be stored & displayed as part of the metrics result.

func (*Provider) Resume

func (p *Provider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*Provider) Run

func (p *Provider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement

Run queries with CloudWatch provider for the metric

func (*Provider) Terminate

func (p *Provider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*Provider) Type

func (p *Provider) Type() string