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

base

package

Go to main page

Versions in this module

v2

v2.1.5

Jul 2, 2024

v2.1.4

Jun 25, 2024

Changes in this version

+ type MempoolInterface interface

+ Contains func(tx sdk.Tx) bool

type PriorityNonceMempool

+ func (mp *PriorityNonceMempool[C]) Contains(tx sdk.Tx) bool

v2.1.3

May 21, 2024

v2.1.2

Apr 23, 2024

v2.1.1

Feb 16, 2024

Changes in this version

+ func IsEmpty[C comparable](mempool sdkmempool.Mempool) error

+ type BaseLane struct

+ func NewBaseLane(cfg LaneConfig, laneName string, options ...LaneOption) (*BaseLane, error)

+ func (l *BaseLane) GetMaxBlockSpace() math.LegacyDec

+ func (l *BaseLane) GetTxInfo(ctx sdk.Context, tx sdk.Tx) (utils.TxWithInfo, error)

+ func (l *BaseLane) Logger() log.Logger

+ func (l *BaseLane) Match(ctx sdk.Context, tx sdk.Tx) bool

+ func (l *BaseLane) Name() string

+ func (l *BaseLane) PrepareLane(ctx sdk.Context, proposal proposals.Proposal, next block.PrepareLanesHandler) (proposals.Proposal, error)

+ func (l *BaseLane) ProcessLane(ctx sdk.Context, proposal proposals.Proposal, txs []sdk.Tx, ...) (proposals.Proposal, error)

+ func (l *BaseLane) TxDecoder() sdk.TxDecoder

+ func (l *BaseLane) TxEncoder() sdk.TxEncoder

+ func (l *BaseLane) ValidateBasic() error

+ func (l *BaseLane) VerifyNoMatches(ctx sdk.Context, txs []sdk.Tx) error

+ func (l *BaseLane) VerifyTx(ctx sdk.Context, tx sdk.Tx, simulate bool) error

+ func (l *BaseLane) WithOptions(options ...LaneOption) *BaseLane

+ type DefaultProposalHandler struct

+ func NewDefaultProposalHandler(lane *BaseLane) *DefaultProposalHandler

+ func (h *DefaultProposalHandler) PrepareLaneHandler() PrepareLaneHandler

+ func (h *DefaultProposalHandler) ProcessLaneHandler() ProcessLaneHandler

+ type LaneConfig struct

+ AnteHandler sdk.AnteHandler

+ Logger log.Logger

+ MaxBlockSpace math.LegacyDec

+ MaxTxs int

+ SignerExtractor signer_extraction.Adapter

+ TxDecoder sdk.TxDecoder

+ TxEncoder sdk.TxEncoder

+ func NewLaneConfig(logger log.Logger, txEncoder sdk.TxEncoder, txDecoder sdk.TxDecoder, ...) LaneConfig

+ func (c *LaneConfig) ValidateBasic() error

+ type LaneOption func(*BaseLane)

+ func WithAnteHandler(anteHandler sdk.AnteHandler) LaneOption

+ func WithMatchHandler(matchHandler MatchHandler) LaneOption

+ func WithMempool(mempool block.LaneMempool) LaneOption

+ func WithMempoolConfigs[C comparable](cfg LaneConfig, txPriority TxPriority[C]) LaneOption

+ func WithPrepareLaneHandler(prepareLaneHandler PrepareLaneHandler) LaneOption

+ func WithProcessLaneHandler(processLaneHandler ProcessLaneHandler) LaneOption

+ type MatchHandler func(ctx sdk.Context, tx sdk.Tx) bool

+ func DefaultMatchHandler() MatchHandler

+ func NewMatchHandler(mh MatchHandler, ignoreMHs ...MatchHandler) MatchHandler

+ type Mempool struct

+ func NewMempool[C comparable](txPriority TxPriority[C], txEncoder sdk.TxEncoder, ...) *Mempool[C]

+ func (cm *Mempool[C]) Compare(ctx sdk.Context, this sdk.Tx, other sdk.Tx) (int, error)

+ func (cm *Mempool[C]) Contains(tx sdk.Tx) bool

+ func (cm *Mempool[C]) CountTx() int

+ func (cm *Mempool[C]) Insert(ctx context.Context, tx sdk.Tx) error

+ func (cm *Mempool[C]) Priority(ctx sdk.Context, tx sdk.Tx) any

+ func (cm *Mempool[C]) Remove(tx sdk.Tx) error

+ func (cm *Mempool[C]) Select(ctx context.Context, txs [][]byte) sdkmempool.Iterator

+ type PrepareLaneHandler func(ctx sdk.Context, proposal proposals.Proposal, limit proposals.LaneLimits) (txsToInclude []sdk.Tx, txsToRemove []sdk.Tx, err error)

+ func NoOpPrepareLaneHandler() PrepareLaneHandler

+ func PanicPrepareLaneHandler() PrepareLaneHandler

+ type PriorityNonceIterator struct

+ func (i *PriorityNonceIterator[C]) Next() sdkmempool.Iterator

+ func (i *PriorityNonceIterator[C]) Tx() sdk.Tx

+ type PriorityNonceMempool struct

+ func DefaultPriorityMempool(extractor signer_extraction.DefaultAdapter) *PriorityNonceMempool[int64]

+ func NewPriorityMempool[C comparable](cfg PriorityNonceMempoolConfig[C], extractor signer_extraction.Adapter) *PriorityNonceMempool[C]

+ func (mp *PriorityNonceMempool[C]) CountTx() int

+ func (mp *PriorityNonceMempool[C]) Insert(ctx context.Context, tx sdk.Tx) error

+ func (mp *PriorityNonceMempool[C]) NextSenderTx(sender string) sdk.Tx

+ func (mp *PriorityNonceMempool[C]) Remove(tx sdk.Tx) error

+ func (mp *PriorityNonceMempool[C]) Select(_ context.Context, _ [][]byte) sdkmempool.Iterator

+ type PriorityNonceMempoolConfig struct

+ MaxTx int

+ OnRead func(tx sdk.Tx)

+ TxPriority TxPriority[C]

+ TxReplacement func(op, np C, oTx, nTx sdk.Tx) bool

+ func DefaultPriorityNonceMempoolConfig() PriorityNonceMempoolConfig[int64]

+ type ProcessLaneHandler func(ctx sdk.Context, partialProposal []sdk.Tx) (txsFromLane []sdk.Tx, remainingTxs []sdk.Tx, err error)

+ func NoOpProcessLaneHandler() ProcessLaneHandler

+ func PanicProcessLaneHandler() ProcessLaneHandler

+ type TxPriority struct

+ Compare func(a, b C) int

+ GetTxPriority func(ctx context.Context, tx sdk.Tx) C

+ MinValue C

+ func DefaultTxPriority() TxPriority[int]

+ func NewDefaultTxPriority() TxPriority[int64]

Other modules containing this package

github.com/skip-mev/block-sdk