Module de.stklcode.jvault.connector

Package de.stklcode.jvault.connector

Class HTTPVaultConnector

java.lang.Object

de.stklcode.jvault.connector.HTTPVaultConnector

All Implemented Interfaces:

VaultConnector, Serializable, AutoCloseable

public class HTTPVaultConnector
extends Object
implements VaultConnector

Vault Connector implementation using Vault's HTTP API.

Since:

0.1

Author:

Stefan Kalscheuer

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
final AuthResponse	authAppRole(String roleID, String secretID)	Authorize to Vault using AppRole method.
final TokenResponse	authToken(String token)	Authorize to Vault using token.
final AuthResponse	authUserPass(String username, String password)	Authorize to Vault using username and password.
static HTTPVaultConnectorBuilder	builder()	Get a new builder for a connector.
static HTTPVaultConnectorBuilder	builder(String baseURL)	Get a new builder for a connector.
static HTTPVaultConnectorBuilder	builder(URI baseURL)	Get a new builder for a connector.
final void	close()
final boolean	createAppRole(AppRole role)	Register a new AppRole role from given metamodel.
final AppRoleSecretResponse	createAppRoleSecret(String roleName, AppRoleSecret secret)	Register new AppRole secret with custom ID.
boolean	createOrUpdateTokenRole(String name, TokenRole role)	Create a new or update an existing token role.
final AuthResponse	createToken(Token token)	Create a new token.
final AuthResponse	createToken(Token token, boolean orphan)	Create a new token.
final AuthResponse	createToken(Token token, String role)	Create a new token for specific role.
final void	delete(String key)	Delete key from Vault.
final void	deleteAllSecretVersions(String mount, String key)	Delete latest version of a secret from Vault.
final boolean	deleteAppRole(String roleName)	Delete AppRole role from Vault.
final void	deleteLatestSecretVersion(String mount, String key)	Delete latest version of a secret from Vault.
final void	deleteSecretVersions(String mount, String key, int... versions)	Delete secret versions from Vault.
boolean	deleteTokenRole(String name)	Delete a token role.
final boolean	destroyAppRoleSecret(String roleName, String secretID)	Destroy an AppRole secret.
final void	destroySecretVersions(String mount, String key, int... versions)	Destroy secret versions from Vault.
final String	getAppRoleID(String roleName)	Retrieve ID for an AppRole role.
final List<AuthBackend>	getAuthBackends()	Get all available authentication backends.
HealthResponse	getHealth()	Query server health information.
final boolean	isAuthorized()	Get authorization status.
final List<String>	list(String path)	List available nodes from Vault.
final List<String>	listAppRoles()	List existing (accessible) AppRole roles.
final List<String>	listAppRoleSecrets(String roleName)	List existing (accessible) secret IDs for AppRole role.
List<String>	listTokenRoles()	List available token roles from Vault.
final AppRoleResponse	lookupAppRole(String roleName)	Lookup an AppRole role.
final AppRoleSecretResponse	lookupAppRoleSecret(String roleName, String secretID)	Lookup an AppRole secret.
final TokenResponse	lookupToken(String token)	Lookup token information.
final SecretResponse	read(String key)	Retrieve any nodes content from Vault.
final MetadataResponse	readSecretMetadata(String mount, String key)	Retrieve secret metadata from Vault.
final SecretResponse	readSecretVersion(String mount, String key, Integer version)	Retrieve secret data from Vault.
TokenRoleResponse	readTokenRole(String name)	Lookup token information.
final SecretResponse	renew(String leaseID, Integer increment)	Renew lease with given ID.
final void	resetAuth()	Reset authorization information.
final void	revoke(String leaseID)	Revoke given lease immediately.
final void	seal()	Seal vault.
final SealResponse	sealStatus()	Retrieve status of vault seal.
final boolean	setAppRoleID(String roleName, String roleID)	Set custom ID for an AppRole role.
final void	undeleteSecretVersions(String mount, String key, int... versions)	Undelete (restore) secret versions from Vault.
final SealResponse	unseal(String key, Boolean reset)	Unseal vault.
void	updateSecretMetadata(String mount, String key, Integer maxVersions, boolean casRequired)	Update secret metadata.
final void	write(String key, Map<String,Object> data, Map<String,Object> options)	Write value to Vault.
final SecretVersionResponse	writeSecretData(String mount, String key, Map<String,Object> data, Integer cas)	Write secret to Vault.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface de.stklcode.jvault.connector.VaultConnector

