worker

Documentation

Index

• func AddAcceptRecord(args *tokens.BuildTxArgs, swapTx string) (err error)
• func AddSwapJob(pairCfg *tokens.TokenPairConfig)
• func AddTokenPairDynamically()
• func CheckAcceptRecord(args *tokens.BuildTxArgs) (err error)
• func DeleteCachedSwap(isSwapin bool, txid, bind string)
• func FindAcceptRecords(args *tokens.BuildTxArgs) map[string]int64
• func ReplaceSwapin(txid, pairID, bind, gasPrice string) (string, error)
• func ReplaceSwapout(txid, pairID, bind, gasPrice string) (string, error)
• func StartAcceptSignJob()
• func StartAggregateJob()
• func StartPassBigValueJob()
• func StartReplaceJob()
• func StartScanJob(isServer bool)
• func StartStableJob()
• func StartSwapJob()
• func StartUpdateLatestBlockHeightJob()
• func StartVerifyJob()
• func StartWork(isServer bool)
• type MatchTx

Functions

func AddAcceptRecord

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

AddAcceptRecord add accept record

func AddSwapJob

func AddSwapJob(pairCfg *tokens.TokenPairConfig)

AddSwapJob add swap job

func AddTokenPairDynamically

func AddTokenPairDynamically()

AddTokenPairDynamically add token pair dynamically

func CheckAcceptRecord

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

CheckAcceptRecord check accept record

func DeleteCachedSwap

func DeleteCachedSwap(isSwapin bool, txid, bind string)

DeleteCachedSwap delete cached swap

func FindAcceptRecords

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

FindAcceptRecords find accept records

func ReplaceSwapin

func ReplaceSwapin(txid, pairID, bind, gasPrice string) (string, error)

ReplaceSwapin api

func ReplaceSwapout

func ReplaceSwapout(txid, pairID, bind, gasPrice string) (string, error)

ReplaceSwapout api

func StartAcceptSignJob

func StartAcceptSignJob()

StartAcceptSignJob accept job

func StartAggregateJob

func StartAggregateJob()

StartAggregateJob aggregate job

func StartPassBigValueJob

func StartPassBigValueJob()

StartPassBigValueJob pass big value job

func StartReplaceJob

func StartReplaceJob()

StartReplaceJob replace job

func StartScanJob

func StartScanJob(isServer bool)

StartScanJob scan job

func StartStableJob

func StartStableJob()

StartStableJob stable job

func StartSwapJob

func StartSwapJob()

StartSwapJob swap job

func StartUpdateLatestBlockHeightJob

func StartUpdateLatestBlockHeightJob()

StartUpdateLatestBlockHeightJob update latest block height job

func StartVerifyJob

func StartVerifyJob()

StartVerifyJob verify job

func StartWork

func StartWork(isServer bool)

StartWork start swap server work

Types

type MatchTx

type MatchTx struct {
	SwapTx     string
	SwapHeight uint64
	SwapTime   uint64
	SwapValue  string
	SwapType   tokens.SwapType
	SwapNonce  uint64
}

MatchTx struct