track oversize block errors in metrics

2020-11-17 17:18:49 -05:00
parent e23170d194
commit 8191654089
1 changed files with 2 additions and 0 deletions
@@ -342,6 +342,8 @@ func (bv *BlockValidator) validateLocalBlock(ctx context.Context, msg *pubsub.Me

 	if size := msg.Size(); size > 1<<20-1<<15 {
 		log.Errorf("ignoring oversize block (%dB)", size)
+		ctx, _ = tag.New(ctx, tag.Insert(metrics.FailureType, "oversize_block"))
+		stats.Record(ctx, metrics.BlockValidationFailure.M(1))
 		return pubsub.ValidationIgnore
 	}