authAppRole, createAppRole, createAppRole, createAppRole, createAppRole, createAppRoleSecret, createAppRoleSecret, createOrUpdateTokenRole, readDbCredentials, readMongoDbCredentials, readMsSqlCredentials, readMySqlCredentials, readPostgreSqlCredentials, readSecretData, renew, unseal, write, write, writeSecretData

Method Details

builder

public static HTTPVaultConnectorBuilder builder()

Get a new builder for a connector.

Returns:

Builder instance.

Since:

0.9.5

builder

public static HTTPVaultConnectorBuilder builder(String baseURL)
                                         throws URISyntaxException

Get a new builder for a connector.

Parameters:

baseURL - Base URL.

Returns:

Builder instance.

Throws:

URISyntaxException - Invalid URI syntax.

Since:

1.0

builder

public static HTTPVaultConnectorBuilder builder(URI baseURL)

Get a new builder for a connector.

Parameters:

baseURL - Base URL.

Returns:

Builder instance.

Since:

1.0

resetAuth

public final void resetAuth()

Description copied from interface: VaultConnector

Reset authorization information.

Specified by:

resetAuth in interface VaultConnector

sealStatus

public final SealResponse sealStatus()
                              throws VaultConnectorException

Description copied from interface: VaultConnector

Retrieve status of vault seal.

Specified by:

sealStatus in interface VaultConnector

Returns:

Seal status

Throws:

VaultConnectorException - on error

seal

public final void seal()
                throws VaultConnectorException

Description copied from interface: VaultConnector

Seal vault.

Specified by:

seal in interface VaultConnector

Throws:

VaultConnectorException - on error

unseal

public final SealResponse unseal(String key,
 Boolean reset)
                          throws VaultConnectorException

Description copied from interface: VaultConnector

Unseal vault.

Specified by:

unseal in interface VaultConnector

Parameters:

key - A single master share key

reset - Discard previously provided keys (optional)

Returns:

Response with seal status

Throws:

VaultConnectorException - on error

getHealth

public HealthResponse getHealth()
                         throws VaultConnectorException

Description copied from interface: VaultConnector

Query server health information.

Specified by:

getHealth in interface VaultConnector

Returns:

Health information.

Throws:

VaultConnectorException - on error

isAuthorized

public final boolean isAuthorized()

Description copied from interface: VaultConnector

Get authorization status.

Specified by:

isAuthorized in interface VaultConnector

Returns:

TRUE, if successfully authorized

getAuthBackends

public final List<AuthBackend> getAuthBackends()
                                        throws VaultConnectorException

Description copied from interface: VaultConnector

Get all available authentication backends.

Specified by:

getAuthBackends in interface VaultConnector

Returns:

List of backends

Throws:

VaultConnectorException - on error

authToken

public final TokenResponse authToken(String token)
                              throws VaultConnectorException

Description copied from interface: VaultConnector

Authorize to Vault using token.

Specified by:

authToken in interface VaultConnector

Parameters:

token - The token

Returns:

Token response

Throws:

VaultConnectorException - on error

authUserPass

public final AuthResponse authUserPass(String username,
 String password)
                                throws VaultConnectorException

Description copied from interface: VaultConnector

Authorize to Vault using username and password.

Specified by:

authUserPass in interface VaultConnector

Parameters:

username - The username

password - The password

Returns:

Authorization result

Throws:

VaultConnectorException - on error

authAppRole

public final AuthResponse authAppRole(String roleID,
 String secretID)
                               throws VaultConnectorException

Description copied from interface: VaultConnector

Authorize to Vault using AppRole method.

Specified by:

authAppRole in interface VaultConnector

Parameters:

roleID - The role ID

