Versions in this module Expand all Collapse all v0 v0.31.5 Apr 16, 2019 Changes in this version + const MempoolChannel + const MetricsSubsystem + const UnknownPeerID + var ErrTxInCache = errors.New("Tx already exists in cache") + var ErrTxTooLarge = fmt.Errorf("Tx too large. Max size is %d", maxTxSize) + func IsPreCheckError(err error) bool + func RegisterMempoolMessages(cdc *amino.Codec) + func TxID(tx []byte) string + type ErrMempoolIsFull struct + func (e ErrMempoolIsFull) Error() string + type ErrPreCheck struct + Reason error + func (e ErrPreCheck) Error() string + type Mempool struct + func NewMempool(config *cfg.MempoolConfig, proxyAppConn proxy.AppConnMempool, height int64, ...) *Mempool + func (mem *Mempool) CheckTx(tx types.Tx, cb func(*abci.Response)) (err error) + func (mem *Mempool) CheckTxWithInfo(tx types.Tx, cb func(*abci.Response), txInfo TxInfo) (err error) + func (mem *Mempool) CloseWAL() + func (mem *Mempool) EnableTxsAvailable() + func (mem *Mempool) Flush() + func (mem *Mempool) FlushAppConn() error + func (mem *Mempool) InitWAL() + func (mem *Mempool) Lock() + func (mem *Mempool) ReapMaxBytesMaxGas(maxBytes, maxGas int64) types.Txs + func (mem *Mempool) ReapMaxTxs(max int) types.Txs + func (mem *Mempool) SetLogger(l log.Logger) + func (mem *Mempool) Size() int + func (mem *Mempool) TxsAvailable() <-chan struct{} + func (mem *Mempool) TxsBytes() int64 + func (mem *Mempool) TxsFront() *clist.CElement + func (mem *Mempool) TxsWaitChan() <-chan struct{} + func (mem *Mempool) Unlock() + func (mem *Mempool) Update(height int64, txs types.Txs, preCheck PreCheckFunc, postCheck PostCheckFunc) error + type MempoolMessage interface + type MempoolOption func(*Mempool) + func WithMetrics(metrics *Metrics) MempoolOption + func WithPostCheck(f PostCheckFunc) MempoolOption + func WithPreCheck(f PreCheckFunc) MempoolOption + type MempoolReactor struct + Mempool *Mempool + func NewMempoolReactor(config *cfg.MempoolConfig, mempool *Mempool) *MempoolReactor + func (memR *MempoolReactor) AddPeer(peer p2p.Peer) + func (memR *MempoolReactor) GetChannels() []*p2p.ChannelDescriptor + func (memR *MempoolReactor) OnStart() error + func (memR *MempoolReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (memR *MempoolReactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (memR *MempoolReactor) SetLogger(l log.Logger) + type Metrics struct + FailedTxs metrics.Counter + RecheckTimes metrics.Counter + Size metrics.Gauge + TxSizeBytes metrics.Histogram + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics + type PeerState interface + GetHeight func() int64 + type PostCheckFunc func(types.Tx, *abci.ResponseCheckTx) error + func PostCheckMaxGas(maxGas int64) PostCheckFunc + type PreCheckFunc func(types.Tx) error + func PreCheckAminoMaxBytes(maxBytes int64) PreCheckFunc + type TxInfo struct + PeerID uint16 + type TxMessage struct + Tx types.Tx + func (m *TxMessage) String() string
Go to main page