actor

Documentation

Index

• Constants
• func AddBlock(block *types.Block) error
• func AppendTxToPool(txn *types.Transaction) ontErrors.ErrCode
• func BlockHeight() (uint32, error)
• func ConsensusSrvHalt() error
• func ConsensusSrvStart() error
• func CurrentBlockHash() (common.Uint256, error)
• func GetBlockFromStore(hash common.Uint256) (*types.Block, error)
• func GetBlockHashFromStore(height uint32) (common.Uint256, error)
• func GetBlockHeightByTxHashFromStore(hash common.Uint256) (uint32, error)
• func GetConnectionCnt() (uint, error)
• func GetConnectionState() (uint32, error)
• func GetContractStateFromStore(hash common.Address) (*payload.DeployCode, error)
• func GetEventNotifyByHeight(height uint32) ([]common.Uint256, error)
• func GetEventNotifyByTxHash(txHash common.Uint256) ([]*event.NotifyEventInfo, error)
• func GetID() (uint64, error)
• func GetNeighborAddrs() ([]protocol.NodeAddr, uint64)
• func GetNodePort() (uint16, error)
• func GetNodeTime() (int64, error)
• func GetNodeType() (uint64, error)
• func GetRelayState() (bool, error)
• func GetStorageItem(codeHash common.Address, key []byte) ([]byte, error)
• func GetTransaction(hash common.Uint256) (*types.Transaction, error)
• func GetTxFromPool(hash common.Uint256) (tcomn.TXEntry, error)
• func GetTxnCnt() ([]uint64, error)
• func GetTxsFromPool(byCount bool) (map[common.Uint256]*types.Transaction, common.Fixed64)
• func GetVersion() (uint32, error)
• func PreExecuteContract(tx *types.Transaction) ([]interface{}, error)
• func SetConsensusPid(actr *actor.PID)
• func SetLedgerPid(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 AddBlock

func AddBlock(block *types.Block) error

func AppendTxToPool

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

func BlockHeight

func BlockHeight() (uint32, error)

func ConsensusSrvHalt

func ConsensusSrvHalt() error

func ConsensusSrvStart

func ConsensusSrvStart() error

func CurrentBlockHash

func CurrentBlockHash() (common.Uint256, error)

func GetBlockFromStore

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

func GetBlockHashFromStore

func GetBlockHashFromStore(height uint32) (common.Uint256, error)

func GetBlockHeightByTxHashFromStore

func GetBlockHeightByTxHashFromStore(hash common.Uint256) (uint32, error)

func GetConnectionCnt

func GetConnectionCnt() (uint, error)

func GetConnectionState

func GetConnectionState() (uint32, error)

func GetContractStateFromStore

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

func GetEventNotifyByHeight

func GetEventNotifyByHeight(height uint32) ([]common.Uint256, error)

func GetEventNotifyByTxHash

func GetEventNotifyByTxHash(txHash common.Uint256) ([]*event.NotifyEventInfo, error)

func GetID

func GetID() (uint64, error)

func GetNeighborAddrs

func GetNeighborAddrs() ([]protocol.NodeAddr, uint64)

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(codeHash 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 GetTxnCnt

func GetTxnCnt() ([]uint64, error)

func GetTxsFromPool

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

func GetVersion

func GetVersion() (uint32, error)

func PreExecuteContract

func PreExecuteContract(tx *types.Transaction) ([]interface{}, error)

func SetConsensusPid

func SetConsensusPid(actr *actor.PID)

func SetLedgerPid

func SetLedgerPid(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)