secretID - The secret ID

Returns:

The AuthResponse

Throws:

VaultConnectorException - on error

createAppRole

public final boolean createAppRole(AppRole role)
                            throws VaultConnectorException

Description copied from interface: VaultConnector

Register a new AppRole role from given metamodel.

Specified by:

createAppRole in interface VaultConnector

Parameters:

role - The role

Returns:

true on success

Throws:

VaultConnectorException - on error

lookupAppRole

public final AppRoleResponse lookupAppRole(String roleName)
                                    throws VaultConnectorException

Description copied from interface: VaultConnector

Lookup an AppRole role.

Specified by:

lookupAppRole in interface VaultConnector

Parameters:

roleName - The role name

Returns:

Result of the lookup

Throws:

VaultConnectorException - on error

deleteAppRole

public final boolean deleteAppRole(String roleName)
                            throws VaultConnectorException

Description copied from interface: VaultConnector

Delete AppRole role from Vault.

Specified by:

deleteAppRole in interface VaultConnector

Parameters:

roleName - The role name

Returns:

true on success

Throws:

VaultConnectorException - on error

getAppRoleID

public final String getAppRoleID(String roleName)
                          throws VaultConnectorException

Description copied from interface: VaultConnector

Retrieve ID for an AppRole role.

Specified by:

getAppRoleID in interface VaultConnector

Parameters:

roleName - The role name

Returns:

The role ID

Throws:

VaultConnectorException - on error

setAppRoleID

public final boolean setAppRoleID(String roleName,
 String roleID)
                           throws VaultConnectorException

Description copied from interface: VaultConnector

Set custom ID for an AppRole role.

Specified by:

setAppRoleID in interface VaultConnector

Parameters:

roleName - The role name

roleID - The role ID

Returns:

true on success

Throws:

VaultConnectorException - on error

createAppRoleSecret

public final AppRoleSecretResponse createAppRoleSecret(String roleName,
 AppRoleSecret secret)
                                                throws VaultConnectorException

Description copied from interface: VaultConnector

Register new AppRole secret with custom ID.

Specified by:

createAppRoleSecret in interface VaultConnector

Parameters:

roleName - The role name

secret - The secret meta object

Returns:

The secret ID

Throws:

VaultConnectorException - on error

lookupAppRoleSecret

public final AppRoleSecretResponse lookupAppRoleSecret(String roleName,
 String secretID)
                                                throws VaultConnectorException

Description copied from interface: VaultConnector

Lookup an AppRole secret.

Specified by:

lookupAppRoleSecret in interface VaultConnector

Parameters:

roleName - The role name

secretID - The secret ID

Returns:

Result of the lookup

Throws:

VaultConnectorException - on error

destroyAppRoleSecret

public final boolean destroyAppRoleSecret(String roleName,
 String secretID)
                                   throws VaultConnectorException

Description copied from interface: VaultConnector

Destroy an AppRole secret.

Specified by:

destroyAppRoleSecret in interface VaultConnector

Parameters:

roleName - The role name

secretID - The secret meta object

Returns:

The secret ID

Throws:

VaultConnectorException - on error

listAppRoles

public final List<String> listAppRoles()
                                throws VaultConnectorException

Description copied from interface: VaultConnector

List existing (accessible) AppRole roles.

Specified by:

listAppRoles in interface VaultConnector

Returns:

List of roles

Throws:

VaultConnectorException - on error

listAppRoleSecrets

public final List<String> listAppRoleSecrets(String roleName)
                                      throws VaultConnectorException

Description copied from interface: VaultConnector

List existing (accessible) secret IDs for AppRole role.

Specified by:

listAppRoleSecrets in interface VaultConnector

Parameters:

roleName - The role name

Returns:

List of roles

Throws:

VaultConnectorException - on error

read

public final SecretResponse read(String key)
                          throws VaultConnectorException

Description copied from interface: VaultConnector

Retrieve any nodes content from Vault.

Specified by:

read in interface VaultConnector

Parameters:

key - Secret identifier

Returns:

Secret response

Throws:

VaultConnectorException - on error

readSecretVersion

