lsm

Documentation

Index

• Constants
• type Node
  • func (n *Node[T]) Iterate(f func(*Node[T]) error) error
  • func (n *Node[T]) Prepend(part T) *Node[T]
• type Tree
  • func New(db *badger.DB, seq *seq.Seq) (*Tree, error)
  • func (t *Tree) Append(resource v1.RESOURCE, id, minTs, maxTs uint64)
  • func (t *Tree) Close() error
  • func (t *Tree) Compact() error
  • func (t *Tree) Flush()
  • func (t *Tree) Scan(resource v1.RESOURCE, start, end uint64) (*bitmaps.Bitmap, error)
  • func (t *Tree) Size() uint64
  • func (t *Tree) Start(ctx context.Context)

Constants

const (
	PartSize = 16 << 20
)

Types

type Node

type Node[T any] struct {
	// contains filtered or unexported fields
}

func (*Node[T]) Iterate

func (n *Node[T]) Iterate(f func(*Node[T]) error) error

func (*Node[T]) Prepend

func (n *Node[T]) Prepend(part T) *Node[T]

type Tree

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

func New

func New(db *badger.DB, seq *seq.Seq) (*Tree, error)

func (*Tree) Append

func (t *Tree) Append(resource v1.RESOURCE, id, minTs, maxTs uint64)

func (*Tree) Close

func (t *Tree) Close() error

func (*Tree) Compact

func (t *Tree) Compact() error

func (*Tree) Flush

func (t *Tree) Flush()

func (*Tree) Scan

func (t *Tree) Scan(resource v1.RESOURCE, start, end uint64) (*bitmaps.Bitmap, error)

func (*Tree) Size

func (t *Tree) Size() uint64

func (*Tree) Start

func (t *Tree) Start(ctx context.Context)