cache

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 6, 2025 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

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 NewOutbox

func NewOutbox() *Outbox

func (*Outbox) Checkpoint

func (o *Outbox) Checkpoint(pid string) (string, error)

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

func (*Outbox) Restore

func (o *Outbox) Restore(data string) 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 (r *Registry) Checkpoint() (data string, err error)

func (*Registry) GetId

func (r *Registry) GetId() (string, error)

func (*Registry) GetNode

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

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 (r *Registry) GetProcesses(accid string) (procs []string, err error)

func (*Registry) GetTokenPid

func (r *Registry) GetTokenPid() (string, error)

func (*Registry) Register

func (r *Registry) Register(node registrySchema.Node) error

func (*Registry) RegisterProcess

func (r *Registry) RegisterProcess(accid, pid string) error

func (*Registry) Restore

func (r *Registry) Restore(data string) error

func (*Registry) Unregister

func (r *Registry) Unregister(accid string) error

func (*Registry) UnregisterProcess

func (r *Registry) UnregisterProcess(accid, pid string) error

type Token

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

func NewToken

func NewToken(info tokenSchema.Info, bals, stakes map[string]*big.Int) *Token

func (*Token) BalanceOf

func (h *Token) BalanceOf(accId string) (*big.Int, error)

func (*Token) Balances

func (h *Token) Balances() (map[string]*big.Int, error)

func (*Token) Checkpoint

func (h *Token) Checkpoint() (data string, err error)

func (*Token) GetInfo

func (h *Token) GetInfo() tokenSchema.Info

func (*Token) GetTotalSupply

func (h *Token) GetTotalSupply() (*big.Int, error)

func (*Token) Restore

func (h *Token) Restore(data string) error

func (*Token) StakeOf

func (h *Token) StakeOf(accId string) (*big.Int, error)

func (*Token) Stakes

func (h *Token) Stakes() (map[string]*big.Int, error)

func (*Token) UpdateBalance

func (h *Token) UpdateBalance(accId string, amount *big.Int) error

func (*Token) UpdateStake

func (h *Token) UpdateStake(accId string, amount *big.Int) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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