Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mempool

package

Go to main page

Versions in this module

v0

v0.30.1

Mar 1, 2019

Changes in this version

+ const MetricsSubsystem

+ var ErrMempoolIsFull = errors.New("Mempool is full")

+ 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 ErrPreCheck struct

+ Reason error

+ func (e ErrPreCheck) Error() string

type Mempool

+ func (mem *Mempool) CloseWAL()

+ func (mem *Mempool) EnableTxsAvailable()

+ func (mem *Mempool) FlushAppConn() error

+ func (mem *Mempool) InitWAL()

+ 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) TxsAvailable() <-chan struct{}

+ func (mem *Mempool) TxsFront() *clist.CElement

+ func (mem *Mempool) TxsWaitChan() <-chan struct{}

+ type MempoolOption func(*Mempool)

+ func WithMetrics(metrics *Metrics) MempoolOption

+ func WithPostCheck(f PostCheckFunc) MempoolOption

+ func WithPreCheck(f PreCheckFunc) MempoolOption

type MempoolReactor

+ func (memR *MempoolReactor) OnStart() error

+ 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 PostCheckFunc func(types.Tx, *abci.ResponseCheckTx) error

+ func PostCheckMaxGas(maxGas int64) PostCheckFunc

+ type PreCheckFunc func(types.Tx) error

+ func PreCheckAminoMaxBytes(maxBytes int64) PreCheckFunc

v0.30.1-libsecp256k1

Mar 1, 2019

v0.7.0

Aug 7, 2016

Changes in this version

+ const MempoolChannel

+ type Mempool struct

+ func NewMempool(config cfg.Config, proxyAppConn proxy.AppConn) *Mempool

+ func (mem *Mempool) CheckTx(tx types.Tx, cb func(*tmsp.Response)) (err error)

+ func (mem *Mempool) Flush()

+ func (mem *Mempool) Lock()

+ func (mem *Mempool) Reap(maxTxs int) []types.Tx

+ func (mem *Mempool) Size() int

+ func (mem *Mempool) TxsFrontWait() *clist.CElement

+ func (mem *Mempool) Unlock()

+ func (mem *Mempool) Update(height int, txs []types.Tx)

+ type MempoolMessage interface

+ func DecodeMessage(bz []byte) (msgType byte, msg MempoolMessage, err error)

+ type MempoolReactor struct

+ Mempool *Mempool

+ func NewMempoolReactor(config cfg.Config, mempool *Mempool) *MempoolReactor

+ func (memR *MempoolReactor) AddPeer(peer *p2p.Peer)

+ func (memR *MempoolReactor) BroadcastTx(tx types.Tx, cb func(*tmsp.Response)) error

+ func (memR *MempoolReactor) GetChannels() []*p2p.ChannelDescriptor

+ func (memR *MempoolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)

+ func (memR *MempoolReactor) RemovePeer(peer *p2p.Peer, reason interface{})

+ func (memR *MempoolReactor) SetEventSwitch(evsw *events.EventSwitch)

+ type Peer interface

+ Get func(string) interface{}

+ IsRunning func() bool

+ Send func(byte, interface{}) bool

+ type PeerState interface

+ GetHeight func() int

+ type TxMessage struct

+ Tx types.Tx

+ func (m *TxMessage) String() string