Documentation ¶
Index ¶
- func GetSyncWorkers(workerNums int, bc *blockchain.Blockchain) []mpool.VmWorker
- type SyncWorker
- func (worker *SyncWorker) OnBlock(workerData *types.WorkerData)
- func (worker *SyncWorker) OnGetBlocks(workerData *types.WorkerData)
- func (worker *SyncWorker) OnGetData(workerData *types.WorkerData)
- func (worker *SyncWorker) OnGetInv(workerData *types.WorkerData)
- func (worker *SyncWorker) OnStatus(workerData *types.WorkerData)
- func (worker *SyncWorker) OnTransaction(workerData *types.WorkerData)
- func (worker *SyncWorker) SendMsg(peer *peer.Peer, protoID proto.ProtoID, msgID proto.MsgType, imsg proto.IMsg) error
- func (worker *SyncWorker) VmJob(data interface{}) (interface{}, error)
- func (worker *SyncWorker) VmReady() bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetSyncWorkers ¶
func GetSyncWorkers(workerNums int, bc *blockchain.Blockchain) []mpool.VmWorker
Types ¶
type SyncWorker ¶
type SyncWorker struct {
// contains filtered or unexported fields
}
func NewSyncWorker ¶
func NewSyncWorker(ledger *ledger.Ledger, bc *blockchain.Blockchain) *SyncWorker
func (*SyncWorker) OnBlock ¶
func (worker *SyncWorker) OnBlock(workerData *types.WorkerData)
func (*SyncWorker) OnGetBlocks ¶
func (worker *SyncWorker) OnGetBlocks(workerData *types.WorkerData)
func (*SyncWorker) OnGetData ¶
func (worker *SyncWorker) OnGetData(workerData *types.WorkerData)
func (*SyncWorker) OnGetInv ¶
func (worker *SyncWorker) OnGetInv(workerData *types.WorkerData)
func (*SyncWorker) OnStatus ¶
func (worker *SyncWorker) OnStatus(workerData *types.WorkerData)
func (*SyncWorker) OnTransaction ¶
func (worker *SyncWorker) OnTransaction(workerData *types.WorkerData)
func (*SyncWorker) VmJob ¶
func (worker *SyncWorker) VmJob(data interface{}) (interface{}, error)
func (*SyncWorker) VmReady ¶
func (worker *SyncWorker) VmReady() bool
Click to show internal directories.
Click to hide internal directories.