Merge pull request #489 add update token interval options for topic

Author: rekby

CHANGELOG.md

@@ -1,3 +1,4 @@
+* Added option for set interval of auth token update in topic streams
 * Supported internal allocator in `{session,statement}.Execute` for decrease memory usage
 * Fixed typo in `topic/README.md`
 * Upgraded `ydb-go-genproto` dependency

internal/topic/topicwriterinternal/writer_options.go

@@ -42,6 +42,12 @@ func WithCompressorCount(num int) PublicWriterOption {
 	}
 }
 
+func WithTokenUpdateInterval(interval time.Duration) PublicWriterOption {
+	return func(cfg *WriterReconnectorConfig) {
+		cfg.credUpdateInterval = interval
+	}
+}
+
 // WithCommonConfig
 //
 // # Experimental

topic/topicoptions/topicoptions_reader.go

@@ -234,3 +234,14 @@ func WithReaderTrace(tracer trace.Topic) ReaderOption {
 		cfg.Tracer = cfg.Tracer.Compose(tracer)
 	}
 }
+
+// WithReaderUpdateTokenInterval
+//
+// # Experimental
+//
+// Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
+func WithReaderUpdateTokenInterval(interval time.Duration) ReaderOption {
+	return func(cfg *topicreaderinternal.ReaderConfig) {
+		cfg.CredUpdateInterval = interval
+	}
+}

topic/topicoptions/topicoptions_writer.go

@@ -1,6 +1,8 @@
 package topicoptions
 
 import (
+	"time"
+
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopiccommon"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicwriterinternal"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topictypes"
@@ -169,3 +171,12 @@ func WithWriterSetAutoCreatedAt(val bool) WriterOption {
 func WithWriterTrace(tracer trace.Topic) WriterOption {
 	return topicwriterinternal.WithTrace(tracer)
 }
+
+// WithWriterUpdateTokenInterval
+//
+// # Experimental
+//
+// Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
+func WithWriterUpdateTokenInterval(interval time.Duration) WriterOption {
+	return topicwriterinternal.WithTokenUpdateInterval(interval)
+}