diff options
| author | panesher <[email protected]> | 2026-07-16 11:52:03 +0300 |
|---|---|---|
| committer | panesher <[email protected]> | 2026-07-17 12:33:26 +0300 |
| commit | 2c4547384335d164cbfc6e6480e1d4480e2b98be (patch) | |
| tree | e3ad9d5b15e9f8768f58413ed2221027123bed89 | |
| parent | 76f1ce35ad03a3ccd28f88b759591137ce0be247 (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.cpp | 1 | ||||
| -rw-r--r-- | yt/yt/client/object_client/public.h | 7 |
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. |
