Versions in this module Expand all Collapse all v0 v0.2.0 Nov 6, 2026 v0.1.0 Jul 28, 2026 Changes in this version + const MaxTxPayloadLen + var ErrCorruptCRC = errors.New("reader: tx block CRC mismatch") + var ErrTruncated = errors.New("reader: file truncated before EOF marker") + var ErrTxTooLarge = errors.New("reader: tx payload length exceeds MaxTxPayloadLen") + var ErrUnknownMagic = errors.New("reader: unknown magic bytes in stream") + var ErrZeroLengthDecode = errors.New("zero-length decode") + func ReadHeader(path string, opts ...Option) (*format.Meta, error) + func ReadHeaderFS(fsys fs.FS, name string, opts ...Option) (*format.Meta, error) + type Option func(*readerCfg) + func AcceptV012() Option + func IgnoreMissingEOF() Option + func SkipCorruptTx() Option + func WithAliasBodies() Option + type Reader struct + func NewReader(rs io.ReadSeeker, opts ...Option) (*Reader, error) + func NewReaderBytes(b []byte, opts ...Option) (*Reader, error) + func Open(path string, opts ...Option) (*Reader, error) + func OpenAt(path string, blockOffset int64, opts ...Option) (*Reader, error) + func OpenFS(fsys fs.FS, name string, opts ...Option) (*Reader, error) + func OpenMmap(path string, opts ...Option) (*Reader, error) + func (r *Reader) Close() error + func (r *Reader) Err() error + func (r *Reader) Meta() *format.Meta + func (r *Reader) Next() (format.XRow, error) + func (r *Reader) NextBlockRaw() ([]byte, error) + func (r *Reader) NextTx() (*Transaction, error) + func (r *Reader) Offset() int64 + func (r *Reader) Recycle() + func (r *Reader) Row() format.XRow + func (r *Reader) Rows() iter.Seq2[format.XRow, error] + func (r *Reader) SawEOFMarker() bool + func (r *Reader) Scan() bool + func (r *Reader) ScanTx() bool + func (r *Reader) Tx() []format.XRow + func (r *Reader) Txs() iter.Seq2[*Transaction, error] + type Transaction struct + Rows []format.XRow + StartLSN int64
Go to main page