Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 2018 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 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, raft DeploymentRaftEndpoints, ...) *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, state *state.StateStore)
Go to main page