fix public files for changes internal type location

Author: rekby

internal/topic/topicreadercommon/batch.go

@@ -117,12 +117,6 @@ func (m *PublicBatch) PartitionID() int64 {
 	return m.partitionSession().PartitionID
 }
 
-// PartitionSessionID example only
-func (m *PublicBatch) PartitionSessionID() int64 {
-	// TODO implement me
-	panic("implement me")
-}
-
 func (m *PublicBatch) partitionSession() *PartitionSession {
 	return m.commitRange.PartitionSession
 }

testutil/topic.go

@@ -1,10 +1,12 @@
 package testutil
 
-import "github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreaderinternal"
+import (
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreadercommon"
+)
 
-type TopicReaderMessageBuilder = topicreaderinternal.PublicMessageBuilder
+type TopicReaderMessageBuilder = topicreadercommon.PublicMessageBuilder
 
 // NewTopicReaderMessageBuilder create builder, which can create Message (use for tests only)
 func NewTopicReaderMessageBuilder() *TopicReaderMessageBuilder {
-	return topicreaderinternal.NewPublicMessageBuilder()
+	return topicreadercommon.NewPublicMessageBuilder()
 }

topic/topicoptions/topicoptions_reader.go

@@ -5,13 +5,14 @@ import (
 
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/config"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopiccommon"
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreadercommon"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreaderinternal"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topictypes"
 	"github.com/ydb-platform/ydb-go-sdk/v3/trace"
 )
 
 // ReadSelector set rules for reader: set of topic, partitions, start time filted, etc.
-type ReadSelector = topicreaderinternal.PublicReadSelector
+type ReadSelector = topicreadercommon.PublicReadSelector
 
 // ReadSelectors slice of rules for topic reader
 type ReadSelectors []ReadSelector
@@ -24,6 +25,9 @@ func ReadTopic(path string) ReadSelectors {
 // ReaderOption options for topic reader
 type ReaderOption = topicreaderinternal.PublicReaderOption
 
+// CallbackReaderOption options for topic callback reader
+type CallbackReaderOption = topicreaderinternal.PublicCallbackReaderOption
+
 // WithReaderOperationTimeout
 //
 // Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
@@ -160,7 +164,7 @@ func WithReaderBufferSizeBytes(size int) ReaderOption {
 }
 
 // CreateDecoderFunc interface for fabric of message decoders
-type CreateDecoderFunc = topicreaderinternal.PublicCreateDecoderFunc
+type CreateDecoderFunc = topicreadercommon.PublicCreateDecoderFunc
 
 // WithAddDecoder add decoder for a codec.
 // It allows to set decoders fabric for custom codec and replace internal decoders.

topic/topicreader/errors.go

@@ -3,13 +3,14 @@ package topicreader
 import (
 	"errors"
 
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreadercommon"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreaderinternal"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
 )
 
 // ErrUnexpectedCodec will return if topicreader receive message with unknown codec.
 // client side must check error with errors.Is
-var ErrUnexpectedCodec = topicreaderinternal.ErrPublicUnexpectedCodec
+var ErrUnexpectedCodec = topicreadercommon.ErrPublicUnexpectedCodec
 
 // ErrConcurrencyCall return if method on reader called in concurrency
 // client side must check error with errors.Is

topic/topicreader/reader.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"sync/atomic"
 
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreadercommon"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicreaderinternal"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
 )
@@ -49,10 +50,10 @@ func (r *Reader) ReadMessage(ctx context.Context) (*Message, error) {
 }
 
 // Message contains data and metadata, readed from the server
-type Message = topicreaderinternal.PublicMessage
+type Message = topicreadercommon.PublicMessage
 
 // MessageContentUnmarshaler is interface for unmarshal message content to own struct
-type MessageContentUnmarshaler = topicreaderinternal.PublicMessageContentUnmarshaler
+type MessageContentUnmarshaler = topicreadercommon.PublicMessageContentUnmarshaler
 
 // Commit receive Message, Batch of single offset
 // It can be fast (by default) or sync and waite response from server
@@ -72,7 +73,7 @@ func (r *Reader) Commit(ctx context.Context, obj CommitRangeGetter) error {
 }
 
 // CommitRangeGetter interface for get commit offsets
-type CommitRangeGetter = topicreaderinternal.PublicCommitRangeGetter
+type CommitRangeGetter = topicreadercommon.PublicCommitRangeGetter
 
 // ReadMessageBatch
 //
@@ -103,7 +104,7 @@ func (r *Reader) ReadMessagesBatch(ctx context.Context, opts ...ReadBatchOption)
 }
 
 // Batch is ordered group of messages from one partition
-type Batch = topicreaderinternal.PublicBatch
+type Batch = topicreadercommon.PublicBatch
 
 // ReadBatchOption is type for options of read batch
 type ReadBatchOption = topicreaderinternal.PublicReadBatchOption