store

README

kvstore

This repository contains the source of kvstore, a flexible associative data store based on string-sorted tables. It is supposed to be easily embeddable into any application.

What's working?

• Basic table implementation
• Index-based block access
• Key filtering using bloom filters
• Block level caching
• Block level compression/decompression
• Table-level access conflict resolution
• Row-level access conflict resolution
• Automatic memtable flushing on overflow
• Automatic table merging on overflow using leveled compaction

Documentation

Index

• Constants
• type Record
  • func (record *Record) Bytes() []byte
  • func (record *Record) FromBytes(data []byte)
  • func (record Record) String() string
• type Store
  • func New(name string) (*Store, error)
  • func (store *Store) Close() error
  • func (store *Store) Flush() error
  • func (store *Store) Get(key []byte) []*Record
  • func (store *Store) MemSize() int64
  • func (store *Store) Put(key []byte, record *Record) error
  • func (store *Store) Restore() error

Constants

const MaxMemSize = 2 << 25

Types

type Record

type Record struct {
	Time  int64
	Value []byte
}

func (*Record) Bytes

func (record *Record) Bytes() []byte

func (*Record) FromBytes

func (record *Record) FromBytes(data []byte)

func (Record) String

func (record Record) String() string

type Store

type Store struct {
	Name string
	// contains filtered or unexported fields
}

func New

func New(name string) (*Store, error)

func (*Store) Close

func (store *Store) Close() error

func (*Store) Flush

func (store *Store) Flush() error

Flush replaces the active memtable with a new one and compacts the old one to disk. This can be done while serving entries from the flushed memtable as well as the active memtable and all other disk tables.

func (*Store) Get

func (store *Store) Get(key []byte) []*Record

func (*Store) MemSize

func (store *Store) MemSize() int64

func (*Store) Put

func (store *Store) Put(key []byte, record *Record) error

func (*Store) Restore

func (store *Store) Restore() error