transactionpool

Documentation

Index

• Variables
• func HashTransactions(txs ...*protocol.SignedTransaction) (oneBigHash []byte, hashes []primitives.Sha256, err error)
• func NewCommittedPool(transactionPoolFutureTimestampGraceTimeout func() time.Duration, ...) *committedTxPool
• func NewPendingPool(pendingPoolSizeInBytes func() uint32, metricFactory metric.Factory, ...) *pendingTxPool
• func NewRequestConcurrencyLimiter(maxConcurrentRequests int) *requestConcurrencyLimiter
• func NewTransactionForwarder(ctx context.Context, logger log.Logger, signer signer.Signer, ...) *transactionForwarder
• func NewTransactionPool(ctx context.Context, maybeClock adapter.Clock, ...) *service
• type BlockHeightReporter
• type ErrTransactionRejected
  • func (e *ErrTransactionRejected) Error() string
• type TransactionForwarderConfig
• type Transactions
• type TxId

Variables

var LogTag = log.Service("transaction-pool")

Functions

func HashTransactions

func HashTransactions(txs ...*protocol.SignedTransaction) (oneBigHash []byte, hashes []primitives.Sha256, err error)

func NewCommittedPool

func NewCommittedPool(transactionPoolFutureTimestampGraceTimeout func() time.Duration, metricFactory metric.Factory) *committedTxPool

func NewPendingPool

func NewPendingPool(pendingPoolSizeInBytes func() uint32, metricFactory metric.Factory, onNewTransaction func()) *pendingTxPool

func NewRequestConcurrencyLimiter

func NewRequestConcurrencyLimiter(maxConcurrentRequests int) *requestConcurrencyLimiter

func NewTransactionForwarder

func NewTransactionForwarder(ctx context.Context, logger log.Logger, signer signer.Signer, config TransactionForwarderConfig, gossip gossiptopics.TransactionRelay) *transactionForwarder

func NewTransactionPool

func NewTransactionPool(ctx context.Context,
	maybeClock adapter.Clock,
	gossip gossiptopics.TransactionRelay,
	virtualMachine services.VirtualMachine,
	signer signer.Signer,
	blockHeightReporter BlockHeightReporter,
	config config.TransactionPoolConfig,
	parent log.Logger,
	metricFactory metric.Factory) *service

Types

type BlockHeightReporter

type BlockHeightReporter interface {
	IncrementTo(height primitives.BlockHeight)
}

type ErrTransactionRejected

type ErrTransactionRejected struct {
	TransactionStatus protocol.TransactionStatus
	Expected          *log.Field
	Actual            *log.Field
}

func (*ErrTransactionRejected) Error

func (e *ErrTransactionRejected) Error() string

type TransactionForwarderConfig

type TransactionForwarderConfig interface {
	NodeAddress() primitives.NodeAddress
	TransactionPoolPropagationBatchSize() uint16
	TransactionPoolPropagationBatchingTimeout() time.Duration
}

type Transactions

type Transactions []*protocol.SignedTransaction

type TxId

type TxId []byte