zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-10-16 10:40:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: added retry last action support for workspaces and new failure states

Browse Source
This commit is contained in:
Andrey Melnikov
2020-09-10 12:30:18 -07:00
parent 076422e8ac
commit fc7ef5ffac
11 changed files with 693 additions and 107 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
server/workspace_server.go
View File

@@ -177,6 +177,7 @@ func (s *WorkspaceServer) UpdateWorkspaceStatus(ctx context.Context, req *api.Up
status := &v1.WorkspaceStatus{
Phase: v1.WorkspacePhase(req.Status.Phase),
}
err = client.UpdateWorkspaceStatus(req.Namespace, req.Uid, status)
return &empty.Empty{}, err
@@ -276,3 +277,64 @@ func (s *WorkspaceServer) DeleteWorkspace(ctx context.Context, req *api.DeleteWo
return &empty.Empty{}, err
}
// RetryLastWorkspaceAction will attempt the last action on the workspace again.
func (s *WorkspaceServer) RetryLastWorkspaceAction(ctx context.Context, req *api.RetryActionWorkspaceRequest) (*empty.Empty, error) {
client := getClient(ctx)
workspace, err := client.GetWorkspace(req.Namespace, req.Uid)
if err != nil {
return nil, err
}
if workspace == nil {
return nil, util.NewUserError(codes.NotFound, "workspace not found")
}
verb := ""
switch workspace.Status.Phase {
case v1.WorkspaceFailedToLaunch:
verb = "create"
case v1.WorkspaceFailedToPause:
verb = "update"
case v1.WorkspaceFailedToResume:
verb = "update"
case v1.WorkspaceFailedToTerminate:
verb = "delete"
case v1.WorkspaceFailedToUpdate:
verb = "update"
default:
return nil, util.NewUserError(codes.InvalidArgument, "Workspace is not in a failed state")
}
allowed, err := auth.IsAuthorized(client, req.Namespace, verb, "onepanel.io", "workspaces", req.Uid)
if err != nil || !allowed {
return &empty.Empty{}, err
}
switch workspace.Status.Phase {
case v1.WorkspaceFailedToLaunch:
if _, err := client.StartWorkspace(req.Namespace, workspace); err != nil {
return nil, err
}
case v1.WorkspaceFailedToPause:
if err := client.PauseWorkspace(req.Namespace, workspace.UID); err != nil {
return nil, err
}
case v1.WorkspaceFailedToResume:
if err := client.ResumeWorkspace(req.Namespace, workspace.UID); err != nil {
return nil, err
}
case v1.WorkspaceFailedToTerminate:
if err := client.DeleteWorkspace(req.Namespace, workspace.UID); err != nil {
return nil, err
}
case v1.WorkspaceFailedToUpdate:
if err := client.UpdateWorkspace(req.Namespace, workspace.UID, workspace.Parameters); err != nil {
return nil, err
}
default:
return nil, util.NewUserError(codes.InvalidArgument, "Workspace is not in a failed state")
}
return &empty.Empty{}, err
}