txpool

package

v0.2.0 Latest Latest Go to latest Published: Nov 21, 2018 License: MIT Imports: 14 Imported by: 0

Details

View Source

const (
	TxMsgBufferChSize          = 65536
	ChainUpdateMsgBufferChSize = 65536
)

const defines constants

This section is empty.

This section is empty.

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

TransactionPool define struct.

func NewTransactionPool(parent goprocess.Process, notifiee p2p.Net, c *chain.BlockChain, bus eventbus.Bus) *TransactionPool

NewTransactionPool new a transaction pool.

func (tx_pool *TransactionPool) GetAllTxs() []*chain.TxWrap

GetAllTxs returns all transactions in mempool

func (tx_pool *TransactionPool) GetTransactionsInPool() []*types.Transaction

GetTransactionsInPool gets all transactions in memory pool

func (tx_pool *TransactionPool) Proc() goprocess.Process

Proc returns the goprocess of the TransactionPool

func (tx_pool *TransactionPool) ProcessTx(tx *types.Transaction, broadcast bool) error

ProcessTx is used to handle new transactions. utxoSet: utxos associated with the tx

func (tx_pool *TransactionPool) Run() error

Run launch transaction pool.

func (tx_pool *TransactionPool) Stop()

Stop the server