/
githubmirror
/
ydb-go-examples
Обзор
Документация
Войти
/
githubmirror
/
ydb-go-examples
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
topic/topicreader/stubs.go
37 строк
1 KB
Timofey Koolin
add protobuf example, fix linter
03 авг 2022, 17:37
03 авг 2022, 17:37
3c7d631
Код
Авторство
О чём код?
package topicreaderexamples import ( "context" "github.com/ydb-platform/ydb-go-sdk/v3/topic/topicreader" ) func getEndOffset(b *topicreader.Batch) int64 { //nolint:unused panic("example stub") } func externalSystemCommit(ctx context.Context, topic string, partition int64, offset int64) error { //nolint:unused 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) { // 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") }