svc

Documentation

Index

• type ExecutorService
  • func NewExecutorService(db *dal.DB, sgnClient *sgn.SgnClient, chains *chains.Chains, ...) *ExecutorService
  • func (s *ExecutorService) QueryExecutionRecord(query *dal.ExecutionRecordQuery) (*models.ExecutionRecord, error)
  • func (s *ExecutorService) QueryExecutionRecords(query *dal.ExecutionRecordsQuery) ([]*models.ExecutionRecord, error)
  • func (s *ExecutorService) QueryMessage(messageId string) (record *models.ExecutionRecord, msg *msgtypes.Message, err error)
  • func (s *ExecutorService) RevertToLastExecutableStatus(query *dal.ExecutionRecordQuery) error
  • func (s *ExecutorService) RevertToLastExecutableStatusBySrcTx(srcTx string) error
  • func (s *ExecutorService) UnstuckTxAndRevertStatus(query *dal.ExecutionRecordQuery, accountID string, gasOpts *GasPriceOptions, ...) (eth.Hash, error)
  • func (s *ExecutorService) UnstuckTxAndRevertStatusBySrcTx(srcTxHash string, accountID string, gasOpts *GasPriceOptions, wait bool) (eth.Hash, error)
• type GasPriceOptions

Types

type ExecutorService

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

func NewExecutorService

func NewExecutorService(db *dal.DB, sgnClient *sgn.SgnClient, chains *chains.Chains, accs *accounts.Accounts) *ExecutorService

func (*ExecutorService) QueryExecutionRecord

func (s *ExecutorService) QueryExecutionRecord(query *dal.ExecutionRecordQuery) (*models.ExecutionRecord, error)

func (*ExecutorService) QueryExecutionRecords

func (s *ExecutorService) QueryExecutionRecords(query *dal.ExecutionRecordsQuery) ([]*models.ExecutionRecord, error)

func (*ExecutorService) QueryMessage

func (s *ExecutorService) QueryMessage(messageId string) (record *models.ExecutionRecord, msg *msgtypes.Message, err error)

func (*ExecutorService) RevertToLastExecutableStatus

func (s *ExecutorService) RevertToLastExecutableStatus(query *dal.ExecutionRecordQuery) error

func (*ExecutorService) RevertToLastExecutableStatusBySrcTx

func (s *ExecutorService) RevertToLastExecutableStatusBySrcTx(srcTx string) error

func (*ExecutorService) UnstuckTxAndRevertStatus

func (s *ExecutorService) UnstuckTxAndRevertStatus(
	query *dal.ExecutionRecordQuery, accountID string, gasOpts *GasPriceOptions, wait bool) (eth.Hash, error)

func (*ExecutorService) UnstuckTxAndRevertStatusBySrcTx

func (s *ExecutorService) UnstuckTxAndRevertStatusBySrcTx(
	srcTxHash string, accountID string, gasOpts *GasPriceOptions, wait bool) (eth.Hash, error)

type GasPriceOptions

type GasPriceOptions struct {
	// legacy
	GasPrice *big.Int
	// eip1559
	GasTipCap *big.Int
	GasFeeCap *big.Int
}