worker

package

v3.0.0-...-e8b7a4c Latest Latest Go to latest Published: Jul 24, 2023 License: GPL-3.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/deltaswapio/swaprouter

Links

Open Source Insights

Documentation ¶

Overview ¶

Package worker includes all the tasks and jobs to process router swaps.

It contains the following main steps (concurrently):

verify
	verify registered swaps.
swap
	build swaptx, mpc sign the tx, and send the tx to blockchain.
accept
	the `oracle` node do the accept job, agree or disagree the signing after verifying by oralce itself.
stable
	mark swap status to `stabe` status.
replace
	replace swap with the same tx nonce value when the sent swaptx is not packed into block because of lack fee or other reasons.
passbigvalue
	pass big value swap if the swap value is too large.

Most the above jobs is assigned to the `server` node, the `oracle` node mainly do the `accept` job.

Index ¶

func AddAcceptRecord(args *tokens.BuildTxArgs, swapTx string) (err error)
func AddInitialSwapResult(swapInfo *tokens.SwapTxInfo, status mongodb.SwapStatus) (err error)
func CheckAcceptRecord(args *tokens.BuildTxArgs) (err error)
func DeleteCachedSwap(fromChainID, txid string, logIndex int)
func DeleteCachedVerifyingSwap(key string)
func DoAggregateJob()
func FindAcceptRecords(args *tokens.BuildTxArgs) map[string]int64
func ReplaceRouterSwap(res *mongodb.MgoSwapResult, gasPrice *big.Int, isManual bool) error
func StartAcceptSignJob()
func StartAggregateJob()
func StartCheckFailedSwapJob()
func StartPassBigValueJob()
func StartReplaceJob()
func StartReportStatJob()
func StartReswapJob()
func StartRouterSwapWork(isServer bool)
func StartStableJob()
func StartSwapJob()
func StartVerifyJob()
type MatchTx

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddAcceptRecord ¶

func AddAcceptRecord(args *tokens.BuildTxArgs, swapTx string) (err error)

AddAcceptRecord add accept record

func AddInitialSwapResult ¶

func AddInitialSwapResult(swapInfo *tokens.SwapTxInfo, status mongodb.SwapStatus) (err error)

AddInitialSwapResult add initial result

func CheckAcceptRecord ¶

func CheckAcceptRecord(args *tokens.BuildTxArgs) (err error)

CheckAcceptRecord check accept record

func DeleteCachedSwap ¶

func DeleteCachedSwap(fromChainID, txid string, logIndex int)

DeleteCachedSwap delete cached swap

func DeleteCachedVerifyingSwap ¶

func DeleteCachedVerifyingSwap(key string)

DeleteCachedVerifyingSwap delete cached verifying swap

func DoAggregateJob ¶

func DoAggregateJob()

func FindAcceptRecords ¶

func FindAcceptRecords(args *tokens.BuildTxArgs) map[string]int64

FindAcceptRecords find accept records

func ReplaceRouterSwap ¶

func ReplaceRouterSwap(res *mongodb.MgoSwapResult, gasPrice *big.Int, isManual bool) error

ReplaceRouterSwap api

func StartAcceptSignJob ¶

func StartAcceptSignJob()

StartAcceptSignJob accept job

func StartAggregateJob ¶

func StartAggregateJob()

StartAggregateJob aggregate job

func StartCheckFailedSwapJob ¶

func StartCheckFailedSwapJob()

StartCheckFailedSwapJob check failed swap job

func StartPassBigValueJob ¶

func StartPassBigValueJob()

StartPassBigValueJob pass big value job

func StartReplaceJob ¶

func StartReplaceJob()

StartReplaceJob replace job

func StartReportStatJob ¶

func StartReportStatJob()

StartReportStatJob report stat job

func StartReswapJob ¶

func StartReswapJob()

StartreswapJob reswap job

func StartRouterSwapWork ¶

func StartRouterSwapWork(isServer bool)

StartRouterSwapWork start router swap job

func StartStableJob ¶

func StartStableJob()

StartStableJob stable job

func StartSwapJob ¶

func StartSwapJob()

StartSwapJob swap job

func StartVerifyJob ¶

func StartVerifyJob()

StartVerifyJob verify job

Types ¶

type MatchTx ¶

type MatchTx struct {
	MPC        string
	SwapTx     string
	SwapHeight uint64
	SwapTime   uint64
	SwapValue  string
	SwapNonce  uint64
	TTL        uint64
}

MatchTx struct

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL