minerpool

Documentation

Index

• Variables
• type MinerPool
  • func NewPool(ind *core.IpfsNode, chainID string, idxser AIndexes.IndexesServices, ...) MinerPool
• type MiningResult
• type MiningTask
  • func NewTask(block *im.Block) *MiningTask

Variables

var (
	ErrNotLinearBlock  = errors.New("not a linear mining block")
	ErrInvalidLatest   = errors.New("invalid latest block")
	ErrInvalidChainID  = errors.New("invalid ChainID")
	ErrCreateBatch     = errors.New("create cvfs merger failed")
	ErrReadTxsTimeOut  = errors.New("read transaction list from IPFS dag timeout")
	ErrLinkCVFS        = errors.New("can not link to target CVFS")
	ErrCreateCVFSCache = errors.New("can not create cvfs cache(writer)")
)

Types

type MinerPool

type MinerPool interface {
	PutTask(task *MiningTask) *MiningResult
}

func NewPool

func NewPool(ind *core.IpfsNode, chainID string, idxser AIndexes.IndexesServices, asd ASD.StatDaemon) MinerPool

type MiningResult

type MiningResult struct {
	Err error

	Batcher merger.CVFSMerger

	Task *MiningTask
}

type MiningTask

type MiningTask struct {
	MiningBlock *im.Block

	Txs []*im.Transaction

	VWriter VDB.CacheCVFS
}

func NewTask

func NewTask(block *im.Block) *MiningTask