@@ -873,8 +873,10 @@ func TestSurveyor_AccountJetStreamJszLeaderOnly(t *testing.T) {
873873 regexp .MustCompile (`nats_stream_total_messages` ),
874874 regexp .MustCompile (`nats_consumer_ack_floor_consumer_seq` ),
875875 regexp .MustCompile (`nats_consumer_ack_floor_stream_seq` ),
876+ regexp .MustCompile (`nats_consumer_ack_floor_last_active` ),
876877 regexp .MustCompile (`nats_consumer_delivered_consumer_seq` ),
877878 regexp .MustCompile (`nats_consumer_delivered_stream_seq` ),
879+ regexp .MustCompile (`nats_consumer_delivered_last_active` ),
878880 regexp .MustCompile (`nats_consumer_num_ack_pending` ),
879881 regexp .MustCompile (`nats_consumer_num_pending` ),
880882 regexp .MustCompile (`nats_consumer_num_redelivered` ),
@@ -962,7 +964,7 @@ func TestSurveyor_AccountJetStreamJszLeaderOnly(t *testing.T) {
962964 totalConsumers ++
963965 }
964966 }
965- expectedConsumerMetrics := 120
967+ expectedConsumerMetrics := 150
966968 if totalConsumers != expectedConsumerMetrics {
967969 t .Errorf ("Expected %v, got %v" , expectedConsumerMetrics , totalConsumers )
968970 }
@@ -1054,8 +1056,10 @@ func TestSurveyor_AccountJetStreamJszFilters(t *testing.T) {
10541056 notWanted := []* regexp.Regexp {
10551057 regexp .MustCompile (`nats_consumer_ack_floor_consumer_seq` ),
10561058 regexp .MustCompile (`nats_consumer_ack_floor_stream_seq` ),
1059+ regexp .MustCompile (`nats_consumer_ack_floor_last_active` ),
10571060 regexp .MustCompile (`nats_consumer_delivered_consumer_seq` ),
10581061 regexp .MustCompile (`nats_consumer_delivered_stream_seq` ),
1062+ regexp .MustCompile (`nats_consumer_delivered_last_active` ),
10591063 regexp .MustCompile (`nats_consumer_num_redelivered` ),
10601064 regexp .MustCompile (`nats_consumer_num_waiting` ),
10611065 }
0 commit comments