txpool

Documentation

Index

• type TxData
• type TxMap
• type TxPool
  • func New() *TxPool
  • func (t *TxPool) AddEVMTransaction(id types.MessageID, v any, sig *sign.Transaction, evmTxHash string) types.TxHash
  • func (t *TxPool) AddTransaction(id types.MessageID, v any, sig *sign.Transaction) types.TxHash
  • func (t *TxPool) CopyTransactions(ctx context.Context) *TxPool
  • func (t *TxPool) ForID(id types.MessageID) []TxData
  • func (t *TxPool) GetAmountOfTxs() int
  • func (t *TxPool) GetEVMTxs() []TxData
  • func (t *TxPool) Transactions() TxMap

Types

type TxData

type TxData struct {
	MsgID  types.MessageID
	Msg    any
	TxHash types.TxHash
	Tx     *sign.Transaction
	// EVMSourceTxHash is the tx hash of the EVM tx that triggered this tx.
	EVMSourceTxHash string
}

type TxMap

type TxMap map[types.MessageID][]TxData

type TxPool

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

func New

func New() *TxPool

func (*TxPool) AddEVMTransaction

func (t *TxPool) AddEVMTransaction(id types.MessageID, v any, sig *sign.Transaction, evmTxHash string) types.TxHash

func (*TxPool) AddTransaction

func (t *TxPool) AddTransaction(id types.MessageID, v any, sig *sign.Transaction) types.TxHash

func (*TxPool) CopyTransactions

func (t *TxPool) CopyTransactions(ctx context.Context) *TxPool

CopyTransactions returns a copy of the TxPool, and resets the state to 0 values.

func (*TxPool) ForID

func (t *TxPool) ForID(id types.MessageID) []TxData

func (*TxPool) GetAmountOfTxs

func (t *TxPool) GetAmountOfTxs() int

func (*TxPool) GetEVMTxs

func (t *TxPool) GetEVMTxs() []TxData

GetEVMTxs gets all the txs in the queue that originated from the EVM. NOTE: this is called ONLY in the copied tx queue in world.doTick, so we do not need to use the mutex here.

func (*TxPool) Transactions

func (t *TxPool) Transactions() TxMap