Versions in this module Expand all Collapse all v0 v0.12.1 Apr 26, 2026 v0.12.0 Apr 25, 2026 Changes in this version + const HeaderSize + var ErrCorrupted = errors.New("index corrupted") + var ErrKeyNotFound = fmt.Errorf("key: %w", message.ErrNotFound) + var ErrOffsetAfterEnd = fmt.Errorf("%w: offset after end", message.ErrInvalidOffset) + var ErrOffsetBeforeStart = fmt.Errorf("%w: offset before start", message.ErrNotFound) + var ErrOffsetIndexEmpty = fmt.Errorf("%w: no offset items", message.ErrInvalidOffset) + var ErrOffsetNotFound = fmt.Errorf("%w: offset not found", message.ErrNotFound) + var ErrTimeAfterEnd = errors.New("time after end") + var ErrTimeBeforeStart = errors.New("time before start") + var ErrTimeIndexEmpty = fmt.Errorf("%w: no time items", message.ErrInvalidOffset) + var V1 = Version + var V2 = Version + var VLast Version = V2 + var VUnknown = Version + func AppendKeys(keys art.Tree, items []Item) + func Consume(items []Item, offset int64) (int64, int64, error) + func Get(items []Item, offset int64) (int64, error) + func KeyHash(key []byte) uint64 + func KeyHashEncoded(h uint64) []byte + func Keys(keys art.Tree, keyHash []byte) ([]int64, error) + func Stat(path string, offset int64, opts Params) (int64, int, error) + func Time(items []Item, ts int64) (int64, error) + func Write(path string, offset int64, newVersion Version, opts Params, index []Item) (retErr error) + type Item struct + KeyHash uint64 + Offset int64 + Position int64 + Timestamp int64 + func Read(path string, offset int64, opts Params) ([]Item, error) + type Params struct + Keys bool + Times bool + func (o Params) NewItem(m message.Message, position int64, prevts int64) Item + func (o Params) Size() int64 + type Version struct + func GetVersion(path string, offset int64, opts Params) (Version, error) + type Writer struct + func OpenWriter(path string, offset int64, newVersion Version, opts Params) (w *Writer, retErr error) + func (w *Writer) Close() error + func (w *Writer) Size() int64 + func (w *Writer) Sync() error + func (w *Writer) SyncAndClose() error + func (w *Writer) Write(it Item) error
Go to main page