public final SecretResponse readSecretVersion(String mount,
 String key,
 Integer version)
                                       throws VaultConnectorException

Description copied from interface: VaultConnector

Retrieve secret data from Vault.
Path <mount>/data/<key> is read here. Only available for KV v2 secrets.

Specified by:

readSecretVersion in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret identifier

version - Version to read. If null or zero, the latest version will be returned.

Returns:

Secret response.

Throws:

VaultConnectorException - on error

readSecretMetadata

public final MetadataResponse readSecretMetadata(String mount,
 String key)
                                          throws VaultConnectorException

Description copied from interface: VaultConnector

Retrieve secret metadata from Vault.
Path <mount>/metadata/<key> is read here. Only available for KV v2 secrets.

Specified by:

readSecretMetadata in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret identifier

Returns:

Metadata response

Throws:

VaultConnectorException - on error

updateSecretMetadata

public void updateSecretMetadata(String mount,
 String key,
 Integer maxVersions,
 boolean casRequired)
                          throws VaultConnectorException

Description copied from interface: VaultConnector

Update secret metadata.
Path <mount>/metadata/<key> is written here. Only available for KV v2 secrets.

Specified by:

updateSecretMetadata in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret identifier

maxVersions - Maximum number of versions (fallback to backend default if null)

casRequired - Specify if Check-And-Set is required for this secret.

Throws:

VaultConnectorException - on error

writeSecretData

public final SecretVersionResponse writeSecretData(String mount,
 String key,
 Map<String,Object> data,
 Integer cas)
                                            throws VaultConnectorException

Description copied from interface: VaultConnector

Write secret to Vault.
Path <mount>/data/<key> is written here. Only available for KV v2 secrets.

Specified by:

writeSecretData in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret identifier

data - Secret content. Value must be be JSON serializable.

cas - Use Check-And-Set operation, i.e. only allow writing if current version matches this value.

Returns:

Metadata for the created/updated secret.

Throws:

VaultConnectorException - on error

list

public final List<String> list(String path)
                        throws VaultConnectorException

Description copied from interface: VaultConnector

List available nodes from Vault.

Specified by:

list in interface VaultConnector

Parameters:

path - Root path to search

Returns:

List of secret keys

Throws:

VaultConnectorException - on error

write

public final void write(String key,
 Map<String,Object> data,
 Map<String,Object> options)
                 throws VaultConnectorException

Description copied from interface: VaultConnector

Write value to Vault.

Specified by:

write in interface VaultConnector

Parameters:

key - Secret path

data - Secret content. Value must be be JSON serializable.

options - Secret options (optional).

Throws:

VaultConnectorException - on error

delete

public final void delete(String key)
                  throws VaultConnectorException

Description copied from interface: VaultConnector

Delete key from Vault.

Specified by:

delete in interface VaultConnector

Parameters:

key - Secret path

Throws:

VaultConnectorException - on error

deleteLatestSecretVersion

public final void deleteLatestSecretVersion(String mount,
 String key)
                                     throws VaultConnectorException

Description copied from interface: VaultConnector

Delete latest version of a secret from Vault.
Only available for KV v2 stores.

Specified by:

deleteLatestSecretVersion in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret path.

Throws:

VaultConnectorException - on error

deleteAllSecretVersions

public final void deleteAllSecretVersions(String mount,
 String key)
                                   throws VaultConnectorException

Description copied from interface: VaultConnector

Delete latest version of a secret from Vault.
Prefix secret/ is automatically added to path. Only available for KV v2 stores.

Specified by:

deleteAllSecretVersions in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret path.

Throws:

VaultConnectorException - on error

deleteSecretVersions

public final void deleteSecretVersions(String mount,
 String key,
 int... versions)
                                throws VaultConnectorException

Description copied from interface: VaultConnector

Delete secret versions from Vault.
Only available for KV v2 stores.

Specified by:

deleteSecretVersions in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret path.

versions - Versions of the secret to delete.

Throws:

VaultConnectorException - on error

undeleteSecretVersions

