mempool

Documentation

Index

• type Config
• type Mempool
  • func NewMempool(config *Config) *Mempool
  • func (mempool *Mempool) FetchTxs() []*blockchain.Tx
  • func (mempool *Mempool) FindTxByHash(hash *utils.Hash) *blockchain.Tx
  • func (mempool *Mempool) ProcessOrphans(tx *blockchain.Tx) []*utils.Hash
  • func (mempool *Mempool) ProcessTx(tx *blockchain.Tx) []*utils.Hash
  • func (mempool *Mempool) RemoveTx(tx *blockchain.Tx)
  • func (mempool *Mempool) Start() error
  • func (mempool *Mempool) Stop() error

Types

type Config

type Config struct {
	FetchUtxos   func(tx *blockchain.Tx) (*blockchain.Utxos, []*network.Outpoint, error)
	OnAcceptedTx func(tx *blockchain.Tx) error
}

type Mempool

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

func NewMempool

func NewMempool(config *Config) *Mempool

func (*Mempool) FetchTxs

func (mempool *Mempool) FetchTxs() []*blockchain.Tx

func (*Mempool) FindTxByHash

func (mempool *Mempool) FindTxByHash(hash *utils.Hash) *blockchain.Tx

func (*Mempool) ProcessOrphans

func (mempool *Mempool) ProcessOrphans(tx *blockchain.Tx) []*utils.Hash

func (*Mempool) ProcessTx

func (mempool *Mempool) ProcessTx(tx *blockchain.Tx) []*utils.Hash

func (*Mempool) RemoveTx

func (mempool *Mempool) RemoveTx(tx *blockchain.Tx)

func (*Mempool) Start

func (mempool *Mempool) Start() error

func (*Mempool) Stop

func (mempool *Mempool) Stop() error