transactionpool

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 NewRequestConcurrencyLimiter(maxConcurrentRequests int) *requestConcurrencyLimiter
• func NewTransactionForwarder(ctx context.Context, logger log.Logger, signer signer.Signer, ...) *transactionForwarder
• type BlockHeightReporter
• type ErrTransactionRejected
  • func (e *ErrTransactionRejected) Error() string
• type Service
  • func NewTransactionPool(ctx context.Context, maybeClock adapter.Clock, ...) *Service
  • 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)
• type TransactionForwarderConfig
• type Transactions
• type TxId

Constants

const ProtocolVersion = primitives.ProtocolVersion(1)

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

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 Service

type Service struct {
	govnr.TreeSupervisor
	// contains filtered or unexported fields
}

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

func (*Service) AddNewTransaction

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

func (*Service) CommitTransactionReceipts

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

func (*Service) GetCommittedTransactionReceipt

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

func (*Service) GetTransactionsForOrdering

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

func (*Service) HandleForwardedTransactions

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

func (*Service) RegisterTransactionResultsHandler

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

func (*Service) ValidateTransactionsForOrdering

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

type TransactionForwarderConfig

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

type Transactions

type Transactions []*protocol.SignedTransaction

type TxId

type TxId []byte