/
githubmirror
/
ydb-go-sdk
Обзор
Документация
Войти
/
githubmirror
/
ydb-go-sdk
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
topic/topicoptions/topicoptions_commit_offset.go
19 строк
709 B
Oleg Ovcharuk
Implement topic's client CommitOffset call (#2076)
03 апр 2026, 17:37
Не верифицирован
03 апр 2026, 17:37
cb74090
Код
Авторство
О чём код?
package topicoptions // CommitOffsetOption is an option for Topic().CommitOffset() call. type CommitOffsetOption func(*CommitOffsetOptions) // CommitOffsetOptions holds optional parameters for CommitOffset. type CommitOffsetOptions struct { ReadSessionID string } // WithCommitOffsetReadSessionID associates the commit with the given read session. // Passing the current reader's session ID (from reader.ReadSessionID()) prevents // the server from interrupting the active read session for the partition. // If not set, the server will interrupt the active read session. func WithCommitOffsetReadSessionID(id string) CommitOffsetOption { return func(o *CommitOffsetOptions) { o.ReadSessionID = id } }