Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

task

package

Go to main page

Versions in this module

v0

v0.2.7

Nov 27, 2023

v0.2.6

Oct 11, 2023

Changes in this version

+ const BridgeManagerContractType

v0.2.5

May 29, 2023

v0.2.4

Apr 5, 2023

v0.2.3

Mar 27, 2023

v0.2.2

Mar 9, 2023

Changes in this version

+ const ACK_WITHDREW_TASK

+ const BRIDGEADMIN_CONTRACT

+ const DEPOSIT_TASK

+ const ETH_GATEWAY_CONTRACT

+ const ETH_GOVERNANCE_CONTRACT

+ const ErrNotBridgeOperator

+ const ErrOperatorsAlreadyVoted

+ const ErrOutdatedPeriod

+ const ErrSigAlreadySubmitted

+ const EthereumChainId

+ const GATEWAY_CONTRACT

+ const GOVERNANCE_CONTRACT

+ const RELAY_BRIDGE_OPERATORS_TASK

+ const RoninChainId

+ const STATUS_DONE

+ const STATUS_FAILED

+ const STATUS_PENDING

+ const STATUS_PROCESSING

+ const TRUSTED_ORGANIZATION_CONTRACT

+ const VOTE_BRIDGE_OPERATORS_TASK

+ const VoteStatusApproved

+ const VoteStatusExecuted

+ const VoteStatusPending

+ const WITHDRAWAL_TASK

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

+ type BridgeOperatorsSorter []common.Address

+ func (b BridgeOperatorsSorter) Len() int

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

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

+ type MockListener struct

+ func (m MockListener) AddListeners(m2 map[string]bridgeCore.Listener)

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

+ func (m MockListener) Close()

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

+ func (m MockListener) Context() context.Context

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

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

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

+ func (m MockListener) GetCurrentBlock() bridgeCore.Block

+ func (m MockListener) GetEthClient() utils.EthClient

+ func (m MockListener) GetInitHeight() uint64

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

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

+ func (m MockListener) GetListenHandleJob(subscriptionName string, tx bridgeCore.Transaction, eventId string, ...) bridgeCore.JobHandler

+ func (m MockListener) GetListener(s string) bridgeCore.Listener

+ func (m MockListener) GetName() string

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

+ func (m MockListener) GetRelayerSign() utils.ISign

+ func (m MockListener) GetSafeBlockRange() uint64

+ func (m MockListener) GetStore() bridgeCoreStore.MainStore

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

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

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

+ func (m MockListener) GetValidatorSign() utils.ISign

+ func (m MockListener) GetVoterSign() bridgeCoreUtils.ISign

+ func (m MockListener) IsDisabled() bool

+ func (m MockListener) IsUpTodate() bool

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

+ func (m MockListener) Period() time.Duration

+ func (m MockListener) SaveCurrentBlockToDB() error

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

+ func (m MockListener) SendCallbackJobs(listeners map[string]bridgeCore.Listener, subscriptionName string, ...)

+ func (m MockListener) SetInitHeight(u uint64)

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

+ func (m MockListener) Start()

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

+ type MockRoninTask struct

+ func (m MockRoninTask) Close()

+ func (m MockRoninTask) GetListener() bridgeCore.Listener

+ func (m MockRoninTask) SetLimitQuery(limit int)

+ func (m MockRoninTask) Start()

+ type RoninTask struct

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

+ func (r *RoninTask) Close()

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

+ func (r *RoninTask) SetLimitQuery(limit int)

+ func (r *RoninTask) Start()

+ type Tasker interface