deth_worker

Documentation

Index

• func AddSharesToMap(sharesMap map[uint64]*pb.ShareMap, chainId uint64, ...)
• func GetTotalShares(sharesMap map[uint64]*pb.ShareMap) *big.Int
• type WorkerProcessor
  • func NewWorkerProcessor(db *database.DB, bridgeRpcService bridge.BridgeRpcService, ...) (*WorkerProcessor, error)
  • func (b *WorkerProcessor) TranserL2Shares() error
  • func (b *WorkerProcessor) TransferL2Shares(fromAddress, toAddress common.Address, shares *big.Int, ...) error
  • func (b *WorkerProcessor) WorkerStart() error

Functions

func AddSharesToMap

func AddSharesToMap(sharesMap map[uint64]*pb.ShareMap, chainId uint64, strategyAddress common.Address, shares *big.Int)

func GetTotalShares

func GetTotalShares(sharesMap map[uint64]*pb.ShareMap) *big.Int

Types

type WorkerProcessor

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

func NewWorkerProcessor

func NewWorkerProcessor(db *database.DB, bridgeRpcService bridge.BridgeRpcService, shutdown context.CancelCauseFunc) (*WorkerProcessor, error)

func (*WorkerProcessor) TranserL2Shares

func (b *WorkerProcessor) TranserL2Shares() error

func (*WorkerProcessor) TransferL2Shares

func (b *WorkerProcessor) TransferL2Shares(fromAddress, toAddress common.Address,
	shares *big.Int, stakeMessageNonce uint64, txHash common.Hash) error

func (*WorkerProcessor) WorkerStart

func (b *WorkerProcessor) WorkerStart() error