pool

Documentation

Index

• Constants
• Variables
• type Mempool
  • func NewMempool(bus EventBus.Bus, cm cache.CacheManager) (*Mempool, error)
  • func (mp *Mempool) DeleteTx(txHash []byte) error
  • func (mp *Mempool) GetAllTransactions() []*types2.Transaction
  • func (mp *Mempool) GetTransaction(hash []byte) (*types2.Transaction, error)
  • func (mp *Mempool) GetTransactionsForNewBlock() []*types2.Transaction
  • func (mp *Mempool) StoreTx(tx *types2.Transaction) error

Constants

const (
	DefaultTxTTL    = 10 * time.Minute
	DefaultTxPrefix = "tx_"
)

Variables

var (
	ErrTxNotFound = errors.New("tx isn't found in mempool")
)

Types

type Mempool

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

func NewMempool

func NewMempool(bus EventBus.Bus, cm cache.CacheManager) (*Mempool, error)

func (*Mempool) DeleteTx

func (mp *Mempool) DeleteTx(txHash []byte) error

func (*Mempool) GetAllTransactions

func (mp *Mempool) GetAllTransactions() []*types2.Transaction

func (*Mempool) GetTransaction

func (mp *Mempool) GetTransaction(hash []byte) (*types2.Transaction, error)

func (*Mempool) GetTransactionsForNewBlock

func (mp *Mempool) GetTransactionsForNewBlock() []*types2.Transaction

func (*Mempool) StoreTx

func (mp *Mempool) StoreTx(tx *types2.Transaction) error