Documentation
¶
Index ¶
- type Outbox
- func (o *Outbox) Checkpoint(pid string) (string, error)
- func (o *Outbox) Commit(pid, target string, assign goarSchema.BundleItem) error
- func (o *Outbox) Peek(pid, target string) (seq int, item *goarSchema.BundleItem, err error)
- func (o *Outbox) Push(pid, target string, message goarSchema.BundleItem) error
- func (o *Outbox) Restore(data string) error
- type Registry
- func (r *Registry) Checkpoint() (data string, err error)
- func (r *Registry) GetId() (string, error)
- func (r *Registry) GetNode(accid string) (*registrySchema.Node, error)
- func (r *Registry) GetNodes() (nodes map[string]registrySchema.Node, err error)
- func (r *Registry) GetNodesByProcess(pid string) (nodes []registrySchema.Node, err error)
- func (r *Registry) GetProcesses(accid string) (procs []string, err error)
- func (r *Registry) GetTokenPid() (string, error)
- func (r *Registry) Register(node registrySchema.Node) error
- func (r *Registry) RegisterProcess(accid, pid string) error
- func (r *Registry) Restore(data string) error
- func (r *Registry) Unregister(accid string) error
- func (r *Registry) UnregisterProcess(accid, pid string) error
- type Token
- func (h *Token) BalanceOf(accId string) (*big.Int, error)
- func (h *Token) Balances() (map[string]*big.Int, error)
- func (h *Token) Checkpoint() (data string, err error)
- func (h *Token) GetInfo() tokenSchema.Info
- func (h *Token) GetTotalSupply() (*big.Int, error)
- func (h *Token) Restore(data string) error
- func (h *Token) StakeOf(accId string) (*big.Int, error)
- func (h *Token) Stakes() (map[string]*big.Int, error)
- func (h *Token) UpdateBalance(accId string, amount *big.Int) error
- func (h *Token) UpdateStake(accId string, amount *big.Int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Outbox ¶
type Outbox struct {
// contains filtered or unexported fields
}
func (*Outbox) Commit ¶
func (o *Outbox) Commit(pid, target string, assign goarSchema.BundleItem) error
func (*Outbox) Peek ¶
func (o *Outbox) Peek(pid, target string) (seq int, item *goarSchema.BundleItem, err error)
func (*Outbox) Push ¶
func (o *Outbox) Push(pid, target string, message goarSchema.BundleItem) error
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func NewRegistry ¶
func NewRegistry(id, tokenPid string, mainNode registrySchema.Node) *Registry
func (*Registry) Checkpoint ¶
func (*Registry) GetNodes ¶
func (r *Registry) GetNodes() (nodes map[string]registrySchema.Node, err error)
func (*Registry) GetNodesByProcess ¶
func (r *Registry) GetNodesByProcess(pid string) (nodes []registrySchema.Node, err error)
func (*Registry) GetProcesses ¶
func (*Registry) GetTokenPid ¶
func (*Registry) RegisterProcess ¶
func (*Registry) Unregister ¶
func (*Registry) UnregisterProcess ¶
type Token ¶
type Token struct {
// contains filtered or unexported fields
}
func (*Token) Checkpoint ¶
func (*Token) GetInfo ¶
func (h *Token) GetInfo() tokenSchema.Info
Click to show internal directories.
Click to hide internal directories.