miner

Documentation

Index

• type Miner
  • func NewMiner(cfgFile string, chain PovChainReader, txPool PovTxPoolReader, ...) *Miner
  • func (miner *Miner) GetAccounts() []*types.Account
  • func (miner *Miner) GetChain() PovChainReader
  • func (miner *Miner) GetConfig() *config.Config
  • func (miner *Miner) GetLogger() *zap.SugaredLogger
  • func (miner *Miner) GetPovConsensus() PovConsensusReader
  • func (miner *Miner) GetSyncState() topic.SyncState
  • func (miner *Miner) GetTxPool() PovTxPoolReader
  • func (miner *Miner) Init() error
  • func (miner *Miner) Start() error
  • func (miner *Miner) Stop() error
• type PovChainReader
• type PovConsensusReader
• type PovMinerAlgoBlock
• type PovTxPoolReader
• type PovWorker
  • func NewPovWorker(cc *context.ChainContext, miner *Miner) *PovWorker
  • func (w *PovWorker) GetAlgoType() types.PovAlgoType
  • func (w *PovWorker) GetConfig() *config.Config
  • func (w *PovWorker) GetMinerAccount() *types.Account
  • func (w *PovWorker) GetMinerAddress() types.Address
  • func (w *PovWorker) GetMiningInfo(in interface{}, out interface{})
  • func (w *PovWorker) GetWork(in interface{}, out interface{})
  • func (w *PovWorker) Init() error
  • func (w *PovWorker) OnEventRpcSyncCall(msg *topic.EventRPCSyncCallMsg)
  • func (w *PovWorker) Start() error
  • func (w *PovWorker) StartMining(in interface{}, out interface{})
  • func (w *PovWorker) Stop() error
  • func (w *PovWorker) StopMining(in interface{}, out interface{})
  • func (w *PovWorker) SubmitWork(in interface{}, out interface{})

Types

type Miner

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

func NewMiner

func NewMiner(cfgFile string, chain PovChainReader, txPool PovTxPoolReader, cs PovConsensusReader) *Miner

func (*Miner) GetAccounts

func (miner *Miner) GetAccounts() []*types.Account

func (*Miner) GetChain

func (miner *Miner) GetChain() PovChainReader

func (*Miner) GetConfig

func (miner *Miner) GetConfig() *config.Config

func (*Miner) GetLogger

func (miner *Miner) GetLogger() *zap.SugaredLogger

func (*Miner) GetPovConsensus

func (miner *Miner) GetPovConsensus() PovConsensusReader

func (*Miner) GetSyncState

func (miner *Miner) GetSyncState() topic.SyncState

func (*Miner) GetTxPool

func (miner *Miner) GetTxPool() PovTxPoolReader

func (*Miner) Init

func (miner *Miner) Init() error

func (*Miner) Start

func (miner *Miner) Start() error

func (*Miner) Stop

func (miner *Miner) Stop() error

type PovChainReader

type PovChainReader interface {
	LatestHeader() *types.PovHeader
	LatestBlock() *types.PovBlock
	TransitStateDB(height uint64, txs []*types.PovTransaction, gsdb *statedb.PovGlobalStateDB) error
	CalcBlockReward(header *types.PovHeader) (types.Balance, types.Balance, error)
	CalcPastMedianTime(prevHeader *types.PovHeader) uint32
}

type PovConsensusReader

type PovConsensusReader interface {
	PrepareHeader(header *types.PovHeader) error
}

type PovMinerAlgoBlock

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

type PovTxPoolReader

type PovTxPoolReader interface {
	SelectPendingTxs(gsdb *statedb.PovGlobalStateDB, limit int) []*types.StateBlock
	LastUpdated() time.Time
	GetPendingTxNum() uint32
}

type PovWorker

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

func NewPovWorker

func NewPovWorker(cc *context.ChainContext, miner *Miner) *PovWorker

func (*PovWorker) GetAlgoType

func (w *PovWorker) GetAlgoType() types.PovAlgoType

func (*PovWorker) GetConfig

func (w *PovWorker) GetConfig() *config.Config

func (*PovWorker) GetMinerAccount

func (w *PovWorker) GetMinerAccount() *types.Account

func (*PovWorker) GetMinerAddress

func (w *PovWorker) GetMinerAddress() types.Address

func (*PovWorker) GetMiningInfo

func (w *PovWorker) GetMiningInfo(in interface{}, out interface{})

func (*PovWorker) GetWork

func (w *PovWorker) GetWork(in interface{}, out interface{})

func (*PovWorker) Init

func (w *PovWorker) Init() error

func (*PovWorker) OnEventRpcSyncCall

func (w *PovWorker) OnEventRpcSyncCall(msg *topic.EventRPCSyncCallMsg)

func (*PovWorker) Start

func (w *PovWorker) Start() error

func (*PovWorker) StartMining

func (w *PovWorker) StartMining(in interface{}, out interface{})

func (*PovWorker) Stop

func (w *PovWorker) Stop() error

func (*PovWorker) StopMining

func (w *PovWorker) StopMining(in interface{}, out interface{})

func (*PovWorker) SubmitWork

func (w *PovWorker) SubmitWork(in interface{}, out interface{})