The highest tagged major version is v3.

single

package module

v2.4.0 Latest Latest Go to latest Published: May 28, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
func IsDumpTxsInQueue() bool
func IsMessageTurbo(chainConf protocol.ChainConf) bool
func IsMetrics() bool
func IsTxTimeVerify(chainConf protocol.ChainConf) bool
func MaxCommonTxPoolSize() int
func MaxConfigTxPoolSize() int
func MaxTxCount(chainConf protocol.ChainConf) int
func MaxTxTimeTimeout(chainConf protocol.ChainConf) float64
func NewTxPoolImpl(nodeId string, chainId string, txFilter protocol.TxFilter, ...) (protocol.TxPool, error)
func QueryUpperLimit() int
type ReBroadcastConfig
type TxPoolReBroadcast
- func NewTxPoolReBroadcast(reBroadcastConfig ReBroadcastConfig, netService protocol.NetService) *TxPoolReBroadcast

Constants ¶

View Source

const TxPoolType = "SINGLE"

TxPoolType is tx_pool type

Variables ¶

View Source

var (
	// TxPoolConfig is tx_pool global configuration
	TxPoolConfig *txPoolConfig
	// MonitorEnabled indicates whether monitoring is enabled
	MonitorEnabled bool
)

Functions ¶

func IsDumpTxsInQueue ¶ added in v2.3.0

func IsDumpTxsInQueue() bool

IsDumpTxsInQueue Whether to dump config and common transaction in queue

func IsMessageTurbo ¶ added in v2.3.0

func IsMessageTurbo(chainConf protocol.ChainConf) bool

IsMessageTurbo Whether block clipping

func IsMetrics ¶

func IsMetrics() bool

IsMetrics Whether to log operation time

func IsTxTimeVerify ¶

func IsTxTimeVerify(chainConf protocol.ChainConf) bool

IsTxTimeVerify Whether transactions require validation

func MaxCommonTxPoolSize ¶

func MaxCommonTxPoolSize() int

MaxCommonTxPoolSize Maximum number of common transaction in the pool

func MaxConfigTxPoolSize ¶

func MaxConfigTxPoolSize() int

MaxConfigTxPoolSize The maximum number of configure transaction in the pool

func MaxTxCount ¶

func MaxTxCount(chainConf protocol.ChainConf) int

MaxTxCount Maximum number of transactions in a block

func MaxTxTimeTimeout ¶

func MaxTxTimeTimeout(chainConf protocol.ChainConf) float64

MaxTxTimeTimeout The maximum timeout for a transaction

func NewTxPoolImpl ¶

func NewTxPoolImpl(
	nodeId string,
	chainId string,
	txFilter protocol.TxFilter,
	chainStore protocol.BlockchainStore,
	msgBus msgbus.MessageBus,
	chainConf protocol.ChainConf,
	singer protocol.SigningMember,
	ac protocol.AccessControlProvider,
	netService protocol.NetService,
	log protocol.Logger,
	monitorEnabled bool,
	poolConfig map[string]interface{}) (protocol.TxPool, error)

NewTxPoolImpl create single tx pool txPoolImpl

func QueryUpperLimit ¶ added in v2.3.0

func QueryUpperLimit() int

QueryUpperLimit Maximum number of querying transaction in the pool

Types ¶

type ReBroadcastConfig ¶ added in v2.4.0

type ReBroadcastConfig struct {
	// TxPoolSyncEnable enable tx pool sync or not for common node
	TxPoolSyncEnable bool `mapstructure:"tx_pool_sync_enable"`
	// TxPoolStatusTick trigger tick of sync tx pool
	TxPoolStatusTick float64 `mapstructure:"tx_pool_status_tick"`
	// TxPoolSyncProportion trigger proportion of sync tx pool
	TxPoolSyncProportion float64 `mapstructure:"tx_pool_sync_proportion"`
}

ReBroadcastConfig common node tx pool secondary broadcast to prevent stranded txs in common tx pool

type TxPoolReBroadcast ¶ added in v2.4.0

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

TxPoolReBroadcast inner config

func NewTxPoolReBroadcast ¶ added in v2.4.0

func NewTxPoolReBroadcast(reBroadcastConfig ReBroadcastConfig,
	netService protocol.NetService) *TxPoolReBroadcast

NewTxPoolReBroadcast new rebroadcast struct

Source Files ¶

mocks.go
pool_config.go
tx_cache.go
tx_list.go
tx_pool_impl.go
tx_pool_rebroadcast.go
tx_queue.go
tx_recover.go
tx_validator.go
types.go
utils.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL