index

package

v0.9.0 Latest Latest Go to latest Published: Jul 8, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var ErrCorrupted = errors.New("index corrupted")

View Source

var ErrKeyNotFound = fmt.Errorf("key: %w", message.ErrNotFound)

View Source

var ErrOffsetAfterEnd = fmt.Errorf("%w: offset after end", message.ErrInvalidOffset)

View Source

var ErrOffsetBeforeStart = fmt.Errorf("%w: offset before start", message.ErrNotFound)

View Source

var ErrOffsetIndexEmpty = fmt.Errorf("%w: no offset items", message.ErrInvalidOffset)

View Source

var ErrOffsetNotFound = fmt.Errorf("%w: offset not found", message.ErrNotFound)

View Source

var ErrTimeAfterEnd = errors.New("time after end")

View Source

var ErrTimeBeforeStart = errors.New("time before start")

View Source

var ErrTimeIndexEmpty = fmt.Errorf("%w: no time items", message.ErrInvalidOffset)

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 Time(items []Item, ts int64) (int64, error)

func Write(path string, opts Params, index []Item) error

type Item struct {
	Offset    int64
	Position  int64
	Timestamp int64
	KeyHash   uint64
}

func Read(path string, opts Params) ([]Item, error)

type Params struct {
	Times bool
	Keys  bool
}

func (o Params) NewItem(m message.Message, position int64, prevts int64) Item

func (o Params) Size() int64

type Writer struct {
	// contains filtered or unexported fields
}

func OpenWriter(path string, opts Params) (*Writer, 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