upgrade

package

v0.0.0-...-91c7ab2 Latest Latest Go to latest Published: Mar 27, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func InitUpgrade(storeDir string)

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

func (j *Job) GetError() error

func (j *Job) GetProcess() int

func (j *Job) GetState() model.UpgradeState

func (j *Job) Run()

type Result struct {
	JobID string
	Err   error
}

type Upgrade struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func GetInst() *Upgrade

func (u *Upgrade) AddUpgradeJob(jobID string, upgradeType model.UpgradeDeviceType, version string, filename string, body []byte) error

func (u *Upgrade) QueryJobState(jobID string) (state model.UpgradeState, process int, exist bool)

func (u *Upgrade) Run()

func (u *Upgrade) SelectJobResult() <-chan Result