Documentation ¶
Index ¶
- type Store
- func (store *Store) AfterCommit()
- func (store *Store) AfterRecover()
- func (store *Store) BeforeRecover([]byte)
- func (store *Store) CancelPrepare()
- func (store *Store) Clean() error
- func (store *Store) Close() error
- func (store *Store) Commit() error
- func (store *Store) CompactRange(r util.Range) error
- func (store *Store) Get(key []byte) ([]byte, error)
- func (store *Store) GetOriginal(key []byte) ([]byte, error)
- func (store *Store) GetStatus() []interfaces.DBStatus
- func (store *Store) Has(key []byte) (bool, error)
- func (store *Store) Id() types.Hash
- func (store *Store) NewBatch() *leveldb.Batch
- func (store *Store) NewIterator(slice *util.Range) interfaces.StorageIterator
- func (store *Store) PatchRedoLog(redoLog []byte) error
- func (store *Store) Prepare()
- func (store *Store) RedoLog() ([]byte, error)
- func (store *Store) RegisterAfterRecover(f func())
- func (store *Store) RollbackAccountBlockByHash(rollbackBatch *leveldb.Batch, blockHashList []types.Hash)
- func (store *Store) RollbackAccountBlocks(rollbackBatch *leveldb.Batch, accountBlocks []*ledger.AccountBlock)
- func (store *Store) RollbackSnapshot(rollbackBatch *leveldb.Batch)
- func (store *Store) WriteAccountBlock(batch *leveldb.Batch, block *ledger.AccountBlock)
- func (store *Store) WriteAccountBlockByHash(batch *leveldb.Batch, blockHash types.Hash)
- func (store *Store) WriteDirectly(batch *leveldb.Batch)
- func (store *Store) WriteSnapshot(snapshotBatch *leveldb.Batch, accountBlocks []*ledger.AccountBlock)
- func (store *Store) WriteSnapshotByHash(snapshotBatch *leveldb.Batch, blockHashList []types.Hash)
- type UnconfirmedBatchs
- func (ub *UnconfirmedBatchs) All(f func(batch *leveldb.Batch))
- func (ub *UnconfirmedBatchs) Clear()
- func (ub *UnconfirmedBatchs) Get(blockHash types.Hash) (*leveldb.Batch, bool)
- func (ub *UnconfirmedBatchs) Put(blockHash types.Hash, batch *leveldb.Batch)
- func (ub *UnconfirmedBatchs) Remove(blockHash types.Hash)
- func (ub *UnconfirmedBatchs) Size() int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func NewStoreWithDb ¶
func (*Store) AfterCommit ¶
func (store *Store) AfterCommit()
assume lock write when call after commit
func (*Store) CancelPrepare ¶
func (store *Store) CancelPrepare()
assume lock write when cancel prepare
func (*Store) GetStatus ¶
func (store *Store) GetStatus() []interfaces.DBStatus
func (*Store) NewIterator ¶
func (store *Store) NewIterator(slice *util.Range) interfaces.StorageIterator
func (*Store) RollbackAccountBlockByHash ¶
func (store *Store) RollbackAccountBlockByHash(rollbackBatch *leveldb.Batch, blockHashList []types.Hash)
rollback
func (*Store) RollbackAccountBlocks ¶
func (store *Store) RollbackAccountBlocks(rollbackBatch *leveldb.Batch, accountBlocks []*ledger.AccountBlock)
rollback
func (*Store) WriteAccountBlock ¶
func (store *Store) WriteAccountBlock(batch *leveldb.Batch, block *ledger.AccountBlock)
func (*Store) WriteAccountBlockByHash ¶
func (*Store) WriteSnapshot ¶
func (store *Store) WriteSnapshot(snapshotBatch *leveldb.Batch, accountBlocks []*ledger.AccountBlock)
snapshot
type UnconfirmedBatchs ¶
type UnconfirmedBatchs struct {
// contains filtered or unexported fields
}
func NewUnconfirmedBatchs ¶
func NewUnconfirmedBatchs() *UnconfirmedBatchs
func (*UnconfirmedBatchs) All ¶
func (ub *UnconfirmedBatchs) All(f func(batch *leveldb.Batch))
func (*UnconfirmedBatchs) Clear ¶
func (ub *UnconfirmedBatchs) Clear()
func (*UnconfirmedBatchs) Get ¶
func (ub *UnconfirmedBatchs) Get(blockHash types.Hash) (*leveldb.Batch, bool)
func (*UnconfirmedBatchs) Put ¶
func (ub *UnconfirmedBatchs) Put(blockHash types.Hash, batch *leveldb.Batch)
func (*UnconfirmedBatchs) Remove ¶
func (ub *UnconfirmedBatchs) Remove(blockHash types.Hash)
func (*UnconfirmedBatchs) Size ¶
func (ub *UnconfirmedBatchs) Size() int
Click to show internal directories.
Click to hide internal directories.