txsubmitchecker

Documentation

Index

• type TxSubmitChecker
  • func NewTxSubmitChecker(storage relay.Storage, rpcClient rpcclient.Client, logger *zap.Logger) *TxSubmitChecker
  • func (tc *TxSubmitChecker) Run(ctx context.Context, ...) error

Types

type TxSubmitChecker

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

func NewTxSubmitChecker

func NewTxSubmitChecker(
	storage relay.Storage,
	rpcClient rpcclient.Client,
	logger *zap.Logger,
) *TxSubmitChecker

func (*TxSubmitChecker) Run

func (tc *TxSubmitChecker) Run(ctx context.Context, submittedTxsTasksQueue <-chan relay.PendingSubmittedTxInfo) error