job

package
v0.0.0-...-9f09256 Latest Latest
Warning

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

Go to latest
Published: Feb 8, 2023 License: GPL-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DebugJobChan workpool.Dispathcher
	TxJobChan    workpool.Dispathcher
)

Functions

func GlobalInit

func GlobalInit(work int)

Types

type CheckBlockDebugLog

type CheckBlockDebugLog struct {
	Block uint64

	Complete bool
	// contains filtered or unexported fields
}

func NewCheckBlockDebugLog

func NewCheckBlockDebugLog(block uint64,
	client rpcclient.RpcClient,
	db kv.Database,
) *CheckBlockDebugLog

func (*CheckBlockDebugLog) Execute

func (e *CheckBlockDebugLog) Execute()

type Jobs

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

type SyncDebugJob

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

func NewSyncDebugJob

func NewSyncDebugJob(
	txhash common.Hash,
	client rpcclient.RpcClient,
	db kv.Writer,
) *SyncDebugJob

func (*SyncDebugJob) Execute

func (e *SyncDebugJob) Execute()

type SyncJob

type SyncJob struct {
	Completed bool
	Block     uint64

	BlockData            *types.Block
	TransactionDatas     []*types.Tx
	ReceiptDatas         []*types.Rt
	CallFrames           map[common.Hash]*types.CallFrame    // trace log
	InternalTxs          map[common.Hash][]*types.InternalTx // changed money internal tx
	ContractOrMemberData map[common.Address]*types.Account   // miner , from , to, new contract(changed money)
	ContractInfoMap      map[common.Address]*types.Contract  // new contract
	ProxyContracts       map[common.Address]common.Address   // proxy contract => logic contract
	// contains filtered or unexported fields
}

func NewSyncJob

func NewSyncJob(block uint64, client rpcclient.RpcClient) *SyncJob

func (*SyncJob) Execute

func (e *SyncJob) Execute()

type SyncRtJob

type SyncRtJob struct {
	Completed bool

	ReceiptData *types.Rt
	// contains filtered or unexported fields
}

func NewSyncRtJob

func NewSyncRtJob(tx common.Hash,
	client rpcclient.RpcClient,
) *SyncRtJob

func (*SyncRtJob) Execute

func (e *SyncRtJob) Execute()

type SyncTracerJob

type SyncTracerJob struct {
	Completed bool
	Status    bool // tx exec result

	CallFrame *types.CallFrame
	Error     string

	InternalTxs []*types.InternalTx
	// address => map
	ContractOrMemberData map[common.Address]*types.Account
	ContractInfoMap      map[common.Address]*types.Contract
	ProxyContract        map[common.Address]common.Address // proxy => logic
	// contains filtered or unexported fields
}

func NewSyncTracerJob

func NewSyncTracerJob(block uint64,
	tx common.Hash,
	client rpcclient.RpcClient,
) *SyncTracerJob

func (*SyncTracerJob) Execute

func (e *SyncTracerJob) Execute()

type SyncTxJob

type SyncTxJob struct {
	Completed bool

	TransactionData      *types.Tx
	ContractOrMemberData map[common.Address]*types.Account
	// contains filtered or unexported fields
}

func NewSyncTxJob

func NewSyncTxJob(tx common.Hash,
	client rpcclient.RpcClient) *SyncTxJob

func (*SyncTxJob) Execute

func (e *SyncTxJob) Execute()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL