store

Documentation

Index

• Variables
• func DisableLog()
• func Reg(name string, create StoreCreate)
• func SetLogLevel(level string)
• type BaseStore
  • func NewBaseStore(cfg *types.Store) *BaseStore
  • func (store *BaseStore) Close()
  • func (store *BaseStore) GetDB() dbm.DB
  • func (store *BaseStore) GetQueueClient() queue.Client
  • func (store *BaseStore) SetChild(sub SubStore)
  • func (store *BaseStore) SetQueueClient(c queue.Client)
• type StoreCreate
  • func Load(name string) (create StoreCreate, err error)
• type SubStore

Variables

var EmptyRoot [32]byte

Functions

func DisableLog

func DisableLog()

func Reg

func Reg(name string, create StoreCreate)

func SetLogLevel

func SetLogLevel(level string)

Types

type BaseStore

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

func NewBaseStore

func NewBaseStore(cfg *types.Store) *BaseStore

driver dbpath

func (*BaseStore) Close

func (store *BaseStore) Close()

func (*BaseStore) GetDB

func (store *BaseStore) GetDB() dbm.DB

func (*BaseStore) GetQueueClient

func (store *BaseStore) GetQueueClient() queue.Client

func (*BaseStore) SetChild

func (store *BaseStore) SetChild(sub SubStore)

func (*BaseStore) SetQueueClient

func (store *BaseStore) SetQueueClient(c queue.Client)

type StoreCreate

type StoreCreate func(cfg *types.Store, sub []byte) queue.Module

func Load

func Load(name string) (create StoreCreate, err error)

type SubStore

type SubStore interface {
	Set(datas *types.StoreSet, sync bool) ([]byte, error)
	Get(datas *types.StoreGet) [][]byte
	MemSet(datas *types.StoreSet, sync bool) ([]byte, error)
	Commit(hash *types.ReqHash) ([]byte, error)
	Rollback(req *types.ReqHash) ([]byte, error)
	Del(req *types.StoreDel) ([]byte, error)
	IterateRangeByStateHash(statehash []byte, start []byte, end []byte, ascending bool, fn func(key, value []byte) bool)
	ProcEvent(msg queue.Message)
}