Skip to content

Commit e6202f6

Browse files
committed
Fix broadcast metrics
1 parent 39d4d04 commit e6202f6

3 files changed

Lines changed: 5 additions & 1 deletion

File tree

liveactivities/src/main/scala/com/gu/liveactivities/BroadcastLambda.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,9 +77,11 @@ object BroadcastLambda extends RequestStreamHandler with Lambda with Logging {
7777
// to ensure the Lambda doesn't fail a healthy request that is just running slow.
7878
Try(Await.result(broadcastFuture, 160.seconds)) match {
7979
case Success(msg) => {
80+
metrics.increment(Metrics.BroadcastProcessed)
8081
logger.info(msg) // Broadcast successfully processed or processing is disabled by config msg.
8182
}
8283
case Failure(exception) => {
84+
metrics.increment(Metrics.BroadcastNotProcessed)
8385
logger.error(s"Failed to send broadcast ${if(shouldEndBroadcast)"END"} for liveActivityID $matchId: ${exception.getMessage}")
8486
throw exception
8587
}

liveactivities/src/main/scala/com/gu/liveactivities/service/BroadcastService.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ class BroadcastService(repository: ChannelMappingsRepository, broadcastApiClient
2424

2525
if (broadcastNotAllowed) {
2626
logger.warn(s"${requestPayload.eventType.asString} event ID $eventId not allowed after ${EndLiveActivityEvent.asString} for match ID $matchId")
27-
metrics.increment(Metrics.BroadcastNotProcessed)
27+
metrics.increment(Metrics.BroadcastNotAllowed)
2828
Future.successful(mapping.channelId)
2929
} else {
3030
for {

liveactivities/src/main/scala/com/gu/liveactivities/util/Metrics.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,9 @@ object Metrics {
4646
val ChannelManagerLambdaName = "channel-manager"
4747
val ChannelCleanUpLambdaName = "channel-cleanup"
4848

49+
val BroadcastProcessed = "BroadcastProcessed"
4950
val BroadcastNotProcessed = "BroadcastNotProcessed"
51+
val BroadcastNotAllowed = "BroadcastNotAllowed"
5052
val ChannelNotActive = "ChannelNotActive"
5153
val DuplicateEvent = "DuplicateEvent"
5254
val OutOfOrderEvent = "OutOfOrderEvent"

0 commit comments

Comments
 (0)