mempool

Documentation

Index

• Variables
• type HashMap
  • func (m HashMap) Clone() []transactions.ContractCall
  • func (m *HashMap) Close()
  • func (m *HashMap) Contains(txID []byte) bool
  • func (m *HashMap) Create(path string) error
  • func (m *HashMap) Delete(txID []byte) error
  • func (m HashMap) FilterByType(filterType transactions.TxType) []transactions.ContractCall
  • func (m *HashMap) Get(txID []byte) transactions.ContractCall
  • func (m *HashMap) Len() int
  • func (m *HashMap) Put(t TxDesc) error
  • func (m *HashMap) Range(fn func(k txHash, t TxDesc) error) error
  • func (m *HashMap) RangeSort(fn func(k txHash, t TxDesc) (bool, error)) error
  • func (m *HashMap) Size() uint32
• type Mempool
  • func NewMempool(db database.DB, eventBus *eventbus.EventBus, rpcBus *rpcbus.RPCBus, ...) *Mempool
  • func (m *Mempool) Loop(ctx context.Context)
  • func (m *Mempool) OnClose()
  • func (m *Mempool) ProcessTx(srcPeerID string, msg message.Message) ([]bytes.Buffer, error)
  • func (m *Mempool) Run(ctx context.Context)
• type Pool
• type TxDesc

Variables

var (
	// ErrCoinbaseTxNotAllowed coinbase tx must be built by block generator only.
	ErrCoinbaseTxNotAllowed = errors.New("coinbase tx not allowed")
	// ErrAlreadyExists transaction with the same txid already exists in mempool.
	ErrAlreadyExists = errors.New("already exists")
	// ErrAlreadyExistsInBlockchain transaction with the same txid already exists in blockchain.
	ErrAlreadyExistsInBlockchain = errors.New("already exists in blockchain")
)

Types

type HashMap

type HashMap struct {

	// spent key images from the transactions in the pool
	// spentkeyImages map[keyImage]bool.
	Capacity uint32
	// contains filtered or unexported fields
}

HashMap represents a pool implementation based on golang map. The generic solution to bench against.

func (HashMap) Clone

func (m HashMap) Clone() []transactions.ContractCall

Clone the entire pool.

func (*HashMap) Close

func (m *HashMap) Close()

Close empty implementation of Pool.Close.

func (*HashMap) Contains

func (m *HashMap) Contains(txID []byte) bool

Contains returns true if the given key is in the pool.

func (*HashMap) Create

func (m *HashMap) Create(path string) error

Create instantiates hashmap and sort index.

func (*HashMap) Delete

func (m *HashMap) Delete(txID []byte) error

Delete a key in the hashmap.

func (HashMap) FilterByType

func (m HashMap) FilterByType(filterType transactions.TxType) []transactions.ContractCall

FilterByType returns all transactions for a specific type that are currently in the HashMap.

func (*HashMap) Get

func (m *HashMap) Get(txID []byte) transactions.ContractCall

Get returns a tx for a given txID if it exists.

func (*HashMap) Len

func (m *HashMap) Len() int

Len returns the number of tx entries.

func (*HashMap) Put

func (m *HashMap) Put(t TxDesc) error

Put sets the value for the given key. It overwrites any previous value for that key.

func (*HashMap) Range

func (m *HashMap) Range(fn func(k txHash, t TxDesc) error) error

Range iterates through all tx entries.

func (*HashMap) RangeSort

func (m *HashMap) RangeSort(fn func(k txHash, t TxDesc) (bool, error)) error

RangeSort iterates through all tx entries sorted by Fee in a descending order.

func (*HashMap) Size

func (m *HashMap) Size() uint32

Size of the txs.

type Mempool

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

Mempool is a storage for the chain transactions that are valid according to the current chain state and can be included in the next block.

func NewMempool

func NewMempool(db database.DB, eventBus *eventbus.EventBus, rpcBus *rpcbus.RPCBus, verifier transactions.UnconfirmedTxProber) *Mempool

NewMempool instantiates and initializes node mempool.

func (*Mempool) Loop

func (m *Mempool) Loop(ctx context.Context)

Loop listens for GetMempoolTxs request and topics.AcceptedBlock events.

func (*Mempool) OnClose

func (m *Mempool) OnClose()

OnClose performs mempool cleanup procedure. It's called on canceling mempool context.

func (*Mempool) ProcessTx

func (m *Mempool) ProcessTx(srcPeerID string, msg message.Message) ([]bytes.Buffer, error)

ProcessTx processes a Transaction wire message.

func (*Mempool) Run

func (m *Mempool) Run(ctx context.Context)

Run spawns the mempool lifecycle routines.

type Pool

type Pool interface {
	// Create instantiates the underlying data storage.
	Create(path string) error
	// Put sets the value for the given key. It overwrites any previous value
	// for that key.
	Put(t TxDesc) error
	// Get retrieves a transaction for a given txID, if it exists.
	Get(txID []byte) transactions.ContractCall
	// Contains returns true if the given key is in the pool.
	Contains(key []byte) bool
	// Delete a key in the pool.
	Delete(key []byte) error
	// Clone the entire pool.
	Clone() []transactions.ContractCall

	// FilterByType returns all verified transactions for a specific type.
	FilterByType(transactions.TxType) []transactions.ContractCall

	// Size is total number of bytes of all txs marshaling size.
	Size() uint32
	// Len returns the number of tx entries.
	Len() int

	// Range iterates through all tx entries.
	Range(fn func(k txHash, t TxDesc) error) error

	// RangeSort iterates through all tx entries sorted by Fee
	// in a descending order.
	RangeSort(fn func(k txHash, t TxDesc) (bool, error)) error

	// Close closes backend.
	Close()
}

Pool represents a transaction pool of the verified txs only.

type TxDesc

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

TxDesc encapsulates both tx raw and meta data.