Merge pull request #501 add examples for topic retry policy

Author: rekby

topic/topicoptions/topicoptions_reader_example_test.go

@@ -0,0 +1,26 @@
+package topicoptions_test
+
+import (
+	"github.com/ydb-platform/ydb-go-sdk/v3"
+	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
+)
+
+func ExampleWithReaderCheckRetryErrorFunction() {
+	var db ydb.Connection
+
+	reader, err := db.Topic().StartReader(
+		"consumer",
+		topicoptions.ReadTopic("topic"),
+		topicoptions.WithReaderCheckRetryErrorFunction(
+			func(errInfo topicoptions.CheckErrorRetryArgs) topicoptions.CheckErrorRetryResult {
+				// Retry not found operations
+				if ydb.IsOperationErrorNotFoundError(errInfo.Error) {
+					return topicoptions.CheckErrorRetryDecisionRetry
+				}
+
+				// and use default behavior for all other errors
+				return topicoptions.CheckErrorRetryDecisionDefault
+			}),
+	)
+	_, _ = reader, err
+}

topic/topicoptions/topicoptions_writer_example_test.go

@@ -0,0 +1,25 @@
+package topicoptions_test
+
+import (
+	"github.com/ydb-platform/ydb-go-sdk/v3"
+	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
+)
+
+func ExampleWithWriterCheckRetryErrorFunction() {
+	var db ydb.Connection
+	writer, err := db.Topic().StartWriter(
+		"",
+		"",
+		topicoptions.WithWriterCheckRetryErrorFunction(
+			func(errInfo topicoptions.CheckErrorRetryArgs) topicoptions.CheckErrorRetryResult {
+				// Retry for all transport errors
+				if ydb.IsTransportError(errInfo.Error) {
+					return topicoptions.CheckErrorRetryDecisionRetry
+				}
+
+				// and use default behavior for all other errors
+				return topicoptions.CheckErrorRetryDecisionDefault
+			}),
+	)
+	_, _ = writer, err
+}