db

package

v0.2.0 Latest Latest Go to latest Published: May 20, 2019 License: Apache-2.0 Imports: 6 Imported by: 4

Details

This section is empty.

View Source

var (
	ErrKeyNotFound = errors.New("key not found")
)

func RegisterAmino(cdc *amino.Codec)

type RWSet struct {
	ReadSet  []Read
	WriteSet []Write
}

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

func NewRWSetMap() *RWSetMap

func (m *RWSetMap) AddRead(key []byte, version Version) bool

func (m *RWSetMap) AddWrite(key, value []byte)

func (m *RWSetMap) GetRead(key []byte) (Read, bool)

func (m *RWSetMap) GetWrite(key []byte) (Write, bool)

func (m *RWSetMap) ToSet() *RWSet

type RWSets struct {
	Address common.Address
	RWSet   *RWSet
	Childs  []*RWSets
}

func (rs RWSets) Bytes() ([]byte, error)

func (rs *RWSets) FromBytes(b []byte) error

func (rs RWSets) Hash() []byte

type Read struct {
	Key     []byte
	Version Version
}

type State struct {
	Childs []*RWSets
}

func (s *State) Add(rws *RWSets)

type StateDB interface {
	Set(k, v []byte) error
	Get(k []byte) ([]byte, error)
}

type ValueObject struct {
	Value   []byte
	Version Version
}

func BytesToValueObject(b []byte) (*ValueObject, error)

func (vo *ValueObject) Marshal() []byte

func (vo *ValueObject) Unmarshal(b []byte) error

type Version struct {
	Height uint32
	TxIdx  uint32
}

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

func NewVersionedDB(store types.KVStore, version Version) *VersionedDB

func (db *VersionedDB) Commit() (*RWSet, error)

func (db *VersionedDB) Get(k []byte) ([]byte, error)

func (db *VersionedDB) Set(k, v []byte) error

type Write struct {
	Key   []byte
	Value []byte
}