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, error)
• func GetConnectionState() (uint32, error)
• func GetContractStateFromStore(hash common.Address) (*payload.DeployCode, 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() (uint64, error)
• func GetMaxPeerBlockHeight() (uint64, error)
• func GetMerkleProof(proofHeight uint32, rootHeight uint32) ([]common.Uint256, error)
• func GetNeighborAddrs() []common.PeerAddr
• func GetNodePort() (uint16, error)
• func GetNodeTime() (int64, error)
• func GetNodeType() (uint64, error)
• func GetRelayState() (bool, error)
• 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 GetTxnWithHeightByTxHash(hash common.Uint256) (uint32, *types.Transaction, error)
• func GetTxsFromPool(byCount bool) map[common.Uint256]*types.Transaction
• func GetVersion() (uint32, error)
• 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 SetNetServerPID(actr *actor.PID)
• func SetTxPid(actr *actor.PID)
• func SetTxnPoolPid(actr *actor.PID)
• func SubscribeEvent(topic string, handler func(v interface{}))
• func Xmit(msg interface{}) error
• 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, error)

GetConnectionCnt from netSever actor

func GetConnectionState

func GetConnectionState() (uint32, error)

GetConnectionState from netSever actor

func GetContractStateFromStore

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

GetContractStateFromStore from ledger

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() (uint64, error)

GetID from netSever actor

func GetMaxPeerBlockHeight

func GetMaxPeerBlockHeight() (uint64, error)

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, error)

GetNodePort from netSever actor

func GetNodeTime

func GetNodeTime() (int64, error)

GetNodeTime from netSever actor

func GetNodeType

func GetNodeType() (uint64, error)

GetNodeType from netSever actor

func GetRelayState

func GetRelayState() (bool, error)

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 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, error)

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 SetNetServerPID

func SetNetServerPID(actr *actor.PID)

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

func Xmit

func Xmit(msg interface{}) error

Xmit to netSever actor

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