deploymentwatcher

Jul 26, 2017

Changes in this version

+ const CrossDeploymentEvalBatchDuration

+ const LimitStateQueriesPerSecond

+ type DeploymentRaftEndpoints interface

+ UpdateDeploymentAllocHealth func(req *structs.ApplyDeploymentAllocHealthRequest) (uint64, error)

+ UpdateDeploymentPromotion func(req *structs.ApplyDeploymentPromoteRequest) (uint64, error)

+ UpdateDeploymentStatus func(u *structs.DeploymentStatusUpdateRequest) (uint64, error)

+ UpsertEvals func([]*structs.Evaluation) (uint64, error)

+ UpsertJob func(job *structs.Job) (uint64, error)

+ type DeploymentStateWatchers interface

+ Allocations func(args *structs.DeploymentSpecificRequest, reply *structs.AllocListResponse) error

+ Evaluations func(args *structs.JobSpecificRequest, reply *structs.JobEvaluationsResponse) error

+ GetDeployment func(args *structs.DeploymentSpecificRequest, ...) error

+ GetJob func(args *structs.JobSpecificRequest, reply *structs.SingleJobResponse) error

+ GetJobVersions func(args *structs.JobVersionsRequest, reply *structs.JobVersionsResponse) error

+ List func(args *structs.DeploymentListRequest, reply *structs.DeploymentListResponse) error

+ type EvalBatcher struct

+ func NewEvalBatcher(batchDuration time.Duration, raft DeploymentRaftEndpoints, ctx context.Context) *EvalBatcher

+ func (b *EvalBatcher) CreateEval(e *structs.Evaluation) *EvalFuture

+ type EvalFuture struct

+ func NewEvalFuture() *EvalFuture

+ func (f *EvalFuture) Results() (uint64, error)

+ func (f *EvalFuture) Set(index uint64, err error)

+ type Watcher struct

+ func NewDeploymentsWatcher(logger *log.Logger, watchers DeploymentStateWatchers, ...) *Watcher

+ func (w *Watcher) FailDeployment(req *structs.DeploymentFailRequest, resp *structs.DeploymentUpdateResponse) error

+ func (w *Watcher) PauseDeployment(req *structs.DeploymentPauseRequest, resp *structs.DeploymentUpdateResponse) error

+ func (w *Watcher) PromoteDeployment(req *structs.DeploymentPromoteRequest, resp *structs.DeploymentUpdateResponse) error

+ func (w *Watcher) SetAllocHealth(req *structs.DeploymentAllocHealthRequest, ...) error

+ func (w *Watcher) SetEnabled(enabled bool) error