Mlp tests (#28411)

Author: nshestakov

ydb/core/persqueue/pqtablet/partition/mlp/mlp_storage.cpp

@@ -333,6 +333,10 @@ const std::deque<ui64>& TStorage::GetDLQMessages() const {
     return DLQQueue;
 }
 
+const std::unordered_set<ui32>& TStorage::GetLockedMessageGroupsId() const {
+    return LockedMessageGroupsId;
+}
+
 std::pair<TStorage::TMessage*, bool> TStorage::GetMessageInt(ui64 offset, EMessageStatus expectedStatus) {
     auto [message, slowZone] = GetMessageInt(offset);
     if (!message) {

ydb/core/persqueue/pqtablet/partition/mlp/mlp_storage.h

@@ -151,6 +151,7 @@ class TStorage {
     TInstant GetMessageDeadline(ui64 message);
     std::pair<const TMessage*, bool> GetMessage(ui64 message);
     const std::deque<ui64>& GetDLQMessages() const;
+    const std::unordered_set<ui32>& GetLockedMessageGroupsId() const;
 
 
     struct TPosition {

ydb/core/persqueue/pqtablet/partition/mlp/mlp_storage__serialization.cpp

@@ -310,6 +310,7 @@ bool TStorage::Initialize(const NKikimrPQ::TMLPStorageSnapshot& snapshot) {
                     ++Metrics.UnprocessedMessageCount;
                     break;
                 case EMessageStatus::DLQ:
+                    ++Metrics.DLQMessageCount;
                     break;
             }
         }