database

Documentation

Index

• Variables
• type LevelDBMovStore
  • func NewLevelDBMovStore(db dbm.DB) *LevelDBMovStore
  • func (m *LevelDBMovStore) Clear()
  • func (m *LevelDBMovStore) GetMovDatabaseState() (*common.MovDatabaseState, error)
  • func (m *LevelDBMovStore) InitDBState(height uint64, hash *bc.Hash) error
  • func (m *LevelDBMovStore) ListOrders(orderAfter *common.Order) ([]*common.Order, error)
  • func (m *LevelDBMovStore) ListTradePairsWithStart(fromAssetIDAfter, toAssetIDAfter *bc.AssetID) ([]*common.TradePair, error)
  • func (m *LevelDBMovStore) ProcessOrders(addOrders []*common.Order, delOrders []*common.Order, ...) error
• type MovStore
• type OrderIterator
  • func NewOrderIterator(movStore MovStore, tradePair *common.TradePair) *OrderIterator
  • func (o *OrderIterator) HasNext() bool
  • func (o *OrderIterator) NextBatch() []*common.Order
• type TradePairIterator
  • func NewTradePairIterator(movStore MovStore) *TradePairIterator
  • func (t *TradePairIterator) HasNext() bool
  • func (t *TradePairIterator) Next() *common.TradePair

Variables

var ErrNotInitDBState = errors.New("database state of mov store is not initialized")

ErrNotInitDBState represent the database state of mov store is not initialized

Types

type LevelDBMovStore

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

LevelDBMovStore is the LevelDB implementation for MovStore

func NewLevelDBMovStore

func NewLevelDBMovStore(db dbm.DB) *LevelDBMovStore

NewLevelDBMovStore create a new LevelDBMovStore object

func (*LevelDBMovStore) Clear

func (m *LevelDBMovStore) Clear()

Clear will clear all the data of store

func (*LevelDBMovStore) GetMovDatabaseState

func (m *LevelDBMovStore) GetMovDatabaseState() (*common.MovDatabaseState, error)

GetMovDatabaseState return the current DB's image status

func (*LevelDBMovStore) InitDBState

func (m *LevelDBMovStore) InitDBState(height uint64, hash *bc.Hash) error

InitDBState set the DB's image status

func (*LevelDBMovStore) ListOrders

func (m *LevelDBMovStore) ListOrders(orderAfter *common.Order) ([]*common.Order, error)

ListOrders return n orders after the input order

func (*LevelDBMovStore) ListTradePairsWithStart

func (m *LevelDBMovStore) ListTradePairsWithStart(fromAssetIDAfter, toAssetIDAfter *bc.AssetID) ([]*common.TradePair, error)

ListTradePairsWithStart return n trade pairs after the input trade pair

func (*LevelDBMovStore) ProcessOrders

func (m *LevelDBMovStore) ProcessOrders(addOrders []*common.Order, delOrders []*common.Order, blockHeader *types.BlockHeader) error

ProcessOrders update the DB's image by add new orders, delete the used order

type MovStore

type MovStore interface {
	Clear()
	GetMovDatabaseState() (*common.MovDatabaseState, error)
	InitDBState(height uint64, hash *bc.Hash) error
	ListOrders(orderAfter *common.Order) ([]*common.Order, error)
	ListTradePairsWithStart(fromAssetIDAfter, toAssetIDAfter *bc.AssetID) ([]*common.TradePair, error)
	ProcessOrders(addOrders []*common.Order, delOrders []*common.Order, blockHeader *types.BlockHeader) error
}

MovStore is the interface for mov's persistent storage

type OrderIterator

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

OrderIterator wrap read order from DB action

func NewOrderIterator

func NewOrderIterator(movStore MovStore, tradePair *common.TradePair) *OrderIterator

NewOrderIterator create the new OrderIterator object

func (*OrderIterator) HasNext

func (o *OrderIterator) HasNext() bool

HasNext check if there are more orders in memory or DB

func (*OrderIterator) NextBatch

func (o *OrderIterator) NextBatch() []*common.Order

NextBatch return the next batch of orders in memory or DB

type TradePairIterator

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

TradePairIterator wrap read trade pair from DB action

func NewTradePairIterator

func NewTradePairIterator(movStore MovStore) *TradePairIterator

NewTradePairIterator create the new TradePairIterator object

func (*TradePairIterator) HasNext

func (t *TradePairIterator) HasNext() bool

HasNext check if there are more trade pairs in memory or DB

func (*TradePairIterator) Next

func (t *TradePairIterator) Next() *common.TradePair

Next return the next available trade pair in memory or DB