summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorpanesher <[email protected]>2026-07-16 11:52:03 +0300
committerpanesher <[email protected]>2026-07-17 12:33:26 +0300
commit2c4547384335d164cbfc6e6480e1d4480e2b98be (patch)
treee3ad9d5b15e9f8768f58413ed2221027123bed89
parent76f1ce35ad03a3ccd28f88b759591137ce0be247 (diff)
[queues] feature YT-28252: Support create queue_consumer for multi-consumer
* Changelog entry Type: feature Component: proxy Added `queue_multi_consumer` as a create entity type. Use `create queue_multi_consumer` to create a multi-consumer queue table. commit_hash:90476fa5c865ad615e6e29eec8c8a9e041e90cba
-rw-r--r--yt/yt/client/object_client/helpers.cpp1
-rw-r--r--yt/yt/client/object_client/public.h7
2 files changed, 5 insertions, 3 deletions
diff --git a/yt/yt/client/object_client/helpers.cpp b/yt/yt/client/object_client/helpers.cpp
index facf1ae54d8..45746d9150e 100644
--- a/yt/yt/client/object_client/helpers.cpp
+++ b/yt/yt/client/object_client/helpers.cpp
@@ -140,6 +140,7 @@ bool IsVersionedType(EObjectType type)
case EObjectType::Pipeline:
case EObjectType::QueueConsumer:
case EObjectType::QueueProducer:
+ case EObjectType::QueueMultiConsumer:
case EObjectType::CypressProxyMap:
return true;
diff --git a/yt/yt/client/object_client/public.h b/yt/yt/client/object_client/public.h
index ae8d918bab1..6c6e9a31fba 100644
--- a/yt/yt/client/object_client/public.h
+++ b/yt/yt/client/object_client/public.h
@@ -4,14 +4,14 @@
#include <yt/yt/client/job_tracker_client/public.h>
+#include <library/cpp/yt/compact_containers/compact_flat_set.h>
+#include <library/cpp/yt/compact_containers/compact_vector.h>
+
#include <library/cpp/yt/misc/enum.h>
#include <library/cpp/yt/misc/guid.h>
#include <library/cpp/yt/misc/hash.h>
#include <library/cpp/yt/misc/strong_typedef.h>
-#include <library/cpp/yt/compact_containers/compact_vector.h>
-#include <library/cpp/yt/compact_containers/compact_flat_set.h>
-
#include <library/cpp/yt/string/string_builder.h>
namespace NYT::NObjectClient {
@@ -368,6 +368,7 @@ DEFINE_ENUM(EObjectType,
// Queue stuff
((QueueConsumer) (1700))
((QueueProducer) (1701))
+ ((QueueMultiConsumer) (1702))
);
//! A bit mask marking schema types.