blockprocessor

Documentation

Index

• type BlockProcessor
  • func NewBlockProcessor(w *wallet.Wallet, c *rpcclient.Client, conf *config.Config) *BlockProcessor
  • func (bp *BlockProcessor) GetSyncStatus() SyncStatus
  • func (bp *BlockProcessor) Loop()
  • func (bp *BlockProcessor) PersistChainState()
  • func (bp *BlockProcessor) ReadChainState()
  • func (bp *BlockProcessor) UpdateClient(c *rpcclient.Client)
• type ChainIndex
  • func (activeChain ChainIndex) FindBlock(hash *chainhash.Hash) int
• type SyncStatus

Types

type BlockProcessor

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

func NewBlockProcessor

func NewBlockProcessor(w *wallet.Wallet, c *rpcclient.Client, conf *config.Config) *BlockProcessor

func (*BlockProcessor) GetSyncStatus

func (bp *BlockProcessor) GetSyncStatus() SyncStatus

func (*BlockProcessor) Loop

func (bp *BlockProcessor) Loop()

func (*BlockProcessor) PersistChainState

func (bp *BlockProcessor) PersistChainState()

func (*BlockProcessor) ReadChainState

func (bp *BlockProcessor) ReadChainState()

func (*BlockProcessor) UpdateClient

func (bp *BlockProcessor) UpdateClient(c *rpcclient.Client)

type ChainIndex

type ChainIndex []*chainhash.Hash

func (ChainIndex) FindBlock

func (activeChain ChainIndex) FindBlock(hash *chainhash.Hash) int

type SyncStatus

type SyncStatus struct {
	Connected   bool
	Synced      bool
	Syncing     bool
	SyncHeight  int
	TipHeight   int
	HeaderQueue int
}