lsm

Documentation

Index

• func ScanTimestamp(r arrow.Record, timestampColumn int, start, end int64) *roaring.Bitmap
• type Node
  • func (n *Node) Iterate(f func(*Node) bool)
  • func (n *Node) Prepend(part *Part) *Node
• type Option
  • func WithCompactSize(size uint64) Option
  • func WithTTL(ttl time.Duration) Option
• type Options
  • func DefaultLSMOptions() Options
• type Part
  • func NewPart(r arrow.Record, idx index.Full) *Part
• type ScanCallback
• type Tree
  • func NewTree[T any](mem memory.Allocator, resource string, storage db.Storage, indexer index.Index, ...) *Tree[T]
  • func (lsm *Tree[T]) Add(r arrow.Record) error
  • func (lsm *Tree[T]) Compact()
  • func (lsm *Tree[T]) Scan(ctx context.Context, start, end int64, fs *v1.Filters) (arrow.Record, error)
  • func (lsm *Tree[T]) Start(ctx context.Context)

Functions

func ScanTimestamp

func ScanTimestamp(r arrow.Record, timestampColumn int, start, end int64) *roaring.Bitmap

Types

type Node

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

func (*Node) Iterate

func (n *Node) Iterate(f func(*Node) bool)

func (*Node) Prepend

func (n *Node) Prepend(part *Part) *Node

type Option

type Option func(*Options)

func WithCompactSize

func WithCompactSize(size uint64) Option

func WithTTL

func WithTTL(ttl time.Duration) Option

type Options

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

func DefaultLSMOptions

func DefaultLSMOptions() Options

type Part

type Part struct {
	ID     ulid.ULID
	Record arrow.Record
	Index  index.Full
	Size   uint64
	Min    int64
	Max    int64
}

func NewPart

func NewPart(r arrow.Record, idx index.Full) *Part

type ScanCallback

type ScanCallback func(context.Context, arrow.Record) error

type Tree

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

func NewTree

func NewTree[T any](mem memory.Allocator, resource string, storage db.Storage, indexer index.Index, primary index.Primary, opts ...Option) *Tree[T]

func (*Tree[T]) Add

func (lsm *Tree[T]) Add(r arrow.Record) error

func (*Tree[T]) Compact

func (lsm *Tree[T]) Compact()

func (*Tree[T]) Scan

func (lsm *Tree[T]) Scan(
	ctx context.Context,
	start, end int64,
	fs *v1.Filters,
) (arrow.Record, error)

func (*Tree[T]) Start

func (lsm *Tree[T]) Start(ctx context.Context)