actor

Documentation

Overview

Package actor privides communication with other actor

Package actor privides communication with other actor

Index

• Constants
• Variables
• func AppendTxToPool(txn *types.Transaction) (ontErrors.ErrCode, string)
• func ConsensusSrvHalt() error
• func ConsensusSrvStart() error
• func CurrentBlockHash() common.Uint256
• func GetBlockByHeight(height uint32) (*types.Block, error)
• func GetBlockFromStore(hash common.Uint256) (*types.Block, error)
• func GetBlockHashFromStore(height uint32) common.Uint256
• func GetConnectionCnt() uint32
• func GetContractStateFromStore(hash common.Address) (*payload.DeployCode, error)
• func GetCrossChainMsg(height uint32) (*types.CrossChainMsg, error)
• func GetCrossStatesProof(height uint32, key []byte) ([]byte, error)
• func GetCurrentBlockHeight() uint32
• func GetEventNotifyByHeight(height uint32) ([]*event.ExecuteNotify, error)
• func GetEventNotifyByTxHash(txHash common.Uint256) (*event.ExecuteNotify, error)
• func GetHeaderByHeight(height uint32) (*types.Header, error)
• func GetID() common.PeerId
• func GetMaxPeerBlockHeight() uint64
• func GetMerkleProof(proofHeight uint32, rootHeight uint32) ([]common.Uint256, error)
• func GetNeighborAddrs() []common.PeerAddr
• func GetNodePort() uint16
• func GetNodeType() uint64
• func GetRelayState() bool
• func GetStorageItem(address common.Address, key []byte) ([]byte, error)
• func GetTransaction(hash common.Uint256) (*types.Transaction, error)
• func GetTxFromPool(hash common.Uint256) (tcomn.TXEntry, error)
• func GetTxnCount() ([]uint32, error)
• func GetTxnHashList() ([]common.Uint256, error)
• func GetTxnWithHeightByTxHash(hash common.Uint256) (uint32, *types.Transaction, error)
• func GetTxsFromPool(byCount bool) map[common.Uint256]*types.Transaction
• func GetVersion() uint32
• func PreExecuteContract(tx *types.Transaction) (*cstate.PreExecResult, error)
• func PreExecuteContractBatch(tx []*types.Transaction, atomic bool) ([]*cstate.PreExecResult, uint32, error)
• func SetConsensusPid(actr *actor.PID)
• func SetNetServer(p2p p2p.P2P)
• func SetTxPid(actr *actor.PID)
• func SetTxnPoolPid(actr *actor.PID)
• func SubscribeEvent(topic string, handler func(v interface{}))
• type EventActor
  • func (t *EventActor) Receive(c actor.Context)

Constants

const (
	REQ_TIMEOUT    = 5
	ERR_ACTOR_COMM = "[http] Actor comm error: %v"
)

Variables

var DisableSyncVerifyTx = false

Functions

func AppendTxToPool

func AppendTxToPool(txn *types.Transaction) (ontErrors.ErrCode, string)

append transaction to pool to txpool actor

func ConsensusSrvHalt

func ConsensusSrvHalt() error

halt consensus to consensus actor

func ConsensusSrvStart

func ConsensusSrvStart() error

start consensus to consensus actor

func CurrentBlockHash

func CurrentBlockHash() common.Uint256

CurrentBlockHash from ledger

func GetBlockByHeight

func GetBlockByHeight(height uint32) (*types.Block, error)

GetBlockByHeight from ledger

func GetBlockFromStore

func GetBlockFromStore(hash common.Uint256) (*types.Block, error)

GetBlockFromStore from ledger

func GetBlockHashFromStore

func GetBlockHashFromStore(height uint32) common.Uint256

GetBlockHashFromStore from ledger

func GetConnectionCnt

func GetConnectionCnt() uint32

GetConnectionCnt from netSever actor

func GetContractStateFromStore

func GetContractStateFromStore(hash common.Address) (*payload.DeployCode, error)

GetContractStateFromStore from ledger

func GetCrossChainMsg

func GetCrossChainMsg(height uint32) (*types.CrossChainMsg, error)

func GetCrossStatesProof

func GetCrossStatesProof(height uint32, key []byte) ([]byte, error)

func GetCurrentBlockHeight

func GetCurrentBlockHeight() uint32

GetCurrentBlockHeight from ledger

func GetEventNotifyByHeight

func GetEventNotifyByHeight(height uint32) ([]*event.ExecuteNotify, error)

GetEventNotifyByHeight from ledger

func GetEventNotifyByTxHash

func GetEventNotifyByTxHash(txHash common.Uint256) (*event.ExecuteNotify, error)

GetEventNotifyByTxHash from ledger

func GetHeaderByHeight

func GetHeaderByHeight(height uint32) (*types.Header, error)

GetHeaderByHeight from ledger

func GetID

func GetID() common.PeerId

GetID from netSever actor

func GetMaxPeerBlockHeight

func GetMaxPeerBlockHeight() uint64

GetMaxPeerBlockHeight from netSever actor

func GetMerkleProof

func GetMerkleProof(proofHeight uint32, rootHeight uint32) ([]common.Uint256, error)

GetMerkleProof from ledger

func GetNeighborAddrs

func GetNeighborAddrs() []common.PeerAddr

GetNeighborAddrs from netSever actor

func GetNodePort

func GetNodePort() uint16

GetNodePort from netSever actor

func GetNodeType

func GetNodeType() uint64

GetNodeType from netSever actor

func GetRelayState

func GetRelayState() bool

GetRelayState from netSever actor

func GetStorageItem

func GetStorageItem(address common.Address, key []byte) ([]byte, error)

GetStorageItem from ledger

func GetTransaction

func GetTransaction(hash common.Uint256) (*types.Transaction, error)

GetTransaction from ledger

func GetTxFromPool

func GetTxFromPool(hash common.Uint256) (tcomn.TXEntry, error)

GetTxFromPool from txpool actor

func GetTxnCount

func GetTxnCount() ([]uint32, error)

GetTxnCount from txpool actor

func GetTxnHashList

func GetTxnHashList() ([]common.Uint256, error)

GetTxnHashList from txpool actor

func GetTxnWithHeightByTxHash

func GetTxnWithHeightByTxHash(hash common.Uint256) (uint32, *types.Transaction, error)

GetTxnWithHeightByTxHash from ledger

func GetTxsFromPool

func GetTxsFromPool(byCount bool) map[common.Uint256]*types.Transaction

GetTxsFromPool from txpool actor

func GetVersion

func GetVersion() uint32

GetVersion from netSever actor

func PreExecuteContract

func PreExecuteContract(tx *types.Transaction) (*cstate.PreExecResult, error)

PreExecuteContract from ledger

func PreExecuteContractBatch

func PreExecuteContractBatch(tx []*types.Transaction, atomic bool) ([]*cstate.PreExecResult, uint32, error)

func SetConsensusPid

func SetConsensusPid(actr *actor.PID)

func SetNetServer

func SetNetServer(p2p p2p.P2P)

func SetTxPid

func SetTxPid(actr *actor.PID)

func SetTxnPoolPid

func SetTxnPoolPid(actr *actor.PID)

func SubscribeEvent

func SubscribeEvent(topic string, handler func(v interface{}))

Subscribe save block complete and smartcontract Event

Types

type EventActor

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

func (*EventActor) Receive

func (t *EventActor) Receive(c actor.Context)

receive from subscribed actor