tnmpool

package

v0.0.0-...-a0a9112 Latest Latest Go to latest Published: Nov 21, 2023 License: GPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Documentation ¶

Overview ¶

Package tnmpool is an autonomous module to handle the new-coming txs from internal or external events tnmpool's use requires some other module's initialization: - blockchain(and tnmblocks) - tnmstate - tnmp2p - storage

Index ¶

Variables
type TxPool
- func Init(db *bbolt.DB, chain *blockchain.Chain, localNode *tnmp2p.LocalNode) *TxPool

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrTxInvalidHeight = errors.New("invalid tx height")

Functions ¶

This section is empty.

Types ¶

type TxPool ¶

type TxPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

TxPool is a little mem db which stores **signed** tx. RULE: One Account can only send one Tx, all Txs will be accepted Every time the state updated, the old pool will be deprecated.

func Init ¶

func Init(db *bbolt.DB, chain *blockchain.Chain, localNode *tnmp2p.LocalNode) *TxPool

func (*TxPool) GetPack ¶

func (pool *TxPool) GetPack(height uint64) tnmtypes.TxTrie

GetPack will gives a sorted TxTire.

func (*TxPool) IsInPool ¶

func (pool *TxPool) IsInPool(txHash []byte) (exists bool, inPoolTx *tnmtypes.FullTx)

IsInPool checks one tx is in pool or not.

func (*TxPool) PutNewTxFromLocal ¶

func (pool *TxPool) PutNewTxFromLocal(tx *tnmtypes.FullTx) (err error)

PutNewTxFromLocal puts tx from local(rpc) into txpool.

func (*TxPool) PutNewTxFromRemote ¶

func (pool *TxPool) PutNewTxFromRemote(tx *tnmtypes.FullTx) (err error)

PutNewTxFromRemote puts tx from local(rpc) into txpool.

func (*TxPool) PutTx ¶

func (pool *TxPool) PutTx(tx *tnmtypes.FullTx) error

PutTx puts txs from network(p2p) or RPC into txpool, should check error before putting.

func (*TxPool) Reset ¶

func (pool *TxPool) Reset()

Reset cleans all txs inside the pool.

Source Files ¶

View all Source files

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