transactionpool

Sep 25, 2019

Changes in this version

+ type Service struct

+ func (s *Service) AddNewTransaction(ctx context.Context, input *services.AddNewTransactionInput) (*services.AddNewTransactionOutput, error)

+ func (s *Service) CommitTransactionReceipts(ctx context.Context, input *services.CommitTransactionReceiptsInput) (*services.CommitTransactionReceiptsOutput, error)

+ func (s *Service) GetCommittedTransactionReceipt(ctx context.Context, input *services.GetCommittedTransactionReceiptInput) (*services.GetCommittedTransactionReceiptOutput, error)

+ func (s *Service) GetTransactionsForOrdering(ctx context.Context, input *services.GetTransactionsForOrderingInput) (*services.GetTransactionsForOrderingOutput, error)

+ func (s *Service) HandleForwardedTransactions(ctx context.Context, input *gossiptopics.ForwardedTransactionsInput) (*gossiptopics.EmptyOutput, error)

+ func (s *Service) RegisterTransactionResultsHandler(handler handlers.TransactionResultsHandler)

+ func (s *Service) ValidateTransactionsForOrdering(ctx context.Context, input *services.ValidateTransactionsForOrderingInput) (*services.ValidateTransactionsForOrderingOutput, error)

Apr 11, 2019

Changes in this version

+ func NewRequestConcurrencyLimiter(maxConcurrentRequests int) *requestConcurrencyLimiter

type BlockHeightReporter

+ IncrementTo func(height primitives.BlockHeight)

Dec 20, 2018

Changes in this version

+ type BlockHeightReporter interface

+ IncrementHeight func()

type TransactionForwarderConfig

+ NodeAddress func() primitives.NodeAddress

Nov 26, 2018

Changes in this version

+ const ProtocolVersion

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

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

+ func NewCommittedPool(metricFactory metric.Factory) *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 ErrTransactionRejected struct

+ Actual *log.Field

+ Expected *log.Field

+ TransactionStatus protocol.TransactionStatus

+ func (e *ErrTransactionRejected) Error() string

+ type TransactionForwarderConfig interface

+ NodePrivateKey func() primitives.Ed25519PrivateKey

+ NodePublicKey func() primitives.Ed25519PublicKey

+ TransactionPoolPropagationBatchSize func() uint16

+ TransactionPoolPropagationBatchingTimeout func() time.Duration

+ type Transactions []*protocol.SignedTransaction

+ type TxId []byte