Skip to content

Commit 24d2a36

Browse files
author
panesher
committed
[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
1 parent 2b277d0 commit 24d2a36

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

yt/yt/client/object_client/helpers.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,7 @@ bool IsVersionedType(EObjectType type)
140140
case EObjectType::Pipeline:
141141
case EObjectType::QueueConsumer:
142142
case EObjectType::QueueProducer:
143+
case EObjectType::QueueMultiConsumer:
143144
case EObjectType::CypressProxyMap:
144145
return true;
145146

yt/yt/client/object_client/public.h

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,14 @@
44

55
#include <yt/yt/client/job_tracker_client/public.h>
66

7+
#include <library/cpp/yt/compact_containers/compact_flat_set.h>
8+
#include <library/cpp/yt/compact_containers/compact_vector.h>
9+
710
#include <library/cpp/yt/misc/enum.h>
811
#include <library/cpp/yt/misc/guid.h>
912
#include <library/cpp/yt/misc/hash.h>
1013
#include <library/cpp/yt/misc/strong_typedef.h>
1114

12-
#include <library/cpp/yt/compact_containers/compact_vector.h>
13-
#include <library/cpp/yt/compact_containers/compact_flat_set.h>
14-
1515
#include <library/cpp/yt/string/string_builder.h>
1616

1717
namespace NYT::NObjectClient {
@@ -368,6 +368,7 @@ DEFINE_ENUM(EObjectType,
368368
// Queue stuff
369369
((QueueConsumer) (1700))
370370
((QueueProducer) (1701))
371+
((QueueMultiConsumer) (1702))
371372
);
372373

373374
//! A bit mask marking schema types.

0 commit comments

Comments
 (0)