actor

package

v0.0.0-...-67468a5 Latest Latest Go to latest Published: Sep 24, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

git.fe-cred.com/idfor/idfor

Links

Open Source Insights

Documentation ¶

Overview ¶

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 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 ¶

View Source

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

Variables ¶

View Source

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 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 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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL