rdb

package

v0.1.0 Latest Latest Go to latest Published: Jul 30, 2025 License: MPL-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(redisUrl string) *RDB

func (r *RDB) Close()

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

func (r *RDB) GetAllProcess() (processIds []string, curNonces []int64, err error)

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

func (r *RDB) GetCache(pid, key string) (value string, err error)

func (r *RDB) GetCheckpointIndex(pid string) (id string, err error)

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

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

func (r *RDB) GetNonce(pid string) (nonce int64, err error)

func (r *RDB) GetResult(msgid string) (result *vmmSchema.Result, err error)

func (r *RDB) GetResults(pid string, limit int64) (results []vmmSchema.Result, err error)

func (r *RDB) IsExist(pid string) (ok bool, err error)

func (r *RDB) RevertSpawn(pid string) error

func (r *RDB) SaveCache(pid, key, value string) error

func (r *RDB) SaveCheckpointIndex(pid, id string) error

func (r *RDB) SaveResult(result vmmSchema.Result) (err error)

Path	Synopsis
schema