txsubmitchecker

Documentation

Index

• Constants
• type TxSubmitChecker
  • func NewTxSubmitChecker(inQueue <-chan relay.PendingSubmittedTxInfo, storage relay.Storage, ...) *TxSubmitChecker
  • func (tc *TxSubmitChecker) Run(ctx context.Context) error

Constants

const TxCheckerNumWorkers = 4 // XXX: maybe this value should be configurable by user?

Types

type TxSubmitChecker

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

func NewTxSubmitChecker

func NewTxSubmitChecker(
	inQueue <-chan relay.PendingSubmittedTxInfo,
	storage relay.Storage,
	rpcClient rpcclient.Client,
	logger *zap.Logger,
	checkSubmittedTxStatusDelay uint64,
) *TxSubmitChecker

func (*TxSubmitChecker) Run

func (tc *TxSubmitChecker) Run(ctx context.Context) error