File tree Expand file tree Collapse file tree 2 files changed +9
-0
lines changed
src/Ydb.Sdk/src/Services/Topic/Writer Expand file tree Collapse file tree 2 files changed +9
-0
lines changed Original file line number Diff line number Diff line change 1+ - Added SeqNo to ` WriteResult ` .
12- Changed signature of the ` TopicClient.DropTopic ` method.
23
34## v0.15.1
Original file line number Diff line number Diff 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>
You can’t perform that action at this time.
0 commit comments