SpringCloud/spring-cloud-vault
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Allow Vault standby node to pass health check.

Browse Source 
We now accept Vault standby nodes as available. Requests to standby nodes are redirected by Vault to the master node. Communication with a standby node allows using Vault without functional restrictions.

Related pull request: gh-113.
Fixes gh-112.
This commit is contained in:
Mark Paluch
2017-05-27 23:25:51 +02:00
parent c2cee8572e
commit 656587d7ad
2 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-vault-config/src/main/java/org/springframework/cloud/vault/config/VaultHealthIndicator.java
View File

@@ -21,6 +21,8 @@ import org.springframework.vault.core.VaultOperations;
import org.springframework.vault.support.VaultHealth;
/**
* Simple health indicator reporting Vault's availability.
*
* @author Stuart Ingram
* @author Mark Paluch
*/
@@ -48,8 +50,7 @@ public class VaultHealthIndicator implements HealthIndicator {
}
if (vaultHealthResponse.isStandby()) {
return Health.outOfService().withDetail("state", "Vault in standby")
.build();
return Health.up().withDetail("state", "Vault in standby").build();
}
return Health.up().build();

16
spring-cloud-vault-config/src/test/java/org/springframework/cloud/vault/config/VaultHealthIndicatorUnitTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2016 the original author or authors.
* Copyright 2016-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -51,7 +51,7 @@ public class VaultHealthIndicatorUnitTests {
VaultHealthIndicator healthIndicator;
@Before
public void before() throws Exception {
public void before() {
healthIndicator = new VaultHealthIndicator(vaultOperations);
@@ -60,7 +60,7 @@ public class VaultHealthIndicatorUnitTests {
}
@Test
public void shouldReportHealthyService() throws Exception {
public void shouldReportHealthyService() {
when(healthResponse.isInitialized()).thenReturn(true);
when(vaultOperations.opsForSys()).thenReturn(vaultSysOperations);
@@ -71,7 +71,7 @@ public class VaultHealthIndicatorUnitTests {
}
@Test
public void shouldReportSealedService() throws Exception {
public void shouldReportSealedService() {
when(healthResponse.isInitialized()).thenReturn(true);
when(healthResponse.isSealed()).thenReturn(true);
@@ -83,7 +83,7 @@ public class VaultHealthIndicatorUnitTests {
}
@Test
public void shouldReportUninitializedService() throws Exception {
public void shouldReportUninitializedService() {
Health health = healthIndicator.health();
@@ -92,19 +92,19 @@ public class VaultHealthIndicatorUnitTests {
}
@Test
public void shouldReportStandbyService() throws Exception {
public void shouldReportStandbyService() {
when(healthResponse.isInitialized()).thenReturn(true);
when(healthResponse.isStandby()).thenReturn(true);
Health health = healthIndicator.health();
assertThat(health.getStatus()).isEqualTo(Status.OUT_OF_SERVICE);
assertThat(health.getStatus()).isEqualTo(Status.UP);
assertThat(health.getDetails()).containsEntry("state", "Vault in standby");
}
@Test
public void exceptionsShouldReportDownStatus() throws Exception {
public void exceptionsShouldReportDownStatus() {
reset(vaultSysOperations);
when(vaultSysOperations.health()).thenThrow(new IllegalStateException());