schema

Feb 5, 2026

Changes in this version

+ const StartModeNormal

+ const StartModeRebuild

Dec 1, 2025

Changes in this version

+ var ErrMessageRedirect = errors.New("err_message_redirect")

+ var ErrSpawnRedirect = errors.New("err_spwan_redirect")

Oct 22, 2025

Changes in this version

+ var TryAssignSleepTime = []time.Duration

Sep 5, 2025

Changes in this version

+ type AssignResHandler func(AssignmentResult)

+ type ItemHandler func(ItemMeta) error

+ type ItemMeta struct

+ FromProcess string

+ Instance interface{}

+ Pid string

+ Signer string

Aug 27, 2025

Changes in this version

+ const NodeVersion

type Info

+ NodeVersion string

+ VmCount int64

+ type RedirectError struct

+ Nodes []registrySchema.Node

+ func NewRedirectError(nodes []registrySchema.Node) *RedirectError

+ func (e *RedirectError) Error() string

Aug 6, 2025

Changes in this version

+ type AssignmentHandler func(AssignmentResult)

+ type AssignmentResult struct

+ Assign hymxSchema.Assignment

+ AssignItem goarSchema.BundleItem

+ Error error

+ Item goarSchema.BundleItem

+ Pid string

Jul 30, 2025

Changes in this version

+ var ErrDuplicateItem = errors.New("err_duplicate_item")

+ var ErrInvalidType = errors.New("err_invalid_type")

+ var ErrNotFoundCkp = errors.New("err_not_found_ckp")

+ var ErrNotFoundMod = errors.New("err_not_found_mod")

+ var ErrNotFoundNodes = errors.New("err_not_found_nodes")

+ var ErrProcessAlreadyExists = errors.New("err_process_already_exist")

+ var ErrProcessIsRecovering = errors.New("err_process_is_recovering")

+ var ErrProcessNotFound = errors.New("err_process_not_found")

+ var ErrRedirect = errors.New("err_redirect")

+ var ErrUnauthorizedNode = errors.New("err_unauthorized_node")

+ var ErrUnrecognizedSignatureType = errors.New("err_unrecognized_signature_type")

+ var GenesisAccId = "0x18b4bA4c118279b3eB60a2DB1E794Bc41AFC1D37"

+ var GenesisNode = schema.Node

+ var NonExtractableTags = map[string]string

+ type AssignMessage struct

+ AccId string

+ Item goarSchema.BundleItem

+ Message schema.Message

+ Pid string

+ type AssignProcess struct

+ AccId string

+ Item goarSchema.BundleItem

+ Pid string

+ Process schema.Process

+ type IDB interface

+ Commit func(pid string, nonce int64, msg, assign goarSchema.BundleItem) (err error)

+ GetAllProcess func() (pids []string, curNonces []int64, err error)

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

+ GetCache func(pid, key string) (value string, err error)

+ GetCheckpointIndex func(pid string) (id string, err error)

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

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

+ GetNonce func(pid string) (nonce int64, err error)

+ GetResult func(msgid string) (result *schema.Result, err error)

+ GetResults func(pid string, limit int64) (results []schema.Result, err error)

+ IsExist func(pid string) (ok bool, err error)

+ SaveCache func(pid, key, value string) (err error)

+ SaveCheckpointIndex func(pid, id string) (err error)

+ SaveResult func(result schema.Result) error

+ type IDBOutbox interface

+ Checkpoint func(pid string) (string, error)

+ Commit func(pid, target string, assign goarSchema.BundleItem) error

+ Peek func(pid, target string) (int, *goarSchema.BundleItem, error)

+ Push func(pid, target string, message goarSchema.BundleItem) error

+ Restore func(data string) error

+ type Info struct

+ JoinNetwork bool

+ Node registrySchema.Node

+ Protocol string

+ Registry string

+ Token string

+ Variant string

+ type ResultHandler func(vmmSchema.Result)