schema

type AssignMessage struct {
	Pid     string
	AccId   string
	Message schema.Message
	Item    goarSchema.BundleItem
}

type AssignProcess struct {
	Pid     string
	AccId   string
	Process schema.Process
	Item    goarSchema.BundleItem
}

type AssignmentHandler func(AssignmentResult)

type AssignmentResult struct {
	Pid        string
	Item       goarSchema.BundleItem
	Assign     hymxSchema.Assignment
	AssignItem goarSchema.BundleItem
	Error      error
}

type IDB interface {
	// result
	SaveResult(result schema.Result) error
	GetResult(msgid string) (result *schema.Result, err error)
	GetResults(pid string, limit int64) (results []schema.Result, err error)

	// assignment
	IsExist(pid string) (ok bool, err error)
	GetNonce(pid string) (nonce int64, err error)
	Commit(pid string, nonce int64, msg, assign goarSchema.BundleItem) (err error)

	// get
	GetAllProcess() (pids []string, curNonces []int64, err error)
	GetMessage(msgid string) (msg *goarSchema.BundleItem, err error)
	GetMessageByNonce(pid string, nonce int64) (msg *goarSchema.BundleItem, err error)
	GetAssignByNonce(pid string, nonce int64) (assign *goarSchema.BundleItem, err error)

	// checkpoint
	GetCheckpointIndex(pid string) (id string, err error)
	SaveCheckpointIndex(pid, id string) (err error)

	// cache
	GetCache(pid, key string) (value string, err error)
	SaveCache(pid, key, value string) (err error)
}

type IDBOutbox interface {
	Push(pid, target string, message goarSchema.BundleItem) error
	Peek(pid, target string) (int, *goarSchema.BundleItem, error)
	Commit(pid, target string, assign goarSchema.BundleItem) error

	Checkpoint(pid string) (string, error)
	Restore(data string) error
}

type Info struct {
	Protocol    string              `json:"Protocol"`
	Variant     string              `json:"Variant"`
	JoinNetwork bool                `json:"Join-Network"`
	Token       string              `json:"Token"`
	Registry    string              `json:"Registry"`
	Node        registrySchema.Node `json:"Node"`
}

type ResultHandler func(vmmSchema.Result)