rdb

func (*Chainkit) AddPending ¶ added in v0.3.0

func (r *Chainkit) AddPending(txid string) error

addPending adds a txid to pending txids queue (FIFO)

func (*Chainkit) Cache ¶ added in v0.3.2

func (r *Chainkit) Cache(txid string, item goarSchema.BundleItem) error

func (*Chainkit) EndUpload ¶ added in v0.3.0

func (r *Chainkit) EndUpload() error

func (*Chainkit) GetBundledIn ¶ added in v0.3.0

func (r *Chainkit) GetBundledIn() (string, error)

GetBundledIn returns the current bundledIn ID if it exists, or empty string if it doesn't exist

func (*Chainkit) GetCache ¶ added in v0.3.2

func (r *Chainkit) GetCache(txid string) (*goarSchema.BundleItem, error)

func (*Chainkit) GetUploading ¶ added in v0.3.0

func (r *Chainkit) GetUploading() ([]string, error)

func (*Chainkit) IsUploaded ¶ added in v0.3.2

func (r *Chainkit) IsUploaded(txid string) (bool, error)

IsUploaded checks if a transaction ID has already been uploaded

func (*Chainkit) IsUploadedBatch ¶ added in v0.3.0

func (r *Chainkit) IsUploadedBatch(txids []string) (map[string]bool, error)

IsUploadedBatch checks if multiple transaction IDs have already been uploaded Returns a map where key is txid and value is whether it's uploaded

func (*Chainkit) MoveToUploading ¶ added in v0.3.0

func (r *Chainkit) MoveToUploading() (int64, error)

func (*Chainkit) SetBundledIn ¶ added in v0.3.0

func (r *Chainkit) SetBundledIn(bundledInID string) error

func (*RDB) Close ¶

func (r *RDB) Close()

func (*RDB) Commit ¶

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

func (*RDB) GetAllProcess ¶

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

func (*RDB) GetAssignByNonce ¶

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

func (*RDB) GetCache ¶

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

func (*RDB) GetCheckpointIndex ¶

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

func (*RDB) GetMessage ¶

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

func (*RDB) GetMessageByNonce ¶

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

func (*RDB) GetNonce ¶

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

func (*RDB) GetResult ¶

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

func (*RDB) GetResults ¶

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

func (*RDB) IsExist ¶

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

func (*RDB) RevertSpawn ¶

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

func (*RDB) SaveCache ¶

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

func (*RDB) SaveCheckpointIndex ¶

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

func (*RDB) SaveResult ¶

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