Skip to content

Commit 9e88b10

Browse files
committed
fix imports
1 parent ad61489 commit 9e88b10

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

topic/topicoptions/topicoptions_reader_example_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package topicoptions_test
22

33
import (
44
"github.com/ydb-platform/ydb-go-sdk/v3"
5-
"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic"
65
"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
76
)
87

@@ -13,7 +12,7 @@ func ExampleWithReaderCheckRetryErrorFunction() {
1312
"consumer",
1413
topicoptions.ReadTopic("topic"),
1514
topicoptions.WithReaderCheckRetryErrorFunction(
16-
func(errInfo topic.PublicCheckErrorRetryArgs) topic.PublicCheckRetryResult {
15+
func(errInfo topicoptions.CheckErrorRetryArgs) topicoptions.CheckErrorRetryResult {
1716
// Retry not found operations
1817
if ydb.IsOperationErrorNotFoundError(errInfo.Error) {
1918
return topicoptions.CheckErrorRetryDecisionRetry

topic/topicoptions/topicoptions_writer_example_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package topicoptions_test
22

33
import (
44
"github.com/ydb-platform/ydb-go-sdk/v3"
5-
"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic"
65
"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
76
)
87

@@ -12,7 +11,7 @@ func ExampleWithWriterCheckRetryErrorFunction() {
1211
"",
1312
"",
1413
topicoptions.WithWriterCheckRetryErrorFunction(
15-
func(errInfo topic.PublicCheckErrorRetryArgs) topic.PublicCheckRetryResult {
14+
func(errInfo topicoptions.CheckErrorRetryArgs) topicoptions.CheckErrorRetryResult {
1615
// Retry for all transport errors
1716
if ydb.IsTransportError(errInfo.Error) {
1817
return topicoptions.CheckErrorRetryDecisionRetry

0 commit comments

Comments
 (0)