124 lines
3.9 KiB
Go
124 lines
3.9 KiB
Go
// Copyright (c) HashiCorp, Inc.
|
|
// SPDX-License-Identifier: MPL-2.0
|
|
|
|
package config
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/hashicorp/nomad/helper/pointer"
|
|
)
|
|
|
|
type AutopilotConfig struct {
|
|
// CleanupDeadServers controls whether to remove dead servers when a new
|
|
// server is added to the Raft peers.
|
|
CleanupDeadServers *bool `hcl:"cleanup_dead_servers"`
|
|
|
|
// ServerStabilizationTime is the minimum amount of time a server must be
|
|
// in a stable, healthy state before it can be added to the cluster. Only
|
|
// applicable with Raft protocol version 3 or higher.
|
|
ServerStabilizationTime time.Duration
|
|
ServerStabilizationTimeHCL string `hcl:"server_stabilization_time" json:"-"`
|
|
|
|
// LastContactThreshold is the limit on the amount of time a server can go
|
|
// without leader contact before being considered unhealthy.
|
|
LastContactThreshold time.Duration
|
|
LastContactThresholdHCL string `hcl:"last_contact_threshold" json:"-"`
|
|
|
|
// MaxTrailingLogs is the amount of entries in the Raft Log that a server can
|
|
// be behind before being considered unhealthy.
|
|
MaxTrailingLogs int `hcl:"max_trailing_logs"`
|
|
|
|
// MinQuorum sets the minimum number of servers required in a cluster
|
|
// before autopilot can prune dead servers.
|
|
MinQuorum int `hcl:"min_quorum"`
|
|
|
|
// (Enterprise-only) EnableRedundancyZones specifies whether to enable redundancy zones.
|
|
EnableRedundancyZones *bool `hcl:"enable_redundancy_zones"`
|
|
|
|
// (Enterprise-only) DisableUpgradeMigration will disable Autopilot's upgrade migration
|
|
// strategy of waiting until enough newer-versioned servers have been added to the
|
|
// cluster before promoting them to voters.
|
|
DisableUpgradeMigration *bool `hcl:"disable_upgrade_migration"`
|
|
|
|
// (Enterprise-only) EnableCustomUpgrades specifies whether to enable using custom
|
|
// upgrade versions when performing migrations.
|
|
EnableCustomUpgrades *bool `hcl:"enable_custom_upgrades"`
|
|
|
|
// ExtraKeysHCL is used by hcl to surface unexpected keys
|
|
ExtraKeysHCL []string `hcl:",unusedKeys" json:"-"`
|
|
}
|
|
|
|
// DefaultAutopilotConfig returns the canonical defaults for the Nomad
|
|
// `autopilot` configuration.
|
|
func DefaultAutopilotConfig() *AutopilotConfig {
|
|
return &AutopilotConfig{
|
|
LastContactThreshold: 200 * time.Millisecond,
|
|
MaxTrailingLogs: 250,
|
|
ServerStabilizationTime: 10 * time.Second,
|
|
}
|
|
}
|
|
|
|
func (a *AutopilotConfig) Merge(b *AutopilotConfig) *AutopilotConfig {
|
|
result := a.Copy()
|
|
|
|
if b.CleanupDeadServers != nil {
|
|
result.CleanupDeadServers = pointer.Of(*b.CleanupDeadServers)
|
|
}
|
|
if b.ServerStabilizationTime != 0 {
|
|
result.ServerStabilizationTime = b.ServerStabilizationTime
|
|
}
|
|
if b.ServerStabilizationTimeHCL != "" {
|
|
result.ServerStabilizationTimeHCL = b.ServerStabilizationTimeHCL
|
|
}
|
|
if b.LastContactThreshold != 0 {
|
|
result.LastContactThreshold = b.LastContactThreshold
|
|
}
|
|
if b.LastContactThresholdHCL != "" {
|
|
result.LastContactThresholdHCL = b.LastContactThresholdHCL
|
|
}
|
|
if b.MaxTrailingLogs != 0 {
|
|
result.MaxTrailingLogs = b.MaxTrailingLogs
|
|
}
|
|
if b.MinQuorum != 0 {
|
|
result.MinQuorum = b.MinQuorum
|
|
}
|
|
if b.EnableRedundancyZones != nil {
|
|
result.EnableRedundancyZones = b.EnableRedundancyZones
|
|
}
|
|
if b.DisableUpgradeMigration != nil {
|
|
result.DisableUpgradeMigration = pointer.Of(*b.DisableUpgradeMigration)
|
|
}
|
|
if b.EnableCustomUpgrades != nil {
|
|
result.EnableCustomUpgrades = b.EnableCustomUpgrades
|
|
}
|
|
|
|
return result
|
|
}
|
|
|
|
// Copy returns a copy of this Autopilot config.
|
|
func (a *AutopilotConfig) Copy() *AutopilotConfig {
|
|
if a == nil {
|
|
return nil
|
|
}
|
|
|
|
nc := new(AutopilotConfig)
|
|
*nc = *a
|
|
|
|
// Copy the bools
|
|
if a.CleanupDeadServers != nil {
|
|
nc.CleanupDeadServers = pointer.Of(*a.CleanupDeadServers)
|
|
}
|
|
if a.EnableRedundancyZones != nil {
|
|
nc.EnableRedundancyZones = pointer.Of(*a.EnableRedundancyZones)
|
|
}
|
|
if a.DisableUpgradeMigration != nil {
|
|
nc.DisableUpgradeMigration = pointer.Of(*a.DisableUpgradeMigration)
|
|
}
|
|
if a.EnableCustomUpgrades != nil {
|
|
nc.EnableCustomUpgrades = pointer.Of(*a.EnableCustomUpgrades)
|
|
}
|
|
|
|
return nc
|
|
}
|