package
3.84.1
Repository: https://github.com/ydb-platform/ydb-go-sdk.git
Documentation: pkg.go.dev

# Functions

NewReader create new reader, used internally only.

# Variables

ErrCommitToExpiredSession it is not fatal error and reader can continue work client side must check error with errors.Is.
ErrConcurrencyCall return if method on reader called in concurrency client side must check error with errors.Is.
ErrUnexpectedCodec will return if topicreader receive message with unknown codec.

# Structs

Reader allow to read message from YDB topics.

# Type aliases

Batch is ordered group of messages from one partition.
CommitRangeGetter interface for get commit offsets.
Message contains data and metadata, readed from the server.
MessageContentUnmarshaler is interface for unmarshal message content to own struct.
ReadBatchOption is type for options of read batch.
WithBatchMaxCount max messages within batch.
WithBatchPreferMinCount set prefer min count for batch size.