txpool

Documentation

Index

• Constants
• Variables
• func NewTxPool[T any, Constraint types.TXConstraint[T]](config Config) (txpool.TxPool[T, Constraint], error)
• type Config
  • func NewMockTxPoolConfig() Config
• type GetAccountNonceFunc
• type PoolStatusMgr
  • func (st *PoolStatusMgr) In(pos statusType) bool
  • func (st *PoolStatusMgr) InOne(poss ...statusType) bool
  • func (st *PoolStatusMgr) Off(status ...statusType)
  • func (st *PoolStatusMgr) On(statusPos ...statusType)
  • func (st *PoolStatusMgr) Reset()

Constants

const (
	Ordered = iota
	SortNonce
	Remove
	Rebroadcast
)

const (
	ReadyGenerateBatch statusType = iota
	HasPendingRequest
	PoolFull
	PoolEmpty
)

const (
	DefaultPoolSize              = 50000
	DefaultBatchSize             = 500
	DefaultToleranceNonceGap     = 1000
	DefaultToleranceTime         = 5 * time.Minute
	DefaultToleranceRemoveTime   = 15 * time.Minute
	DefaultCleanEmptyAccountTime = 10 * time.Minute
)

nolint

const (
	SendMissingTxsEvent = iota
	FilterReBroadcastTxsEvent
	RestoreOneBatchEvent
	RestoreAllBatchedEvent
)

=======================consensusEvent=============================

const (
	DefaultTestBatchSize = uint64(4)
)

nolint

Variables

var (
	ErrTxPoolFull   = errors.New("tx pool full")
	ErrNonceTooLow  = errors.New("nonce too low")
	ErrNonceTooHigh = errors.New("nonce too high")
	ErrDuplicateTx  = errors.New("duplicate tx")
)

Functions

func NewTxPool

func NewTxPool[T any, Constraint types.TXConstraint[T]](config Config) (txpool.TxPool[T, Constraint], error)

Types

type Config

type Config struct {
	Logger                logrus.FieldLogger
	BatchSize             uint64
	PoolSize              uint64
	BatchMemLimit         bool
	BatchMaxMem           uint64
	IsTimed               bool
	ToleranceNonceGap     uint64
	ToleranceTime         time.Duration
	ToleranceRemoveTime   time.Duration
	CleanEmptyAccountTime time.Duration
	GetAccountNonce       GetAccountNonceFunc
}

Config defines the txpool config items.

func NewMockTxPoolConfig

func NewMockTxPoolConfig() Config

NewMockTxPoolConfig returns the default test config

type GetAccountNonceFunc

type GetAccountNonceFunc func(address string) uint64

type PoolStatusMgr

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

func (*PoolStatusMgr) In

func (st *PoolStatusMgr) In(pos statusType) bool

In returns the atomic status of specified position.

func (*PoolStatusMgr) InOne

func (st *PoolStatusMgr) InOne(poss ...statusType) bool

func (*PoolStatusMgr) Off

func (st *PoolStatusMgr) Off(status ...statusType)

turn off a status

func (*PoolStatusMgr) On

func (st *PoolStatusMgr) On(statusPos ...statusType)

turn on a status

func (*PoolStatusMgr) Reset

func (st *PoolStatusMgr) Reset()