actor

Documentation

Index

• Constants
• func AppendTxToPool(txn *types.Transaction) ontErrors.ErrCode
• 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 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 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"
)

Functions

func AppendTxToPool

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

func ConsensusSrvHalt

func ConsensusSrvHalt() error

func ConsensusSrvStart

func ConsensusSrvStart() error

func CurrentBlockHash

func CurrentBlockHash() common.Uint256

func GetBlockByHeight

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

func GetBlockFromStore

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

func GetBlockHashFromStore

func GetBlockHashFromStore(height uint32) common.Uint256

func GetConnectionCnt

func GetConnectionCnt() (uint32, error)

func GetConnectionState

func GetConnectionState() (uint32, error)

func GetContractStateFromStore

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

func GetCurrentBlockHeight

func GetCurrentBlockHeight() uint32

func GetEventNotifyByHeight

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

func GetEventNotifyByTxHash

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

func GetHeaderByHeight

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

func GetID

func GetID() (uint64, error)

func GetMerkleProof

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

func GetNeighborAddrs

func GetNeighborAddrs() []common.PeerAddr

func GetNodePort

func GetNodePort() (uint16, error)

func GetNodeTime

func GetNodeTime() (int64, error)

func GetNodeType

func GetNodeType() (uint64, error)

func GetRelayState

func GetRelayState() (bool, error)

func GetStorageItem

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

func GetTransaction

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

func GetTxFromPool

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

func GetTxnCount

func GetTxnCount() ([]uint32, error)

func GetTxnWithHeightByTxHash

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

func GetTxsFromPool

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

func GetVersion

func GetVersion() (uint32, error)

func PreExecuteContract

func PreExecuteContract(tx *types.Transaction) (*cstate.PreExecResult, 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{}))

func Xmit

func Xmit(msg interface{}) error

Types

type EventActor

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

func (*EventActor) Receive

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