node

func (*Node) AddAssignResHandler ¶ added in v0.2.0

func (n *Node) AddAssignResHandler(handler ...schema.AssignResHandler)

func (*Node) AddItemHandler ¶ added in v0.2.0

func (n *Node) AddItemHandler(handler ...schema.ItemHandler)

func (*Node) AddResultHandler ¶

func (n *Node) AddResultHandler(handler ...schema.ResultHandler)

func (*Node) BalanceOf ¶

func (n *Node) BalanceOf(accid string) (*big.Int, error)

func (*Node) Checkpoint ¶

func (n *Node) Checkpoint(pid string) (ckpItem goarSchema.BundleItem, err error)

func (*Node) Close ¶

func (n *Node) Close()

func (*Node) Fork ¶

func (n *Node) Fork(pid, checkpointID, nodeURL string, mode vmmSchema.ExecMode) error

func (*Node) GetAssignByMessage ¶

func (n *Node) GetAssignByMessage(msgid string) (assign *goarSchema.BundleItem, err error)

func (*Node) GetAssignByNonce ¶

func (n *Node) GetAssignByNonce(pid string, nonce int64) (assign *goarSchema.BundleItem, err error)

func (*Node) GetCache ¶

func (n *Node) GetCache(pid, key string) (string, error)

func (*Node) GetMessage ¶

func (n *Node) GetMessage(msgid string) (msg *goarSchema.BundleItem, err error)

func (*Node) GetMessageByNonce ¶

func (n *Node) GetMessageByNonce(pid string, nonce int64) (msg *goarSchema.BundleItem, err error)

func (*Node) GetModuleNames ¶ added in v0.1.3

func (n *Node) GetModuleNames() []string

func (*Node) GetNode ¶

func (n *Node) GetNode(accid string) (*registrySchema.Node, error)

func (*Node) GetNodes ¶

func (n *Node) GetNodes() (map[string]registrySchema.Node, error)

func (*Node) GetNodesByProcess ¶

func (n *Node) GetNodesByProcess(pid string) ([]registrySchema.Node, error)

func (*Node) GetNonce ¶ added in v0.4.8

func (n *Node) GetNonce(pid string) (int64, error)

func (*Node) GetProcesses ¶

func (n *Node) GetProcesses(accid string) ([]string, error)

func (*Node) GetResult ¶

func (n *Node) GetResult(msgid string) (result *vmmSchema.VmmResult, err error)

func (*Node) GetResults ¶

func (n *Node) GetResults(pid string, limit int64) (results []vmmSchema.VmmResult, err error)

func (*Node) Handle ¶

func (n *Node) Handle(item goarSchema.BundleItem) (err error)

func (*Node) HandleMode ¶ added in v0.4.7

func (n *Node) HandleMode(item goarSchema.BundleItem, assign hymxSchema.Assignment, mode vmmSchema.ExecMode, maxNonce int64) (err error)

func (*Node) Info ¶

func (n *Node) Info() schema.Info

func (*Node) IsRedirect ¶ added in v0.4.0

func (n *Node) IsRedirect(pid string) (ok bool, nodes []registrySchema.Node, err error)

func (*Node) LoadModule ¶

func (n *Node) LoadModule(itemId string) (module hymxSchema.Module, err error)

func (*Node) Mount ¶

func (n *Node) Mount(moduleFormat string, spawner vmmSchema.VmSpawnFunc) error

func (*Node) RemoveAssignResHandler ¶ added in v0.2.0

func (n *Node) RemoveAssignResHandler(handler schema.AssignResHandler)

func (*Node) Restore ¶

func (n *Node) Restore(ckpId string) (nonce int64, err error)

func (*Node) Run ¶

func (n *Node) Run(startMode string)

func (*Node) StakeOf ¶

func (n *Node) StakeOf(accid string) (*big.Int, error)

func (*Node) TrySend ¶ added in v0.1.3

func (n *Node) TrySend(pid, target string)

TrySend is a public wrapper for the private trySend method