mirror of
https://github.com/hashicorp/vault.git
synced 2025-11-13 23:01:11 +01:00
9a980d34c7
* Two things: * Change how we populate and clear leader UUID. This fixes a case where if a standby disconnects from an active node and reconnects, without the active node restarting, the UUID doesn't change so triggers on a new active node don't get run. * Add a bunch of test helpers and minor updates to things.
121 lines
3.4 KiB
Go
121 lines
3.4 KiB
Go
package consts
|
|
|
|
import "time"
|
|
|
|
type ReplicationState uint32
|
|
|
|
var ReplicationStaleReadTimeout = 2 * time.Second
|
|
|
|
const (
|
|
_ ReplicationState = iota
|
|
OldReplicationPrimary
|
|
OldReplicationSecondary
|
|
OldReplicationBootstrapping
|
|
// Don't add anything here. Adding anything to this Old block would cause
|
|
// the rest of the values to change below. This was done originally to
|
|
// ensure no overlap between old and new values.
|
|
|
|
ReplicationUnknown ReplicationState = 0
|
|
ReplicationPerformancePrimary ReplicationState = 1 << iota // Note -- iota is 5 here!
|
|
ReplicationPerformanceSecondary
|
|
OldSplitReplicationBootstrapping
|
|
ReplicationDRPrimary
|
|
ReplicationDRSecondary
|
|
ReplicationPerformanceBootstrapping
|
|
ReplicationDRBootstrapping
|
|
ReplicationPerformanceDisabled
|
|
ReplicationDRDisabled
|
|
ReplicationPerformanceStandby
|
|
)
|
|
|
|
func (r ReplicationState) string() string {
|
|
switch r {
|
|
case ReplicationPerformanceSecondary:
|
|
return "secondary"
|
|
case ReplicationPerformancePrimary:
|
|
return "primary"
|
|
case ReplicationPerformanceBootstrapping:
|
|
return "bootstrapping"
|
|
case ReplicationPerformanceDisabled:
|
|
return "disabled"
|
|
case ReplicationDRPrimary:
|
|
return "primary"
|
|
case ReplicationDRSecondary:
|
|
return "secondary"
|
|
case ReplicationDRBootstrapping:
|
|
return "bootstrapping"
|
|
case ReplicationDRDisabled:
|
|
return "disabled"
|
|
}
|
|
|
|
return "unknown"
|
|
}
|
|
|
|
func (r ReplicationState) StateStrings() []string {
|
|
var ret []string
|
|
if r.HasState(ReplicationPerformanceSecondary) {
|
|
ret = append(ret, "perf-secondary")
|
|
}
|
|
if r.HasState(ReplicationPerformancePrimary) {
|
|
ret = append(ret, "perf-primary")
|
|
}
|
|
if r.HasState(ReplicationPerformanceBootstrapping) {
|
|
ret = append(ret, "perf-bootstrapping")
|
|
}
|
|
if r.HasState(ReplicationPerformanceDisabled) {
|
|
ret = append(ret, "perf-disabled")
|
|
}
|
|
if r.HasState(ReplicationDRPrimary) {
|
|
ret = append(ret, "dr-primary")
|
|
}
|
|
if r.HasState(ReplicationDRSecondary) {
|
|
ret = append(ret, "dr-secondary")
|
|
}
|
|
if r.HasState(ReplicationDRBootstrapping) {
|
|
ret = append(ret, "dr-bootstrapping")
|
|
}
|
|
if r.HasState(ReplicationDRDisabled) {
|
|
ret = append(ret, "dr-disabled")
|
|
}
|
|
if r.HasState(ReplicationPerformanceStandby) {
|
|
ret = append(ret, "perfstandby")
|
|
}
|
|
|
|
return ret
|
|
}
|
|
|
|
func (r ReplicationState) GetDRString() string {
|
|
switch {
|
|
case r.HasState(ReplicationDRBootstrapping):
|
|
return ReplicationDRBootstrapping.string()
|
|
case r.HasState(ReplicationDRPrimary):
|
|
return ReplicationDRPrimary.string()
|
|
case r.HasState(ReplicationDRSecondary):
|
|
return ReplicationDRSecondary.string()
|
|
case r.HasState(ReplicationDRDisabled):
|
|
return ReplicationDRDisabled.string()
|
|
default:
|
|
return "unknown"
|
|
}
|
|
}
|
|
|
|
func (r ReplicationState) GetPerformanceString() string {
|
|
switch {
|
|
case r.HasState(ReplicationPerformanceBootstrapping):
|
|
return ReplicationPerformanceBootstrapping.string()
|
|
case r.HasState(ReplicationPerformancePrimary):
|
|
return ReplicationPerformancePrimary.string()
|
|
case r.HasState(ReplicationPerformanceSecondary):
|
|
return ReplicationPerformanceSecondary.string()
|
|
case r.HasState(ReplicationPerformanceDisabled):
|
|
return ReplicationPerformanceDisabled.string()
|
|
default:
|
|
return "unknown"
|
|
}
|
|
}
|
|
|
|
func (r ReplicationState) HasState(flag ReplicationState) bool { return r&flag != 0 }
|
|
func (r *ReplicationState) AddState(flag ReplicationState) { *r |= flag }
|
|
func (r *ReplicationState) ClearState(flag ReplicationState) { *r &= ^flag }
|
|
func (r *ReplicationState) ToggleState(flag ReplicationState) { *r ^= flag }
|