/
githubmirror
/
ydb-go-sdk
Обзор
Документация
Войти
/
githubmirror
/
ydb-go-sdk
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
examples/topic/topicreader/stubs.go
37 строк
1 KB
Timofey Koolin
recreate examples
19 июн 2024, 19:46
19 июн 2024, 19:46
bbd93e6
Код
Авторство
О чём код?
package topicreaderexamples import ( "context" "github.com/ydb-platform/ydb-go-sdk/v3/topic/topicreader" ) func getEndOffset(b *topicreader.Batch) int64 { panic("example stub") } func externalSystemCommit(ctx context.Context, topic string, partition, offset int64) error { panic("example stub") } func externalSystemLock(ctx context.Context, topic string, partition int64) (err error) { panic("example stub") } func externalSystemUnlock(ctx context.Context, topic string, partition int64) error { panic("example stub") } func processBatch(ctx context.Context, batch *topicreader.Batch) (result int, err error) { // recommend derive ctx from batch.Context() for handle signal about stop message processing panic("example stub") } func processMessage(ctx context.Context, m *topicreader.Message) { // recommend derive ctx from m.Context() for handle signal about stop message processing panic("example stub") } func readLastOffsetFromDB(ctx context.Context, topic string, partition int64) (int64, error) { panic("example stub") }