db

Documentation

Index

• Constants
• Variables
• func CommitState(db sdk.KVStore, sets RWSets, version Version)
• func RegisterAmino(cdc *amino.Codec)
• 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)
• 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)

func RegisterAmino

func RegisterAmino(cdc *amino.Codec)

Types

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)

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
}