doublejynx/jx
doublejynx/jx
1
0
Fork 0
Code Issues 6 Pull Requests Actions Packages Projects Releases 7 Wiki Activity

add state transitions for process restart
Some checks failed
Lint / golangci-lint (push) Failing after 10m0s
Details
Declarative Tests / test (push) Failing after 21s
Details

Browse Source
This commit is contained in:
Matthew Rich 2025-08-24 23:54:04 +00:00
parent 9164150c06
commit eaac8c8800
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/resource/resource.go
View File

@ -65,6 +65,11 @@ func ResourceMachine(sub machine.Subscriber) machine.Stater {
return nil
}
stater.AddTransition("read-failed", machine.States("start_read"), "inconsistent")
if e := stater.AddSubscription("read-failed", sub); e != nil {
return nil
}
stater.AddTransition("update-failed", machine.States("start_update"), "inconsistent")
if e := stater.AddSubscription("update-failed", sub); e != nil {
return nil
@ -147,5 +152,20 @@ func ProcessMachine(sub machine.Subscriber) machine.Stater {
if e := stater.AddSubscription("deleted", sub); e != nil {
return nil
}
stater.AddTransition("restart", machine.States("*"), "restarting")
if e := stater.AddSubscription("restart", sub); e != nil {
return nil
}
stater.AddTransition("restarted", machine.States("restarting"), "running")
if e := stater.AddSubscription("restarted", sub); e != nil {
return nil
}
stater.AddTransition("restart-failed", machine.States("restarting"), "inconsistent")
if e := stater.AddSubscription("restart-failed", sub); e != nil {
return nil
}
return stater
}