3e55e79a3f
* k8s doc: update for 0.9.1 and 0.8.0 releases (#10825) * k8s doc: update for 0.9.1 and 0.8.0 releases * Update website/content/docs/platform/k8s/helm/configuration.mdx Co-authored-by: Theron Voran <tvoran@users.noreply.github.com> Co-authored-by: Theron Voran <tvoran@users.noreply.github.com> * Autopilot initial commit * Move autopilot related backend implementations to its own file * Abstract promoter creation * Add nil check for health * Add server state oss no-ops * Config ext stub for oss * Make way for non-voters * s/health/state * s/ReadReplica/NonVoter * Add synopsis and description * Remove struct tags from AutopilotConfig * Use var for config storage path * Handle nin-config when reading * Enable testing autopilot by using inmem cluster * First passing test * Only report the server as known if it is present in raft config * Autopilot defaults to on for all existing and new clusters * Add locking to some functions * Persist initial config * Clarify the command usage doc * Add health metric for each node * Fix audit logging issue * Don't set DisablePerformanceStandby to true in test * Use node id label for health metric * Log updates to autopilot config * Less aggressively consume config loading failures * Return a mutable config * Return early from known servers if raft config is unable to be pulled * Update metrics name * Reduce log level for potentially noisy log * Add knob to disable autopilot * Don't persist if default config is in use * Autopilot: Dead server cleanup (#10857) * Dead server cleanup * Initialize channel in any case * Fix a bunch of tests * Fix panic * Add follower locking in heartbeat tracker * Add LastContactFailureThreshold to config * Add log when marking node as dead * Update follower state locking in heartbeat tracker * Avoid follower states being nil * Pull test to its own file * Add execution status to state response * Optionally enable autopilot in some tests * Updates * Added API function to fetch autopilot configuration * Add test for default autopilot configuration * Configuration tests * Add State API test * Update test * Added TestClusterOptions.PhysicalFactoryConfig * Update locking * Adjust locking in heartbeat tracker * s/last_contact_failure_threshold/left_server_last_contact_threshold * Add disabling autopilot as a core config option * Disable autopilot in some tests * s/left_server_last_contact_threshold/dead_server_last_contact_threshold * Set the lastheartbeat of followers to now when setting up active node * Don't use config defaults from CLI command * Remove config file support * Remove HCL test as well * Persist only supplied config; merge supplied config with default to operate * Use pointer to structs for storing follower information * Test update * Retrieve non voter status from configbucket and set it up when a node comes up * Manage desired suffrage * Consider bucket being created already * Move desired suffrage to its own entry * s/DesiredSuffrageKey/LocalNodeConfigKey * s/witnessSuffrage/recordSuffrage * Fix test compilation * Handle local node config post a snapshot install * Commit to storage first; then record suffrage in fsm * No need of local node config being nili case, post snapshot restore * Reconcile autopilot config when a new leader takes over duty * Grab fsm lock when recording suffrage * s/Suffrage/DesiredSuffrage in FollowerState * Instantiate autopilot only in leader * Default to old ways in more scenarios * Make API gracefully handle 404 * Address some feedback * Make IsDead an atomic.Value * Simplify follower hearbeat tracking * Use uber.atomic * Don't have multiple causes for having autopilot disabled * Don't remove node from follower states if we fail to remove the dead server * Autopilot server removals map (#11019) * Don't remove node from follower states if we fail to remove the dead server * Use map to track dead server removals * Use lock and map * Use delegate lock * Adjust when to remove entry from map * Only hold the lock while accessing map * Fix race * Don't set default min_quorum * Fix test * Ensure follower states is not nil before starting autopilot * Fix race Co-authored-by: Jason O'Donnell <2160810+jasonodonnell@users.noreply.github.com> Co-authored-by: Theron Voran <tvoran@users.noreply.github.com>
64 lines
1.5 KiB
Protocol Buffer
64 lines
1.5 KiB
Protocol Buffer
syntax = "proto3";
|
|
|
|
option go_package = "github.com/hashicorp/vault/vault";
|
|
|
|
import "helper/forwarding/types.proto";
|
|
|
|
package vault;
|
|
|
|
message EchoRequest {
|
|
string message = 1;
|
|
// ClusterAddr is used to send up a standby node's address to the active
|
|
// node upon heartbeat
|
|
string cluster_addr = 2;
|
|
// ClusterAddrs is used to send up a list of cluster addresses to a dr
|
|
// primary from a dr secondary
|
|
repeated string cluster_addrs = 3;
|
|
|
|
uint64 raft_applied_index = 4;
|
|
string raft_node_id = 5;
|
|
NodeInformation node_info = 6;
|
|
uint64 raft_term = 7;
|
|
string raft_desired_suffrage = 8;
|
|
}
|
|
|
|
message EchoReply {
|
|
string message = 1;
|
|
repeated string cluster_addrs = 2;
|
|
uint32 replication_state = 3;
|
|
uint64 raft_applied_index = 4;
|
|
string raft_node_id = 5;
|
|
NodeInformation node_info = 6;
|
|
}
|
|
|
|
message NodeInformation {
|
|
string cluster_addr = 1;
|
|
string api_addr = 2;
|
|
string mode = 3;
|
|
string node_id = 4;
|
|
uint32 replication_state = 5;
|
|
}
|
|
|
|
message ClientKey {
|
|
string type = 1;
|
|
bytes x = 2;
|
|
bytes y = 3;
|
|
bytes d = 4;
|
|
}
|
|
|
|
message PerfStandbyElectionInput {}
|
|
message PerfStandbyElectionResponse {
|
|
string id = 1;
|
|
string cluster_id = 2;
|
|
string primary_cluster_addr = 3;
|
|
bytes ca_cert = 4;
|
|
bytes client_cert = 5;
|
|
ClientKey client_key = 6;
|
|
}
|
|
|
|
service RequestForwarding {
|
|
rpc ForwardRequest(forwarding.Request) returns (forwarding.Response) {}
|
|
rpc Echo(EchoRequest) returns (EchoReply) {}
|
|
rpc PerformanceStandbyElectionRequest(PerfStandbyElectionInput) returns (stream PerfStandbyElectionResponse) {}
|
|
}
|