Skip to content

Commit 50e7d92

Browse files
dev: Added SeqNo to WriteResult (#284)
1 parent 037497a commit 50e7d92

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
- Added SeqNo to `WriteResult`.
12
- Changed signature of the `TopicClient.DropTopic` method.
23

34
## v0.15.1

src/Ydb.Sdk/src/Services/Topic/Writer/WriteResult.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ public class WriteResult
88

99
internal WriteResult(StreamWriteMessage.Types.WriteResponse.Types.WriteAck ack)
1010
{
11+
SeqNo = ack.SeqNo;
12+
1113
switch (ack.MessageWriteStatusCase)
1214
{
1315
case StreamWriteMessage.Types.WriteResponse.Types.WriteAck.MessageWriteStatusOneofCase.Written:
@@ -16,6 +18,7 @@ internal WriteResult(StreamWriteMessage.Types.WriteResponse.Types.WriteAck ack)
1618
case StreamWriteMessage.Types.WriteResponse.Types.WriteAck.MessageWriteStatusOneofCase.Skipped:
1719
Status = PersistenceStatus.AlreadyWritten;
1820
break;
21+
case StreamWriteMessage.Types.WriteResponse.Types.WriteAck.MessageWriteStatusOneofCase.WrittenInTx:
1922
case StreamWriteMessage.Types.WriteResponse.Types.WriteAck.MessageWriteStatusOneofCase.None:
2023
default:
2124
throw new WriterException($"Unexpected WriteAck status: {ack.MessageWriteStatusCase}");
@@ -31,6 +34,11 @@ private WriteResult()
3134
/// The persistence status of the message
3235
/// </summary>
3336
public PersistenceStatus Status { get; }
37+
38+
/// <summary>
39+
/// SeqNo is a unique identifier within a specific ProducerId
40+
/// </summary>
41+
public long SeqNo { get; }
3442
}
3543

3644
/// <summary>

0 commit comments

Comments
 (0)