Skip to content

Commit 7a46c62

Browse files
authored
move quote to separate dir (#31172)
1 parent 371f8ee commit 7a46c62

File tree

15 files changed

+25
-10
lines changed

15 files changed

+25
-10
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
#include "partition_init.h"
88
#include "partition_sourcemanager.h"
99
#include "partition_types.h"
10-
#include "read_quoter.h"
1110
#include "sourceid.h"
1211
#include "subscriber.h"
1312
#include "user_info.h"
@@ -20,6 +19,7 @@
2019
#include <ydb/core/persqueue/common/key.h>
2120
#include <ydb/core/persqueue/pqtablet/blob/blob.h>
2221
#include <ydb/core/persqueue/pqtablet/blob/header.h>
22+
#include <ydb/core/persqueue/pqtablet/quota/read_quoter.h>
2323
#include <ydb/core/persqueue/public/utils.h>
2424
#include <ydb/core/protos/feature_flags.pb.h>
2525
#include <ydb/library/actors/core/actor.h>

ydb/core/persqueue/pqtablet/partition/user_info.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
#pragma once
22

3-
#include "account_read_quoter.h"
4-
53
#include "working_time_counter.h"
64
#include "subscriber.h"
75
#include <ydb/core/persqueue/public/counters/percentile_counter.h>

ydb/core/persqueue/pqtablet/partition/ya.make

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
LIBRARY()
22

33
SRCS(
4-
account_read_quoter.cpp
54
autopartitioning_manager.cpp
65
consumer_offset_tracker.cpp
76
message_id_deduplicator.cpp
@@ -17,12 +16,9 @@ SRCS(
1716
partition_read.cpp
1817
partition_sourcemanager.cpp
1918
partition_write.cpp
20-
quota_tracker.cpp
21-
read_quoter.cpp
2219
sourceid.cpp
2320
subscriber.cpp
2421
user_info.cpp
25-
write_quoter.cpp
2622
)
2723

2824

@@ -39,6 +35,7 @@ PEERDIR(
3935
ydb/core/persqueue/pqtablet/common
4036
ydb/core/persqueue/pqtablet/partition/mirrorer
4137
ydb/core/persqueue/pqtablet/partition/mlp
38+
ydb/core/persqueue/pqtablet/quota
4239
)
4340

4441
END()

ydb/core/persqueue/pqtablet/pq_impl.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
#include <ydb/core/persqueue/dread_cache_service/caching_service.h>
1919
#include <ydb/core/persqueue/pqtablet/common/constants.h>
2020
#include <ydb/core/persqueue/pqtablet/partition/sourceid.h> // FIXME move sourceid
21-
#include <ydb/core/persqueue/pqtablet/partition/read_quoter.h> // FIXME move read_quoter
21+
#include <ydb/core/persqueue/pqtablet/quota/read_quoter.h>
2222
#include <ydb/core/persqueue/public/config.h>
2323
#include <ydb/core/persqueue/public/partition_key_range/partition_key_range.h>
2424
#include <ydb/core/persqueue/writer/writer.h>

ydb/core/persqueue/pqtablet/partition/account_read_quoter.cpp renamed to ydb/core/persqueue/pqtablet/quota/account_read_quoter.cpp

File renamed without changes.

ydb/core/persqueue/pqtablet/partition/account_read_quoter.h renamed to ydb/core/persqueue/pqtablet/quota/account_read_quoter.h

File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.

0 commit comments

Comments
 (0)