Documentation ¶
Index ¶
- Constants
- 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 NewTransactionForwarder(ctx context.Context, logger log.BasicLogger, config TransactionForwarderConfig, ...) *transactionForwarder
- func NewTransactionPool(ctx context.Context, gossip gossiptopics.TransactionRelay, ...) services.TransactionPool
- type BlockHeightReporter
- type ErrTransactionRejected
- type TransactionForwarderConfig
- type Transactions
- type TxId
Constants ¶
View Source
const ProtocolVersion = primitives.ProtocolVersion(1)
Variables ¶
View Source
var LogTag = log.Service("transaction-pool")
Functions ¶
func HashTransactions ¶
func HashTransactions(txs ...*protocol.SignedTransaction) (oneBigHash []byte, hashes []primitives.Sha256, err error)
func NewCommittedPool ¶
func NewPendingPool ¶
func NewTransactionForwarder ¶
func NewTransactionForwarder(ctx context.Context, logger log.BasicLogger, config TransactionForwarderConfig, gossip gossiptopics.TransactionRelay) *transactionForwarder
func NewTransactionPool ¶
func NewTransactionPool(ctx context.Context, gossip gossiptopics.TransactionRelay, virtualMachine services.VirtualMachine, blockHeightReporter BlockHeightReporter, config config.TransactionPoolConfig, parent log.BasicLogger, metricFactory metric.Factory) services.TransactionPool
Types ¶
type BlockHeightReporter ¶ added in v0.7.1
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 NodePrivateKey() primitives.EcdsaSecp256K1PrivateKey TransactionPoolPropagationBatchSize() uint16 TransactionPoolPropagationBatchingTimeout() time.Duration }
type Transactions ¶
type Transactions []*protocol.SignedTransaction
Source Files ¶
- add_new_transaction.go
- cleanup.go
- commit_transaction_receipts.go
- committed_pool.go
- errors.go
- forward_transactions.go
- get_committed_transaction_result.go
- get_transactions_for_ordering.go
- init.go
- pending_pool.go
- service.go
- transaction_waiter.go
- types.go
- validate_transaction.go
- validate_transactions_for_ordering.go
Click to show internal directories.
Click to hide internal directories.