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

simpledb

package

Go to main page

Versions in this module

v1

v1.6.0

Nov 7, 2024

v1.5.0

Jul 28, 2024

v1.4.0

Dec 2, 2022

Changes in this version

+ var ErrAlreadyClosed = errors.New("database is already closed")

+ var ErrAlreadyOpen = errors.New("database is already open")

+ var ErrEmptyKeyValue = errors.New("neither empty keys nor values are allowed")

+ var ErrNotFound = errors.New("ErrNotFound")

+ var ErrNotOpenedYet = errors.New("database has not been opened yet, please call Open() first")

type ExtraOption

+ func EnableAsyncWAL() ExtraOption

+ func EnableDirectIOWAL() ExtraOption

v1.3.1

Sep 15, 2021

v1.3.0

Aug 27, 2021

Changes in this version

+ const CompactionFinishedSuccessfulFileName

+ const DefaultCompactionInterval

+ const DefaultCompactionMaxSizeBytes

+ const MemStoreMaxSizeBytes

+ const NumSSTablesToTriggerCompaction

+ const SSTableCompactionPathPrefix

+ const SSTablePattern

+ const SSTablePrefix

+ const WriteAheadFolder

+ var AlreadyClosed = errors.New("database is already closed")

+ var EmptyKeyValue = errors.New("neither empty keys nor values are allowed")

+ var NotFound = errors.New("NotFound")

+ type DB struct

+ func NewSimpleDB(basePath string, extraOptions ...ExtraOption) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Delete(key string) error

+ func (db *DB) Get(key string) (string, error)

+ func (db *DB) Open() error

+ func (db *DB) Put(key, value string) error

+ type DatabaseI interface

+ Delete func(key string) error

+ Get func(key string) (string, error)

+ Put func(key, value string) error

+ type ExtraOption func(options *ExtraOptions)

+ func CompactionFileThreshold(n int) ExtraOption

+ func CompactionMaxSizeBytes(n uint64) ExtraOption

+ func CompactionRunInterval(interval time.Duration) ExtraOption

+ func DisableAsyncWAL() ExtraOption

+ func DisableCompactions() ExtraOption

+ func MemstoreSizeBytes(n uint64) ExtraOption

+ type ExtraOptions struct

+ type RWMemstore struct

+ func (c *RWMemstore) Add(key []byte, value []byte) error

+ func (c *RWMemstore) Contains(key []byte) bool

+ func (c *RWMemstore) Delete(key []byte) error

+ func (c *RWMemstore) DeleteIfExists(key []byte) error

+ func (c *RWMemstore) EstimatedSizeInBytes() uint64

+ func (c *RWMemstore) Flush(opts ...sstables.WriterOption) error

+ func (c *RWMemstore) Get(key []byte) ([]byte, error)

+ func (c *RWMemstore) SStableIterator() sstables.SSTableIteratorI

+ func (c *RWMemstore) Size() int

+ func (c *RWMemstore) Tombstone(key []byte) error

+ func (c *RWMemstore) Upsert(key []byte, value []byte) error

+ type SSTableManager struct

+ func NewSSTableManager(cmp skiplist.KeyComparator, dbLock *sync.RWMutex, basePath string) *SSTableManager