cooperativewithdraw

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2026 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Callback 

type Callback interface {
	OnWithdraw(withdrawHash string, txHash string)
	OnError(withdrawHash string, err string)
}

type Processor 

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

func StartProcessor 

func StartProcessor(
	nodeConfig common.GlobalNodeConfig,
	selfAddress ctype.Addr,
	signer eth.Signer,
	transactorPool *eth.TransactorPool,
	connectionManager *rpc.ConnectionManager,
	monitorService intfs.MonitorService,
	dal *storage.DAL,
	streamWriter common.StreamWriter,
	keepMonitor bool,
	enableJobs bool) (*Processor, error)

func (*Processor) CooperativeWithdraw 

func (p *Processor) CooperativeWithdraw(cid ctype.CidType, amount *big.Int, cb Callback) (string, error)

func (*Processor) MonitorCooperativeWithdrawJob 

func (p *Processor) MonitorCooperativeWithdrawJob(withdrawHash string, cb Callback)

func (*Processor) ProcessRequest 

func (p *Processor) ProcessRequest(frame *common.MsgFrame) error

func (*Processor) ProcessResponse 

func (p *Processor) ProcessResponse(frame *common.MsgFrame) error

func (*Processor) RemoveCooperativeWithdrawJob 

func (p *Processor) RemoveCooperativeWithdrawJob(withdrawHash string)

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.