normal

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 NewNormalPool(nodeId string, chainId string, txFilter protocol.TxFilter, ...) (protocol.TxPool, error)
• func QueryUpperLimit() int
• type Dispatcher
• type LogHelper

Constants

const TxPoolType = "NORMAL"

TxPoolType is tx_pool type

Variables

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

Functions

func IsDumpTxsInQueue

func IsDumpTxsInQueue() bool

IsDumpTxsInQueue Whether to dump config and common transaction in queue

func IsMessageTurbo

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 transaction timestamp is verified

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 return maximum timeout for a transaction

func NewNormalPool

func NewNormalPool(
	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)

NewNormalPool create normal tx pool normalPool

func QueryUpperLimit

func QueryUpperLimit() int

QueryUpperLimit Maximum number of querying transaction in the pool

Types

type Dispatcher

type Dispatcher interface {
	// DistTx distribute a tx to a specific common queues
	DistTx(txId string, queueNum int) int
	// DistTxs distribute txs to different common queues
	DistTxs(txs []*commonPb.Transaction, queueNum int) (txsTable [][]*commonPb.Transaction)
	// DistTxsToMemTxs distribute txs to different common queues and generate mtxsTable
	DistTxsToMemTxs(txs []*commonPb.Transaction, queueNum int, height uint64) (mtxsTable [][]*memTx)
	// DistTxIds distribute txIds to different common queues
	DistTxIds(txIds []string, queueNum int) (txIdsTable [][]string)
}

Dispatcher is used to distribute transaction to different common queues

type LogHelper

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

LogHelper Auxiliary printing