Skip to content

Commit

Permalink
OSS changes for new update-primary API endpoint (hashicorp#20277)
Browse files Browse the repository at this point in the history
* OSS changes for new update-primary API endpoint

* remove ENT specific piece

* remove another ENT specific field
  • Loading branch information
raskchanky committed Apr 20, 2023
1 parent c94e213 commit d51ae03
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 8 deletions.
4 changes: 4 additions & 0 deletions sdk/helper/consts/consts.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,4 +39,8 @@ const (
VaultEnableFilePermissionsCheckEnv = "VAULT_ENABLE_FILE_PERMISSIONS_CHECK"

VaultDisableUserLockout = "VAULT_DISABLE_USER_LOCKOUT"

PerformanceReplicationPathTarget = "performance"

DRReplicationPathParget = "dr"
)
8 changes: 0 additions & 8 deletions vault/core.go
Original file line number Diff line number Diff line change
Expand Up @@ -517,12 +517,6 @@ type Core struct {
// CORS Information
corsConfig *CORSConfig

// The active set of upstream cluster addresses; stored via the Echo
// mechanism, loaded by the balancer
atomicPrimaryClusterAddrs *atomic.Value

atomicPrimaryFailoverAddrs *atomic.Value

// replicationState keeps the current replication state cached for quick
// lookup; activeNodeReplicationState stores the active value on standbys
replicationState *uint32
Expand Down Expand Up @@ -990,8 +984,6 @@ func CreateCore(conf *CoreConfig) (*Core, error) {
introspectionEnabled: conf.EnableIntrospection,
shutdownDoneCh: new(atomic.Value),
replicationState: new(uint32),
atomicPrimaryClusterAddrs: new(atomic.Value),
atomicPrimaryFailoverAddrs: new(atomic.Value),
localClusterPrivateKey: new(atomic.Value),
localClusterCert: new(atomic.Value),
localClusterParsedCert: new(atomic.Value),
Expand Down
8 changes: 8 additions & 0 deletions vault/testing.go
Original file line number Diff line number Diff line change
Expand Up @@ -971,6 +971,10 @@ func (c *TestClusterCore) Seal(t testing.T) {
}
}

func (c *TestClusterCore) LogicalStorage() logical.Storage {
return c.barrier
}

func (c *TestClusterCore) stop() error {
c.Logger().Info("stopping vault test core")

Expand Down Expand Up @@ -1025,6 +1029,10 @@ func (c *TestClusterCore) TLSConfig() *tls.Config {
return c.tlsConfig.Clone()
}

func (c *TestClusterCore) ClusterListener() *cluster.Listener {
return c.getClusterListener()
}

func (c *TestCluster) Cleanup() {
c.Logger.Info("cleaning up vault cluster")
if tl, ok := c.Logger.(*corehelpers.TestLogger); ok {
Expand Down

0 comments on commit d51ae03

Please sign in to comment.