storage

package

v0.2.0 Latest Latest Go to latest Published: Feb 14, 2019 License: MIT Imports: 10 Imported by: 0

Details

View Source

const (
	ROLLBACK_MAX_BLOCKS = 2000
	RECORD_SIZE         = crypto.SignatureSize + 8
)

View Source

var Empty struct{}

This section is empty.

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

func NewAccountsStorage(globalStor, addr2Index, asset2Index keyvalue.IterableKeyVal, blockIdsFile string) (*AccountsStorage, error)

func (s *AccountsStorage) AccountBalance(addr proto.Address, asset []byte) (uint64, error)

func (s *AccountsStorage) RollbackBlock(blockID crypto.Signature) error

func (s *AccountsStorage) SetAccountBalance(addr proto.Address, asset []byte, balance uint64, blockID crypto.Signature) error

func (s *AccountsStorage) WavesAddressesNumber() (uint64, error)

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

func NewBlockReadWriter(dir string, offsetLen, headerOffsetLen int, keyVal keyvalue.KeyValue) (*BlockReadWriter, error)

func (rw *BlockReadWriter) BlockIDByHeight(height uint64) (crypto.Signature, error)

func (rw *BlockReadWriter) BlockIdsFilePath() (string, error)

func (rw *BlockReadWriter) Close() error

func (rw *BlockReadWriter) CurrentHeight() uint64

func (rw *BlockReadWriter) FinishBlock(blockID crypto.Signature) error

func (rw *BlockReadWriter) HeightByBlockID(blockID crypto.Signature) (uint64, error)

func (rw *BlockReadWriter) ReadBlockHeader(blockID crypto.Signature) ([]byte, error)

func (rw *BlockReadWriter) ReadTransaction(txID []byte) ([]byte, error)

func (rw *BlockReadWriter) ReadTransactionsBlock(blockID crypto.Signature) ([]byte, error)

func (rw *BlockReadWriter) RemoveBlocks(removalEdge crypto.Signature) error

func (rw *BlockReadWriter) StartBlock(blockID crypto.Signature) error

func (rw *BlockReadWriter) WriteBlockHeader(blockID crypto.Signature, header []byte) error

func (rw *BlockReadWriter) WriteTransaction(txID []byte, tx []byte) error