db

Documentation

Index

• Constants
• Variables
• func CommitState(db sdk.KVStore, sets RWSets, version Version, m KeyMaps) error
• func RegisterAmino(cdc *amino.Codec)
• type KeyMap
  • func NewKeyMap() KeyMap
  • func (m KeyMap) Has(k string) bool
  • func (m KeyMap) Set(k string)
• type KeyMaps
  • func NewKeyMaps() KeyMaps
  • func (m *KeyMaps) GetReadKeyMap(addr common.Address) KeyMap
  • func (m *KeyMaps) GetWriteKeyMap(addr common.Address) KeyMap
• type RWSet
• type RWSetItems
• type RWSetMap
  • 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) ToItems() *RWSetItems
• type RWSets
  • func (rs *RWSets) Add(ss ...*RWSet)
  • func (rs RWSets) Bytes() ([]byte, error)
  • func (rs *RWSets) FromBytes(b []byte) error
  • func (rs RWSets) Hash() []byte
• type Read
• type StateDB
• type StateManager
  • func NewStateManager(key sdk.StoreKey) *StateManager
  • func (sm StateManager) CommitState(ctx sdk.Context, sets RWSets) error
• type ValueObject
  • func BytesToValueObject(b []byte) (*ValueObject, error)
  • func (vo ValueObject) Marshal() []byte
  • func (vo *ValueObject) Unmarshal(b []byte) error
• type Version
  • func MakeVersion(b []byte) (Version, error)
  • func (v Version) Bytes() []byte
• type VersionedDB
  • func NewVersionedDB(store types.KVStore) *VersionedDB
  • func (db *VersionedDB) Get(k []byte) ([]byte, error)
  • func (db *VersionedDB) RWSetItems() *RWSetItems
  • func (db *VersionedDB) Set(k, v []byte) error
• type Write

Constants

const (
	VersionSize = 8
)

Variables

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

Functions

func CommitState

func CommitState(db sdk.KVStore, sets RWSets, version Version, m KeyMaps) error

func RegisterAmino

func RegisterAmino(cdc *amino.Codec)

Types

type KeyMap

type KeyMap map[string]struct{}

KeyMap contains updated key

func NewKeyMap

func NewKeyMap() KeyMap

func (KeyMap) Has

func (m KeyMap) Has(k string) bool

func (KeyMap) Set

func (m KeyMap) Set(k string)

type KeyMaps

type KeyMaps struct {
	Read  map[common.Address]KeyMap
	Write map[common.Address]KeyMap
}

func NewKeyMaps

func NewKeyMaps() KeyMaps

func (*KeyMaps) GetReadKeyMap

func (m *KeyMaps) GetReadKeyMap(addr common.Address) KeyMap

func (*KeyMaps) GetWriteKeyMap

func (m *KeyMaps) GetWriteKeyMap(addr common.Address) KeyMap

type RWSet

type RWSet struct {
	Address common.Address
	Items   *RWSetItems
}

type RWSetItems

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

type RWSetMap

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

func NewRWSetMap

func NewRWSetMap() *RWSetMap

func (*RWSetMap) AddRead

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

func (*RWSetMap) AddWrite

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

func (*RWSetMap) GetRead

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

func (*RWSetMap) GetWrite

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

func (*RWSetMap) ToItems

func (m *RWSetMap) ToItems() *RWSetItems

type RWSets

type RWSets []*RWSet

func (*RWSets) Add

func (rs *RWSets) Add(ss ...*RWSet)

func (RWSets) Bytes

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

func (*RWSets) FromBytes

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

func (RWSets) Hash

func (rs RWSets) Hash() []byte

type Read

type Read struct {
	Key     []byte
	Version Version
}

type StateDB

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

type StateManager

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

func NewStateManager

func NewStateManager(key sdk.StoreKey) *StateManager

func (StateManager) CommitState

func (sm StateManager) CommitState(ctx sdk.Context, sets RWSets) error

type ValueObject

type ValueObject struct {
	Value   []byte
	Version Version
}

func BytesToValueObject

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

func (ValueObject) Marshal

func (vo ValueObject) Marshal() []byte

func (*ValueObject) Unmarshal

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

type Version

type Version struct {
	Height uint32
	TxIdx  uint32
}

func MakeVersion

func MakeVersion(b []byte) (Version, error)

func (Version) Bytes

func (v Version) Bytes() []byte

type VersionedDB

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

func NewVersionedDB

func NewVersionedDB(store types.KVStore) *VersionedDB

func (*VersionedDB) Get

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

func (*VersionedDB) RWSetItems

func (db *VersionedDB) RWSetItems() *RWSetItems

func (*VersionedDB) Set

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

type Write

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