sns scope (#214)

runatlantis · Mar 23, 2022 · 5de3318 · 5de3318
1 parent 8d6c504
commit 5de3318
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/server/lyft/aws/sns/writer.go b/server/lyft/aws/sns/writer.go
@@ -28,7 +28,7 @@ func NewWriterWithStats(
 	scope tally.Scope,
 ) Writer {
 	return &writerWithStats{
-		scope: scope.SubScope("aws.sns"),
+		scope: scope,
 		Writer: &writer{
 			client:   awsSns.New(session),
 			topicArn: aws.String(topicArn),

diff --git a/server/server.go b/server/server.go
@@ -645,7 +645,7 @@ func NewServer(userConfig UserConfig, config Config) (*Server, error) {
 		snsWriter = sns.NewWriterWithStats(
 			session,
 			userConfig.LyftAuditJobsSnsTopicArn,
-			statsScope,
+			statsScope.SubScope("aws.sns.jobs"),
 		)
 	} else {
 		snsWriter = sns.NewNoopWriter()
@@ -877,7 +877,7 @@ func NewServer(userConfig UserConfig, config Config) (*Server, error) {
 	)
 
 	ctx, cancel := context.WithCancel(context.Background())
-	gatewaySnsWriter := sns.NewWriterWithStats(session, userConfig.LyftGatewaySnsTopicArn, statsScope)
+	gatewaySnsWriter := sns.NewWriterWithStats(session, userConfig.LyftGatewaySnsTopicArn, statsScope.SubScope("aws.sns.gateway"))
 	autoplanValidator := &gateway.AutoplanValidator{
 		Logger:                        logger,
 		Scope:                         statsScope.SubScope("validator"),