txprocessor

Documentation

Index

• type TXProcessor
  • func NewTxProcessor(trustedHeaderFetcher relay.TrustedHeaderFetcher, storage relay.Storage, ...) TXProcessor
  • func (r TXProcessor) ProcessAndSubmit(ctx context.Context, queryID uint64, tx relay.Transaction, ...) error

Types

type TXProcessor

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

func NewTxProcessor

func NewTxProcessor(
	trustedHeaderFetcher relay.TrustedHeaderFetcher,
	storage relay.Storage,
	submitter relay.Submitter,
	logger *zap.Logger,
	checkSubmittedTxStatusDelay time.Duration,
	ignoreErrorsRegexp string,
) TXProcessor

func (TXProcessor) ProcessAndSubmit

func (r TXProcessor) ProcessAndSubmit(
	ctx context.Context,
	queryID uint64,
	tx relay.Transaction,
	submittedTxsTasksQueue chan relay.PendingSubmittedTxInfo,
) error