Versions in this module Expand all Collapse all v0 v0.8.1 Aug 27, 2021 Changes in this version + var CRCTable = crc32.MakeTable(crc32.Koopman) + type Decoder struct + func NewDecoder(iter RecordIterator, opts ...DecoderOption) *Decoder + func NewStreamDecoder(r io.Reader, opts ...DecoderOption) *Decoder + func (d *Decoder) Close() error + func (d *Decoder) Done() bool + func (d *Decoder) Next() (uint64, []byte, error) + type DecoderOption func(d *Decoder) + func ExpectDescending(desc bool) DecoderOption + func ExpectFirstIndex(index uint64) DecoderOption + type EncodeCloser interface + Encode func([]byte) (int, error) + type Encoder struct + func NewEncoder(a EncodeCloser, opts ...EncoderOption) *Encoder + func NewStreamEncoder(w io.Writer, opts ...EncoderOption) *Encoder + func (e *Encoder) Close() error + func (e *Encoder) Encode(index uint64, p []byte) (int, error) + func (e *Encoder) NextIndex() uint64 + func (e *Encoder) RegisterClose(f func() error) + type EncoderOption func(*Encoder) + func WithFirstIndex(idx uint64) EncoderOption + type RecordIterator interface + Done func() bool + Next func() ([]byte, error)