mempool

Documentation

Index

• Variables
• type API
  • func (s *API) Status() map[string]hexutil.Uint
• type Mempool
  • func NewMempool(chain *core.BlockChain, logger log.Logger) *Mempool
  • func (pool *Mempool) AddLocal(tx types.Tx) error
  • func (pool *Mempool) AddLocals(txs []types.Tx) []error
  • func (pool *Mempool) AddTxs(txs []types.Tx) []error
  • func (pool *Mempool) OnStart() error
  • func (pool *Mempool) OnStop()
  • func (pool *Mempool) Pending() types.Txs
  • func (pool *Mempool) RegisterAPI()
  • func (pool *Mempool) Stats() (int, int)

Variables

var (
	ErrAlreadyKnown   = errors.New("already known")
	ErrTxPoolOverflow = errors.New("txpool is full")
)

Types

type API

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

func (*API) Status

func (s *API) Status() map[string]hexutil.Uint

Status returns the number of pending and queued transaction in the pool.

type Mempool

type Mempool struct {
	service.BaseService
	// contains filtered or unexported fields
}

func NewMempool

func NewMempool(chain *core.BlockChain, logger log.Logger) *Mempool

func (*Mempool) AddLocal

func (pool *Mempool) AddLocal(tx types.Tx) error

func (*Mempool) AddLocals

func (pool *Mempool) AddLocals(txs []types.Tx) []error

func (*Mempool) AddTxs

func (pool *Mempool) AddTxs(txs []types.Tx) []error

func (*Mempool) OnStart

func (pool *Mempool) OnStart() error

func (*Mempool) OnStop

func (pool *Mempool) OnStop()

func (*Mempool) Pending

func (pool *Mempool) Pending() types.Txs

func (*Mempool) RegisterAPI

func (pool *Mempool) RegisterAPI()

func (*Mempool) Stats

func (pool *Mempool) Stats() (int, int)