txpool

package
v0.0.0-...-168a7d3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2019 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PackageTxsLimit = 2048

	AtxPoolWorkModeNormal AtxPoolWorkMode = 0
	AtxPoolWorkModeSuper  AtxPoolWorkMode = 1

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

	ATxPoolThreadElectoralTimeout ATxPoolThreadsName = "ATxPoolThreadElectoralTimeout"
)
View Source
const AtxPoolVersion = "AyaTxPool 0.0.1"

Variables

View Source
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")
)

Functions

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL