fix usage deprecations in examples

Author: asmyasnikov

examples/topic/topicreader/topicreader_advanced.go

@@ -50,14 +50,14 @@ func UnmarshalMessageContentToOwnType(ctx context.Context, reader *topicreader.R
 // ProcessMessagesWithSyncCommit example about guarantee wait for commit accepted by server
 func ProcessMessagesWithSyncCommit(ctx context.Context, db *ydb.Driver) {
 	reader, _ := db.Topic().StartReader("consumer", nil,
-		topicoptions.WithCommitMode(topicoptions.CommitModeSync),
+		topicoptions.WithReaderCommitMode(topicoptions.CommitModeSync),
 	)
 	defer func() {
 		_ = reader.Close(ctx)
 	}()
 
 	for {
-		batch, _ := reader.ReadMessageBatch(ctx)
+		batch, _ := reader.ReadMessagesBatch(ctx)
 		processBatch(batch.Context(), batch)
 		_ = reader.Commit(ctx, batch) // will wait response about commit from server
 	}
@@ -67,7 +67,7 @@ func ProcessMessagesWithSyncCommit(ctx context.Context, db *ydb.Driver) {
 // commit messages to YDB
 func OwnReadProgressStorage(ctx context.Context, db *ydb.Driver) {
 	reader, _ := db.Topic().StartReader("consumer", topicoptions.ReadTopic("asd"),
-		topicoptions.WithGetPartitionStartOffset(
+		topicoptions.WithReaderGetPartitionStartOffset(
 			func(
 				ctx context.Context,
 				req topicoptions.GetPartitionStartOffsetRequest,
@@ -84,7 +84,7 @@ func OwnReadProgressStorage(ctx context.Context, db *ydb.Driver) {
 	)
 
 	for {
-		batch, _ := reader.ReadMessageBatch(ctx)
+		batch, _ := reader.ReadMessagesBatch(ctx)
 
 		processBatch(batch.Context(), batch)
 		_ = externalSystemCommit(

examples/topic/topicreader/topicreader_simple.go

@@ -24,7 +24,7 @@ func PrintMessageContent(ctx context.Context, reader *topicreader.Reader) {
 // ReadMessagesByBatch it is recommended way for process messages
 func ReadMessagesByBatch(ctx context.Context, reader *topicreader.Reader) {
 	for {
-		batch, _ := reader.ReadMessageBatch(ctx)
+		batch, _ := reader.ReadMessagesBatch(ctx)
 		processBatch(batch.Context(), batch)
 		_ = reader.Commit(batch.Context(), batch)
 	}

examples/topic/topicreader/topicreader_trace.go

@@ -71,7 +71,7 @@ func ExplicitPartitionStartStopHandler(ctx context.Context, db *ydb.Driver) {
 	}()
 
 	for {
-		batch, _ := reader.ReadMessageBatch(readContext)
+		batch, _ := reader.ReadMessagesBatch(readContext)
 
 		processBatch(batch.Context(), batch)
 		_ = externalSystemCommit(
@@ -129,8 +129,7 @@ func PartitionStartStopHandlerAndOwnReadProgressStorage(ctx context.Context, db
 	}
 
 	r, _ := db.Topic().StartReader("consumer", topicoptions.ReadTopic("asd"),
-
-		topicoptions.WithGetPartitionStartOffset(readStartPosition),
+		topicoptions.WithReaderGetPartitionStartOffset(readStartPosition),
 		topicoptions.WithReaderTrace(
 			trace.Topic{
 				OnReaderPartitionReadStartResponse: onPartitionStart,
@@ -144,7 +143,7 @@ func PartitionStartStopHandlerAndOwnReadProgressStorage(ctx context.Context, db
 	}()
 
 	for {
-		batch, _ := r.ReadMessageBatch(readContext)
+		batch, _ := r.ReadMessagesBatch(readContext)
 
 		processBatch(batch.Context(), batch)
 		_ = externalSystemCommit(batch.Context(), batch.Topic(), batch.PartitionID(), getEndOffset(batch))

examples/topic/topicwriter/topicwriter.go

@@ -17,13 +17,13 @@ func ConnectSimple(ctx context.Context, db *ydb.Driver) *topicwriter.Writer {
 }
 
 func ConnectWithSyncWrite(ctx context.Context, db *ydb.Driver) *topicwriter.Writer {
-	writer, _ := db.Topic().StartWriter("topicName", topicoptions.WithSyncWrite(true))
+	writer, _ := db.Topic().StartWriter("topicName", topicoptions.WithWriterWaitServerAck(true))
 
 	return writer
 }
 
 func ConnectSelectCodec(ctx context.Context, db *ydb.Driver) *topicwriter.Writer {
-	writer, _ := db.Topic().StartWriter("topicName", topicoptions.WithCodec(topictypes.CodecGzip))
+	writer, _ := db.Topic().StartWriter("topicName", topicoptions.WithWriterCodec(topictypes.CodecGzip))
 
 	return writer
 }