task

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ACK_WITHDREW_TASK     = "acknowledgeWithdrew"
	DEPOSIT_TASK          = "deposit"
	WITHDRAWAL_TASK       = "withdrawal"
	WITHDRAWAL_AGAIN_TASK = "withdrawAgain"

	STATUS_PENDING    = "pending"
	STATUS_FAILED     = "failed"
	STATUS_PROCESSING = "processing"
	STATUS_DONE       = "done"

	GATEWAY_CONTRACT              = "Gateway"
	GOVERNANCE_CONTRACT           = "Governance"
	TRUSTED_ORGANIZATION_CONTRACT = "TrustedOrganization"
	ETH_GOVERNANCE_CONTRACT       = "EthGovernance"
	ETH_GATEWAY_CONTRACT          = "EthGateway"
	BRIDGEADMIN_CONTRACT          = "BridgeAdmin"

	CROSSBELL_GATEWAY_CONTRACT = "CrossbellGateway"
	CROSSBELL_VALIDATOR        = "CrossbellValidator"
	MAINCHAIN_GATEWAY_CONTRACT = "MainchainGateway"
	MAINCHAIN_VALIDATOR        = "MainchainValidator"
)
View Source 
const (
	Salt                   = "0xe3922a0bff7e80c6f7465bc1b150f6c95d9b9203f1731a09f86e759ea1eaa306"
	ErrSigAlreadySubmitted = "execution reverted: BOsGovernanceRelay: query for outdated period"
	ErrOutdatedPeriod      = "execution reverted: BOsGovernanceProposal: query for outdated period"
)
View Source 
const (
	RoninChainId    = "0x539"
	EthereumChainId = "0x5"
)
View Source 
const (
	ErrNotBridgeOperator = "execution reverted: RoninGatewayV2: unauthorized sender"
)

Variables

This section is empty.

Functions

func EqualOperatorSet 

func EqualOperatorSet(a, b []common.Address) bool

Types

type BridgeOperatorsSorter 

type BridgeOperatorsSorter []common.Address

func (BridgeOperatorsSorter) Len 

func (b BridgeOperatorsSorter) Len() int

func (BridgeOperatorsSorter) Less 

func (b BridgeOperatorsSorter) Less(i, j int) bool

func (BridgeOperatorsSorter) Swap 

func (b BridgeOperatorsSorter) Swap(i, j int)

type MockListener 

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

func (MockListener) AddTask 

func (m MockListener) AddTask(handler bridgeCore.TaskHandler)

func (MockListener) Close 

func (m MockListener) Close()

func (MockListener) Config 

func (m MockListener) Config() *bridgeCore.LsConfig

func (MockListener) Context 

func (m MockListener) Context() context.Context

func (MockListener) GetBlock 

func (m MockListener) GetBlock(height uint64) (bridgeCore.Block, error)

func (MockListener) GetBlockWithLogs 

func (m MockListener) GetBlockWithLogs(height uint64) (bridgeCore.Block, error)

func (MockListener) GetChainID 

func (m MockListener) GetChainID() (*big.Int, error)

func (MockListener) GetCurrentBlock 

func (m MockListener) GetCurrentBlock() bridgeCore.Block

func (MockListener) GetEthClient 

func (m MockListener) GetEthClient() utils.EthClient

func (MockListener) GetInitHeight 

func (m MockListener) GetInitHeight() uint64

func (MockListener) GetLatestBlock 

func (m MockListener) GetLatestBlock() (bridgeCore.Block, error)

func (MockListener) GetLatestBlockHeight 

func (m MockListener) GetLatestBlockHeight() (uint64, error)

func (MockListener) GetListenHandleJob 

func (m MockListener) GetListenHandleJob(subscriptionName string, tx bridgeCore.Transaction, eventId string, data []byte) bridgeCore.JobHandler

func (MockListener) GetName 

func (m MockListener) GetName() string

func (MockListener) GetReceipt 

func (m MockListener) GetReceipt(hash common.Hash) (*ethtypes.Receipt, error)

func (MockListener) GetRelayerSign 

func (m MockListener) GetRelayerSign() utils.ISign

func (MockListener) GetSafeBlockRange 

func (m MockListener) GetSafeBlockRange() uint64

func (MockListener) GetStore 

func (m MockListener) GetStore() bridgeCoreStore.MainStore

func (MockListener) GetSubscriptions 

func (m MockListener) GetSubscriptions() map[string]*bridgeCore.Subscribe

func (MockListener) GetTask 

func (m MockListener) GetTask(index int) bridgeCore.TaskHandler

func (MockListener) GetTasks 

func (m MockListener) GetTasks() []bridgeCore.TaskHandler

func (MockListener) GetValidatorSign 

func (m MockListener) GetValidatorSign() utils.ISign

func (MockListener) IsDisabled 

func (m MockListener) IsDisabled() bool

func (MockListener) IsUpTodate 

func (m MockListener) IsUpTodate() bool

func (MockListener) NewJobFromDB 

func (m MockListener) NewJobFromDB(job *bridgeCoreModels.Job) (bridgeCore.JobHandler, error)

func (MockListener) Period 

func (m MockListener) Period() time.Duration

func (MockListener) SaveCurrentBlockToDB 

func (m MockListener) SaveCurrentBlockToDB() error

func (MockListener) SaveTransactionsToDB 

func (m MockListener) SaveTransactionsToDB(txs []bridgeCore.Transaction) error

func (MockListener) SendCallbackJobs 

func (m MockListener) SendCallbackJobs(listeners map[string]bridgeCore.Listener, subscriptionName string, tx bridgeCore.Transaction, inputData []byte)

func (MockListener) SetInitHeight 

func (m MockListener) SetInitHeight(u uint64)

func (MockListener) SetPrepareJobChan 

func (m MockListener) SetPrepareJobChan(handlers chan bridgeCore.JobHandler)

func (MockListener) Start 

func (m MockListener) Start()

func (MockListener) UpdateCurrentBlock 

func (m MockListener) UpdateCurrentBlock(block bridgeCore.Block) error

type MockRoninTask 

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

func (MockRoninTask) Close 

func (m MockRoninTask) Close()

func (MockRoninTask) GetListener 

func (m MockRoninTask) GetListener() bridgeCore.Listener

func (MockRoninTask) SetLimitQuery 

func (m MockRoninTask) SetLimitQuery(limit int)

func (MockRoninTask) Start 

func (m MockRoninTask) Start()

type RoninTask 

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

func NewRoninTask 

func NewRoninTask(listener bridgeCore.Listener, db *gorm.DB, util utils.Utils) (*RoninTask, error)

func (*RoninTask) Close 

func (r *RoninTask) Close()

func (*RoninTask) GetListener 

func (r *RoninTask) GetListener() bridgeCore.Listener

func (*RoninTask) SetLimitQuery 

func (r *RoninTask) SetLimitQuery(limit int)

func (*RoninTask) Start 

func (r *RoninTask) Start()

type Tasker 

type Tasker interface {
	// contains filtered or unexported methods
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.