trace initials

Author: rekby

internal/topic/topicreaderinternal/stream_reader_impl.go

@@ -192,6 +192,7 @@ func (r *topicStreamReaderImpl) PopBatchTx(
 	tx tx.Transaction,
 	opts ReadMessageBatchOptions,
 ) (*topicreadercommon.PublicBatch, error) {
+
 	batch, err := r.ReadMessageBatch(ctx, opts)
 	if err != nil {
 		return nil, err

topic/topicreader/reader.go

@@ -93,6 +93,7 @@ func (r *Reader) PopBatchTx(ctx context.Context, transaction query.TxActor, opts
 	if err != nil {
 		return nil, err
 	}
+	internalTx.ID()
 
 	return r.reader.PopBatchTx(ctx, internalTx, opts...)
 }

trace/topic.go

@@ -63,6 +63,15 @@ type (
 			OnReadStreamUpdateTokenDoneInfo,
 		)
 
+		// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+		OnReaderPopBatchTx func(TopicReaderPopBatchTxStartInfo) func(TopicReaderPopBatchTxDoneInfo)
+
+		// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+		OnReaderUpdateOffsetsInTransaction func(TopicReaderOnUpdateOffsetsInTransactionStartInfo) func(TopicReaderOnUpdateOffsetsInTransactionDoneInfo)
+
+		// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+		OnReaderTransactionCompleted func(TopicReaderTransactionCompletedStartInfo) func(TopicReaderTransactionCompletedDoneInfo)
+
 		// TopicReaderMessageEvents
 
 		// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
@@ -298,6 +307,45 @@ type (
 		Error error
 	}
 
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderPopBatchTxStartInfo struct {
+		Context              *context.Context
+		ReaderConnectionID   string
+		TransactionSessionID string
+		TransactionID        string
+	}
+
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderPopBatchTxDoneInfo struct {
+		Error error
+	}
+
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderOnUpdateOffsetsInTransactionStartInfo struct {
+		Context              *context.Context
+		ReaderConnectionID   string
+		TransactionSessionID string
+		TransactionID        string
+	}
+
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderOnUpdateOffsetsInTransactionDoneInfo struct {
+		Error error
+	}
+
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderTransactionCompletedStartInfo struct {
+		Context              *context.Context
+		ReaderConnectionID   string
+		TransactionSessionID string
+		TransactionID        string
+		TransactionResult    error
+	}
+
+	// Internals: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#internals
+	TopicReaderTransactionCompletedDoneInfo struct {
+	}
+
 	////////////
 	//////////// TopicWriter
 	////////////