ccdb

README

CCDB

an Optimistic Concurrency Control-Based Database with EVM State Management in Mind

Documentation

Index

• type Database
  • func New(storage KeyValueStore) *Database
  • func (db *Database) Snapshot(readonly bool) (*Snapshot, error)
  • func (db *Database) WriteChanges(ss *Snapshot) error
• type ErrModified
  • func (ErrModified) ErrModified()
  • func (ErrModified) Error() string
  • func (ErrModified) String() string
• type KVSnapshot
• type KeyValueStore
  • func LevelDB(database *leveldb.DB) KeyValueStore
• type Snapshot
  • func (ss *Snapshot) Changes() iter.Seq2[string, string]
  • func (ss *Snapshot) Commit(tx *Transaction) bool
  • func (ss *Snapshot) NewTransaction() *Transaction
  • func (ss *Snapshot) Readonly() bool
  • func (ss *Snapshot) Release()
• type Transaction
  • func (tx *Transaction) Changes() iter.Seq2[string, string]
  • func (tx *Transaction) DropPrefix(prefix string)
  • func (tx *Transaction) Get(k string) (string, error)
  • func (tx *Transaction) Set(key, val string)

Types

type Database

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

func New

func New(storage KeyValueStore) *Database

func (*Database) Snapshot

func (db *Database) Snapshot(readonly bool) (*Snapshot, error)

func (*Database) WriteChanges

func (db *Database) WriteChanges(ss *Snapshot) error

type ErrModified

type ErrModified struct{}

func (ErrModified) ErrModified

func (ErrModified) ErrModified()

func (ErrModified) Error

func (ErrModified) Error() string

func (ErrModified) String

func (ErrModified) String() string

type KVSnapshot

type KVSnapshot interface {
	Lookup(key string) (value string, err error)
	Iterate(prefix string) iter.Seq[string]
	Release()
}

type KeyValueStore

type KeyValueStore interface {
	Snapshot() (KVSnapshot, error)
	WriteChanges(ss *Snapshot) error
}

func LevelDB

func LevelDB(database *leveldb.DB) KeyValueStore

type Snapshot

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

func (*Snapshot) Changes

func (ss *Snapshot) Changes() iter.Seq2[string, string]

func (*Snapshot) Commit

func (ss *Snapshot) Commit(tx *Transaction) bool

func (*Snapshot) NewTransaction

func (ss *Snapshot) NewTransaction() *Transaction

func (*Snapshot) Readonly

func (ss *Snapshot) Readonly() bool

func (*Snapshot) Release

func (ss *Snapshot) Release()

type Transaction

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

func (*Transaction) Changes

func (tx *Transaction) Changes() iter.Seq2[string, string]

func (*Transaction) DropPrefix

func (tx *Transaction) DropPrefix(prefix string)

func (*Transaction) Get

func (tx *Transaction) Get(k string) (string, error)

func (*Transaction) Set

func (tx *Transaction) Set(key, val string)