index

package

v0.6.0 Latest Latest Go to latest Published: Apr 22, 2024 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

View Source

var ErrIndexEmpty = fmt.Errorf("%w: no 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