Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kv

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 17, 2023

v0.4.0

Jun 28, 2023

Changes in this version

type IndexStore

+ SizeOnDisk func() int64

type Store

+ SizeOnDisk func() int64

type TimeSeriesStore

+ CollectStats func() *badger.Statistics

+ Handover func(skl *skl.Skiplist) error

+ SizeOnDisk func() int64

v0.3.1

Feb 21, 2023

v0.3.0

Feb 6, 2023

Changes in this version

type Iterator

+ RawKey func() []byte

type TimeSeriesOptions

+ func TSSWithZSTDCompression(chunkSize int) TimeSeriesOptions

v0.2.0

Nov 5, 2022

Changes in this version

type StoreOptions

+ func StoreWithMemTableSize(size int64) StoreOptions

type TimeSeriesOptions

+ func TSSWithMemTableSize(size int64) TimeSeriesOptions

v0.1.0

Jun 2, 2022

Changes in this version

+ var DefaultScanOpts = ScanOpts

+ var ErrKeyNotFound = badger.ErrKeyNotFound

+ var ErrStopScan = errors.New("stop scanning")

+ type HandoverCallback func()

+ type IndexOptions func(store IndexStore)

+ func IndexWithLogger(l *logger.Logger) IndexOptions

+ type IndexStore interface

+ Close func() error

+ Handover func(iterator Iterator) error

+ func OpenIndexStore(shardID int, path string, options ...IndexOptions) (IndexStore, error)

+ type Iterable interface

+ NewIterator func(opt ScanOpts) Iterator

+ type Iterator interface

+ Close func() error

+ Key func() []byte

+ Next func()

+ Rewind func()

+ Seek func(key []byte)

+ Val func() []byte

+ Valid func() bool

+ type Reader interface

+ Get func(key []byte) ([]byte, error)

+ GetAll func(key []byte, applyFn func([]byte) error) error

+ Scan func(prefix, seekKey []byte, opt ScanOpts, f ScanFunc) error

+ type ScanFunc func(shardID int, key []byte, getVal func() ([]byte, error)) error

+ type ScanOpts struct

+ PrefetchSize int

+ PrefetchValues bool

+ Prefix []byte

+ Reverse bool

+ type Store interface

+ func OpenStore(shardID int, path string, options ...StoreOptions) (Store, error)

+ type StoreOptions func(Store)

+ func StoreWithLogger(l *logger.Logger) StoreOptions

+ func StoreWithNamedLogger(name string, l *logger.Logger) StoreOptions

+ type TimeSeriesOptions func(TimeSeriesStore)

+ func TSSWithEncoding(encoderPool encoding.SeriesEncoderPool, decoderPool encoding.SeriesDecoderPool) TimeSeriesOptions

+ func TSSWithFlushCallback(callback func()) TimeSeriesOptions

+ func TSSWithLogger(l *logger.Logger) TimeSeriesOptions

+ type TimeSeriesReader interface

+ Get func(key []byte, ts uint64) ([]byte, error)

+ GetAll func(key []byte) ([][]byte, error)

+ type TimeSeriesStore interface

+ func OpenTimeSeriesStore(shardID int, path string, options ...TimeSeriesOptions) (TimeSeriesStore, error)

+ type TimeSeriesWriter interface

+ Put func(key, val []byte, ts uint64) error

+ PutAsync func(key, val []byte, ts uint64, f func(error)) error

+ type Writer interface

+ Put func(key, val []byte) error

+ PutWithVersion func(key, val []byte, version uint64) error