/
githubmirror
/
ydb-go-sdk
Обзор
Документация
Войти
/
githubmirror
/
ydb-go-sdk
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
internal/topic/topicreadercommon/init_message.go
31 строка
882 B
Timofey Koolin
add option for manage support of topic split-merge on client side.
08 апр 2025, 15:51
08 апр 2025, 15:51
1e61c08
Код
Авторство
О чём код?
package topicreadercommon import "github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopicreader" func CreateInitMessage( consumer string, supportAutoPartition bool, selectors []*PublicReadSelector, ) *rawtopicreader.InitRequest { res := &rawtopicreader.InitRequest{ Consumer: consumer, AutoPartitioningSupport: supportAutoPartition, } res.TopicsReadSettings = make([]rawtopicreader.TopicReadSettings, len(selectors)) for i, selector := range selectors { settings := &res.TopicsReadSettings[i] settings.Path = selector.Path settings.PartitionsID = selector.Partitions if !selector.ReadFrom.IsZero() { settings.ReadFrom.HasValue = true settings.ReadFrom.Value = selector.ReadFrom } if selector.MaxTimeLag != 0 { settings.MaxLag.HasValue = true settings.MaxLag.Value = selector.MaxTimeLag } } return res }