The highest tagged major version is v3.

normal

package module

v2.3.3 Latest Latest Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

git.chainmaker.org.cn/chainmaker/txpool-normal

Links

Open Source Insights

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 ¶

View Source

const TxPoolType = "NORMAL"

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 ¶

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 ¶ added in v2.3.2

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

LogHelper Auxiliary printing

Source Files ¶

View all Source files

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