messages for shadow partition #1084
Conversation
ydb/core/persqueue/events/internal.h
Outdated
| struct TSuccess { | ||
| TString SourceId; | ||
| ui64 MinSeqNo, MaxSeqNo; | ||
| NKikimrPQ::TPartitionKeyRange KeyRange; |
There was a problem hiding this comment.
тут список ключей для ренейма, а не рендж. А лучше то, что в body лежит сразу
ydb/core/persqueue/events/internal.h
Outdated
| }; | ||
|
|
||
| struct TEvGetWriteInfoResponse : public TEventLocal<TEvGetWriteInfoResponse, EvGetWriteInfoResponse> { | ||
| struct TError { |
There was a problem hiding this comment.
тут надо сообщение об ошике, и его в Propose отдавать в итоге ( или в причине аборта транзакции)
There was a problem hiding this comment.
добавил текст сообщения об ошибке
ydb/core/persqueue/events/internal.h
Outdated
| }; | ||
|
|
||
| struct TSuccess { | ||
| TString SourceId; |
There was a problem hiding this comment.
тут вектор. Сорсидов может быть много.
| ui32 Cookie; // ShadowPartitionId | ||
| }; | ||
|
|
||
| struct TEvGetWriteInfoResponse : public TEventLocal<TEvGetWriteInfoResponse, EvGetWriteInfoResponse> { |
There was a problem hiding this comment.
split in 2 messages - writeinforesponse and writeinfoerror
ydb/core/persqueue/events/internal.h
Outdated
| struct TSuccess { | ||
| THashMap<TString, NPQ::TSeqNoRange> SeqNo; // SourceId -> (MinSeqNo, MaxSeqNo) | ||
| std::deque<NPQ::TDataKey> BodyKeys; | ||
| std::deque<NPQ::TBatch> Head; |
There was a problem hiding this comment.
Change to list of messages (MsgWrite)
| {} | ||
| }; | ||
|
|
||
| struct TDataKey { |
There was a problem hiding this comment.
TODO: Change caching proxy logic to process move commands too.
There was a problem hiding this comment.
I added it to the task of transferring data
Alek5andr-Kotov
force-pushed
the
LOGBROKER-8878
branch
from
b3d61ee to
00dee5e
Compare
Alek5andr-Kotov
force-pushed
the
LOGBROKER-8878
branch
from
7f74ed7 to
32351ec
Compare
|
⚪
|
|
⚪
|
ydb/core/persqueue/events/internal.h
Outdated
| THashMap<TString, NPQ::TSeqNoRange> seqNo, | ||
| std::deque<NPQ::TDataKey> bodyKeys, | ||
| std::deque<NPQ::TBatch> head) : | ||
| TVector<NPQ::TClientBlob> head) : |
There was a problem hiding this comment.
TVector && - будет лишнее копирование
Сообщения для служебной партиции. Позволяют получить информацию о записанных данных