public final void undeleteSecretVersions(String mount,
 String key,
 int... versions)
                                  throws VaultConnectorException

Description copied from interface: VaultConnector

Undelete (restore) secret versions from Vault. Only available for KV v2 stores.

Specified by:

undeleteSecretVersions in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret path.

versions - Versions of the secret to undelete.

Throws:

VaultConnectorException - on error

destroySecretVersions

public final void destroySecretVersions(String mount,
 String key,
 int... versions)
                                 throws VaultConnectorException

Description copied from interface: VaultConnector

Destroy secret versions from Vault. Only available for KV v2 stores.

Specified by:

destroySecretVersions in interface VaultConnector

Parameters:

mount - Secret store mount point (without leading or trailing slash).

key - Secret path.

versions - Versions of the secret to destroy.

Throws:

VaultConnectorException - on error

revoke

public final void revoke(String leaseID)
                  throws VaultConnectorException

Description copied from interface: VaultConnector

Revoke given lease immediately.

Specified by:

revoke in interface VaultConnector

Parameters:

leaseID - the lease ID

Throws:

VaultConnectorException - on error

renew

public final SecretResponse renew(String leaseID,
 Integer increment)
                           throws VaultConnectorException

Description copied from interface: VaultConnector

Renew lease with given ID.

Specified by:

renew in interface VaultConnector

Parameters:

leaseID - the lase ID

increment - number of seconds to extend lease time

Returns:

Renewed lease

Throws:

VaultConnectorException - on error

createToken

public final AuthResponse createToken(Token token)
                               throws VaultConnectorException

Description copied from interface: VaultConnector

Create a new token.

Specified by:

createToken in interface VaultConnector

Parameters:

token - the token

Returns:

the result response

Throws:

VaultConnectorException - on error

createToken

public final AuthResponse createToken(Token token,
 boolean orphan)
                               throws VaultConnectorException

Description copied from interface: VaultConnector

Create a new token.

Specified by:

createToken in interface VaultConnector

Parameters:

token - the token

orphan - create orphan token

Returns:

the result response

Throws:

VaultConnectorException - on error

createToken

public final AuthResponse createToken(Token token,
 String role)
                               throws VaultConnectorException

Description copied from interface: VaultConnector

Create a new token for specific role.

Specified by:

createToken in interface VaultConnector

Parameters:

token - the token

role - the role name

Returns:

the result response

Throws:

VaultConnectorException - on error

close

public final void close()

Specified by:

close in interface AutoCloseable

lookupToken

public final TokenResponse lookupToken(String token)
                                throws VaultConnectorException

Description copied from interface: VaultConnector

Lookup token information.

Specified by:

lookupToken in interface VaultConnector

Parameters:

token - the token

Returns:

the result response

Throws:

VaultConnectorException - on error

createOrUpdateTokenRole

public boolean createOrUpdateTokenRole(String name,
 TokenRole role)
                                throws VaultConnectorException

Description copied from interface: VaultConnector

Create a new or update an existing token role.

Specified by:

createOrUpdateTokenRole in interface VaultConnector

Parameters:

name - the role name (overrides name possibly set in role entity)

role - the role entity

Returns:

true on success

Throws:

VaultConnectorException - on error

readTokenRole

public TokenRoleResponse readTokenRole(String name)
                                throws VaultConnectorException

Description copied from interface: VaultConnector

Lookup token information.

Specified by:

readTokenRole in interface VaultConnector

Parameters:

name - the role name

Returns:

the result response

Throws:

VaultConnectorException - on error

listTokenRoles

public List<String> listTokenRoles()
                            throws VaultConnectorException

Description copied from interface: VaultConnector

List available token roles from Vault.

Specified by:

listTokenRoles in interface VaultConnector

Returns:

List of token roles

Throws:

VaultConnectorException - on error

deleteTokenRole

public boolean deleteTokenRole(String name)
                        throws VaultConnectorException

Description copied from interface: VaultConnector

Delete a token role.

Specified by:

deleteTokenRole in interface VaultConnector

Parameters:

name - the role name to delete

Returns:

true on success

Throws:

VaultConnectorException - on error