server

Dec 4, 2018

Changes in this version

+ func NewJobsQueue(scanner Scanner, db DbWorker, workerBlocks int, resultBlocks int, ...) *jobsQueue

+ type BlocksBulkList struct

+ func NewBlocksBulkList() *BlocksBulkList

+ func (l *BlocksBulkList) AddBlocks(start uint64, insertBlocks []*WalletBlock)

+ func (l *BlocksBulkList) BlocksAvailable(start uint64) int

+ func (l *BlocksBulkList) FindMissingBlocks() (uint64, int)

+ func (l *BlocksBulkList) GetBlocks(start uint64, maxCount int) []*WalletBlock

+ func (l *BlocksBulkList) RemoveBlocks(start uint64, count int)

+ func (l *BlocksBulkList) TrimBlocks(topHeight uint64)

type DbWorker

+ GetTopScannedHeightInfo func(walletId uint32) (utils.HeightInfo, error)

type WalletsDb

+ func (w *WalletsDb) GetTopScannedHeightInfo(walletId uint32) (utils.HeightInfo, error)

Nov 20, 2018

Changes in this version

type WalletBlock

+ Timestamp uint64

Nov 16, 2018

Changes in this version

+ var ErrInternalError = errors.New("internal error")

+ var ErrRequestError = errors.New("request error")

+ func WrapHandler(handler func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)

+ type BlockEntry struct

+ Hash moneroutil.Hash

+ Header []byte

+ Height uint64

+ type BlocksHandler struct

+ func NewBlocksHandler(db DbWorker, scanner Scanner) *BlocksHandler

+ func (b *BlocksHandler) HandleGetBlocks(req *rpc.WalletChainInfoV1) (*rpc.WalletBlocksResult, error)

+ type BlocksScanner struct

+ func NewScanner(db DbWorker) *BlocksScanner

+ func (b *BlocksScanner) GetBlocks(startHeight uint64, wallet utils.WalletEntry, maxBlocks int) ([]WalletBlock, error)

+ type DbWorker interface

+ GetBlockEntry func(height uint64) (BlockEntry, error)

+ GetBlocksAbove func(startHeight uint64, maxCount int) ([]PreparsedBlock, error)

+ GetChainIntersection func(chain []moneroutil.Hash) (utils.HeightInfo, error)

+ GetOrCreateKeyProgress func(account utils.AccountInfo) (utils.WalletEntry, error)

+ GetTopBlockHeight func() (uint64, error)

+ GetWalletBlocks func(walletId uint32, startHeight uint64, maxBlocks int) ([]PreSerializedBlock, error)

+ GetWalletOutputs func(walletId uint32) ([]OutputHeight, error)

+ SaveWalletBlocks func(walletId uint32, blocks []moneroutil.Hash, outputs []OutputHeight) error

+ SaveWalletProgress func(walletId uint32, hash moneroutil.Hash) error

+ func NewDbWorker(settings utils.DbSettings) (DbWorker, error)

+ type ExtSerializedTx struct

+ Blob []byte

+ Hash moneroutil.Hash

+ OutputIndices []uint64

+ type OutputHeight struct

+ Height uint64

+ OutputIndex uint64

+ type PreSerializedBlock struct

+ Hash moneroutil.Hash

+ Header []byte

+ Height uint64

+ Txs []ExtSerializedTx

+ type PreparsedBlock struct

+ Txs []PreparsedTx

+ type PreparsedTx struct

+ Blob []byte

+ Hash moneroutil.Hash

+ OutputIndices []uint64

+ OutputKeys []moneroutil.Key

+ UsedInputs []uint64

+ type Scanner interface

+ GetBlocks func(startHeight uint64, wallet utils.WalletEntry, maxBlocks int) ([]WalletBlock, error)

+ type Server struct

+ func NewServer(handler *BlocksHandler) *Server

+ func (s *Server) HandleGetBlocks(resp http.ResponseWriter, req *http.Request)

+ func (s *Server) HandleVersions(resp http.ResponseWriter, req *http.Request)

+ func (s *Server) StartAsync(address string)

+ type WalletBlock struct

+ Bce *moneroproto.BlockCompleteEntry

+ Hash moneroutil.Hash

+ OutputIndices [][]uint64

+ type WalletsDb struct

+ func (w *WalletsDb) GetBlockEntry(height uint64) (BlockEntry, error)

+ func (w *WalletsDb) GetBlocksAbove(startHeight uint64, maxCount int) ([]PreparsedBlock, error)

+ func (w *WalletsDb) GetChainIntersection(chain []moneroutil.Hash) (utils.HeightInfo, error)

+ func (w *WalletsDb) GetOrCreateKeyProgress(account utils.AccountInfo) (utils.WalletEntry, error)

+ func (w *WalletsDb) GetTopBlockHeight() (uint64, error)

+ func (w *WalletsDb) GetWalletBlocks(walletId uint32, startHeight uint64, maxBlocks int) ([]PreSerializedBlock, error)

+ func (w *WalletsDb) GetWalletOutputs(walletId uint32) ([]OutputHeight, error)

+ func (w *WalletsDb) SaveWalletBlocks(walletId uint32, blocks []moneroutil.Hash, outputs []OutputHeight) error

+ func (w *WalletsDb) SaveWalletProgress(walletId uint32, hash moneroutil.Hash) error