136 lines
4.9 KiB
Go
136 lines
4.9 KiB
Go
package nomad
|
|
|
|
import (
|
|
"github.com/hashicorp/nomad/nomad/structs"
|
|
)
|
|
|
|
// deploymentWatcherStateShim is the shim that provides the state watching
|
|
// methods. These should be set by the server and passed to the deployment
|
|
// watcher.
|
|
type deploymentWatcherStateShim struct {
|
|
// region is the region the server is a member of. It is used to
|
|
// auto-populate requests that do not have it set
|
|
region string
|
|
|
|
// evaluations returns the set of evaluations for the given job
|
|
evaluations func(args *structs.JobSpecificRequest, reply *structs.JobEvaluationsResponse) error
|
|
|
|
// allocations returns the set of allocations that are part of the
|
|
// deployment.
|
|
allocations func(args *structs.DeploymentSpecificRequest, reply *structs.AllocListResponse) error
|
|
|
|
// list is used to list all the deployments in the system
|
|
list func(args *structs.DeploymentListRequest, reply *structs.DeploymentListResponse) error
|
|
|
|
// GetDeployment is used to lookup a particular deployment.
|
|
getDeployment func(args *structs.DeploymentSpecificRequest, reply *structs.SingleDeploymentResponse) error
|
|
|
|
// getJobVersions is used to lookup the versions of a job. This is used when
|
|
// rolling back to find the latest stable job
|
|
getJobVersions func(args *structs.JobVersionsRequest, reply *structs.JobVersionsResponse) error
|
|
|
|
// getJob is used to lookup a particular job.
|
|
getJob func(args *structs.JobSpecificRequest, reply *structs.SingleJobResponse) error
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) Evaluations(args *structs.JobSpecificRequest, reply *structs.JobEvaluationsResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.evaluations(args, reply)
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) Allocations(args *structs.DeploymentSpecificRequest, reply *structs.AllocListResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.allocations(args, reply)
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) List(args *structs.DeploymentListRequest, reply *structs.DeploymentListResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.list(args, reply)
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) GetDeployment(args *structs.DeploymentSpecificRequest, reply *structs.SingleDeploymentResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.getDeployment(args, reply)
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) GetJobVersions(args *structs.JobVersionsRequest, reply *structs.JobVersionsResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.getJobVersions(args, reply)
|
|
}
|
|
|
|
func (d *deploymentWatcherStateShim) GetJob(args *structs.JobSpecificRequest, reply *structs.SingleJobResponse) error {
|
|
if args.Region == "" {
|
|
args.Region = d.region
|
|
}
|
|
|
|
return d.getJob(args, reply)
|
|
}
|
|
|
|
// deploymentWatcherRaftShim is the shim that provides the state watching
|
|
// methods. These should be set by the server and passed to the deployment
|
|
// watcher.
|
|
type deploymentWatcherRaftShim struct {
|
|
// apply is used to apply a message to Raft
|
|
apply raftApplyFn
|
|
}
|
|
|
|
// convertApplyErrors parses the results of a raftApply and returns the index at
|
|
// which it was applied and any error that occurred. Raft Apply returns two
|
|
// separate errors, Raft library errors and user returned errors from the FSM.
|
|
// This helper, joins the errors by inspecting the applyResponse for an error.
|
|
func (d *deploymentWatcherRaftShim) convertApplyErrors(applyResp interface{}, index uint64, err error) (uint64, error) {
|
|
if applyResp != nil {
|
|
if fsmErr, ok := applyResp.(error); ok && fsmErr != nil {
|
|
return index, fsmErr
|
|
}
|
|
}
|
|
return index, err
|
|
}
|
|
|
|
func (d *deploymentWatcherRaftShim) UpsertEvals(evals []*structs.Evaluation) (uint64, error) {
|
|
update := &structs.EvalUpdateRequest{
|
|
Evals: evals,
|
|
}
|
|
fsmErrIntf, index, raftErr := d.apply(structs.EvalUpdateRequestType, update)
|
|
return d.convertApplyErrors(fsmErrIntf, index, raftErr)
|
|
}
|
|
|
|
func (d *deploymentWatcherRaftShim) UpsertJob(job *structs.Job) (uint64, error) {
|
|
job.SetSubmitTime()
|
|
update := &structs.JobRegisterRequest{
|
|
Job: job,
|
|
}
|
|
fsmErrIntf, index, raftErr := d.apply(structs.JobRegisterRequestType, update)
|
|
return d.convertApplyErrors(fsmErrIntf, index, raftErr)
|
|
}
|
|
|
|
func (d *deploymentWatcherRaftShim) UpdateDeploymentStatus(u *structs.DeploymentStatusUpdateRequest) (uint64, error) {
|
|
fsmErrIntf, index, raftErr := d.apply(structs.DeploymentStatusUpdateRequestType, u)
|
|
return d.convertApplyErrors(fsmErrIntf, index, raftErr)
|
|
}
|
|
|
|
func (d *deploymentWatcherRaftShim) UpdateDeploymentPromotion(req *structs.ApplyDeploymentPromoteRequest) (uint64, error) {
|
|
fsmErrIntf, index, raftErr := d.apply(structs.DeploymentPromoteRequestType, req)
|
|
return d.convertApplyErrors(fsmErrIntf, index, raftErr)
|
|
}
|
|
|
|
func (d *deploymentWatcherRaftShim) UpdateDeploymentAllocHealth(req *structs.ApplyDeploymentAllocHealthRequest) (uint64, error) {
|
|
fsmErrIntf, index, raftErr := d.apply(structs.DeploymentAllocHealthRequestType, req)
|
|
return d.convertApplyErrors(fsmErrIntf, index, raftErr)
|
|
}
|