txpool

Documentation

Index

• Constants
• Variables
• type ATxPoolThreadsName
• type AtxPoolWorkMode
• type State
• type TxPool
  • func NewTxPool(ind *core.IpfsNode, chainID string, cvfs vdb.CVFS, acc EAccount.Account, ...) TxPool

Constants

const (
	PackageTxsLimit = 2048

	AtxPoolWorkModeNormal AtxPoolWorkMode = 0
	AtxPoolWorkModeSuper  AtxPoolWorkMode = 1

	ATxPoolThreadTxListen  ATxPoolThreadsName = "ATxPoolThreadTxListen"
	ATxPoolThreadTxPackage ATxPoolThreadsName = "ATxPoolThreadTxPackage"
	ATxPoolThreadRepeater  ATxPoolThreadsName = "ATxPoolThreadRepeater"

	ATxPoolThreadElectoralTimeout ATxPoolThreadsName = "ATxPoolThreadElectoralTimeout"
)

const AtxPoolVersion = "AyaTxPool 0.0.1"

Variables

var (
	ErrRawDBEndoedZeroLen        = errors.New("ready to sent content is empty")
	ErrMessageVerifyExpected     = errors.New("message verify failed")
	ErrTxVerifyExpected          = errors.New("tx tid verify expected")
	ErrTxVerifyInsufficientFunds = errors.New("insufficient funds ( value + cost )")

	ErrCannotCreateMiningBlock = errors.New("can not create new mining block")
)

Types

type ATxPoolThreadsName

type ATxPoolThreadsName string

type AtxPoolWorkMode

type AtxPoolWorkMode uint8

type State

type State struct {
	Account string

	Pending int

	WorkMode string

	Version string
}

type TxPool

type TxPool interface {
	PowerOn(ctx context.Context)

	PublishTx(tx *im.Transaction) error

	ElectoralServices() AElectoral.MemServices

	GetWorkMode() AtxPoolWorkMode

	GetState() *State

	GetTx(hash EComm.Hash) *im.Transaction
}

func NewTxPool

func NewTxPool(ind *core.IpfsNode, chainID string, cvfs vdb.CVFS, acc EAccount.Account, mchannel string, asd ASD.StatDaemon) TxPool