Function New

monitoring/cloudwatch/cloudwatch.go:40–73

New creates a new CloudWatch instance

(ctx context.Context, config *Config, stats *stats.Stats)

// New creates a new CloudWatch instance
func New(ctx context.Context, config *Config, stats *stats.Stats) (*CloudWatch, error) {
	if !config.Enabled() {
		return nil, nil
	}

	cw := &CloudWatch{
		config: config,
		stats:  stats,
	}

	if err := config.Validate(); err != nil {
		return nil, err
	}

	conf, err := awsConfig.LoadDefaultConfig(ctx)
	if err != nil {
		return nil, fmt.Errorf("can't load CloudWatch config: %w", err)
	}

	if len(config.Region) > 0 {
		conf.Region = config.Region
	}

	if len(conf.Region) == 0 {
		conf.Region = defaultAwsRegion
	}

	cw.client = cloudwatch.NewFromConfig(conf)
	cw.collectorCtx, cw.collectorCtxCancel = context.WithCancel(ctx)

	go cw.runMetricsCollector()

	return cw, nil
}

// Stop stops the CloudWatch metrics collection
func (cw *CloudWatch) Stop(ctx context.Context) {