org.springframework.vault.core

Class ReactiveVaultTemplate

java.lang.Object

org.springframework.vault.core.ReactiveVaultTemplate

All Implemented Interfaces:

ReactiveVaultOperations

public class ReactiveVaultTemplate
extends Object
implements ReactiveVaultOperations

This class encapsulates main Vault interaction. ReactiveVaultTemplate will log into Vault on initialization and use the token throughout the whole lifetime.

Since:

2.0

Author:

Mark Paluch

See Also:

SessionManager

Constructor Summary

Constructors

Constructor and Description
ReactiveVaultTemplate(VaultEndpoint vaultEndpoint, ClientHttpConnector connector, VaultTokenSupplier vaultTokenSupplier) Create a new ReactiveVaultTemplate with a VaultEndpoint, ClientHttpConnector and VaultTokenSupplier.
ReactiveVaultTemplate(VaultEndpointProvider endpointProvider, ClientHttpConnector connector, VaultTokenSupplier vaultTokenSupplier) Create a new ReactiveVaultTemplate with a VaultEndpointProvider, ClientHttpConnector and VaultTokenSupplier.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<Void>	delete(String path) Delete a path.
protected WebClient	doCreateSessionWebClient(VaultEndpointProvider endpointProvider, ClientHttpConnector connector) Create a session-bound WebClient to be used by VaultTemplate for Vault communication given VaultEndpointProvider and ClientHttpConnector for calls that require an authenticated context.
protected WebClient	doCreateWebClient(VaultEndpointProvider endpointProvider, ClientHttpConnector connector) Create a WebClient to be used by ReactiveVaultTemplate for Vault communication given VaultEndpointProvider and ClientHttpConnector.
<V,T extends org.reactivestreams.Publisher<V>> T	doWithSession(Function<WebClient,? extends T> sessionCallback) Executes a Vault RestOperationsCallback.
<V,T extends org.reactivestreams.Publisher<V>> T	doWithVault(Function<WebClient,? extends T> clientCallback) Executes a Vault RestOperationsCallback.
reactor.core.publisher.Flux<String>	list(String path) Enumerate keys from a Vault path.
reactor.core.publisher.Mono<VaultResponse>	read(String path) Read from a Vault path.
<T> reactor.core.publisher.Mono<VaultResponseSupport<T>>	read(String path, Class<T> responseType) Read from a Vault path.
reactor.core.publisher.Mono<VaultResponse>	write(String path, Object body) Write to a Vault path.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.vault.core.ReactiveVaultOperations

write

Constructor Detail

ReactiveVaultTemplate

public ReactiveVaultTemplate(VaultEndpoint vaultEndpoint,
                             ClientHttpConnector connector,
                             VaultTokenSupplier vaultTokenSupplier)

Create a new ReactiveVaultTemplate with a VaultEndpoint, ClientHttpConnector and VaultTokenSupplier.

Parameters:

vaultEndpoint - must not be null.

connector - must not be null.

vaultTokenSupplier - must not be null.

ReactiveVaultTemplate

public ReactiveVaultTemplate(VaultEndpointProvider endpointProvider,
                             ClientHttpConnector connector,
                             VaultTokenSupplier vaultTokenSupplier)

Create a new ReactiveVaultTemplate with a VaultEndpointProvider, ClientHttpConnector and VaultTokenSupplier.

Parameters:

endpointProvider - must not be null.

connector - must not be null.

vaultTokenSupplier - must not be null.

Method Detail

doCreateWebClient

protected WebClient doCreateWebClient(VaultEndpointProvider endpointProvider,
                                      ClientHttpConnector connector)

Create a WebClient to be used by ReactiveVaultTemplate for Vault communication given VaultEndpointProvider and ClientHttpConnector. VaultEndpointProvider is used to contribute host and port details for relative URLs typically used by the Template API. Subclasses may override this method to customize the WebClient.

Parameters:

endpointProvider - must not be null.

connector - must not be null.

Returns:

the WebClient used for Vault communication.

Since:

2.1

doCreateSessionWebClient

protected WebClient doCreateSessionWebClient(VaultEndpointProvider endpointProvider,
                                             ClientHttpConnector connector)

Create a session-bound WebClient to be used by VaultTemplate for Vault communication given VaultEndpointProvider and ClientHttpConnector for calls that require an authenticated context. VaultEndpointProvider is used to contribute host and port details for relative URLs typically used by the Template API. Subclasses may override this method to customize the WebClient.

Parameters:

endpointProvider - must not be null.

connector - must not be null.

Returns:

the WebClient used for Vault communication.

Since:

2.1

read

public reactor.core.publisher.Mono<VaultResponse> read(String path)

Description copied from interface: ReactiveVaultOperations

Read from a Vault path. Reading data using this method is suitable for API calls/secret backends that do not require a request body.

Specified by:

read in interface ReactiveVaultOperations

Parameters:

path - must not be null.

Returns:

the data. May be empty if the path does not exist.

read

public <T> reactor.core.publisher.Mono<VaultResponseSupport<T>> read(String path,
                                                                     Class<T> responseType)

Description copied from interface: ReactiveVaultOperations

Read from a Vault path. Reading data using this method is suitable for API calls/secret backends that do not require a request body.

Specified by:

read in interface ReactiveVaultOperations

Parameters:

path - must not be null.

responseType - must not be null.

Returns:

the data. May be empty if the path does not exist.

list

public reactor.core.publisher.Flux<String> list(String path)

Description copied from interface: ReactiveVaultOperations

Enumerate keys from a Vault path.

Specified by:

list in interface ReactiveVaultOperations

Parameters:

path - must not be null.

Returns:

the data. May be empty if the path does not exist.

write

public reactor.core.publisher.Mono<VaultResponse> write(String path,
                                                        @Nullable
                                                        Object body)

Description copied from interface: ReactiveVaultOperations

Write to a Vault path.

Specified by:

write in interface ReactiveVaultOperations

Parameters:

path - must not be null.

body - the body, may be null if absent.

Returns:

the response. May be empty if the response has no body.

delete

public reactor.core.publisher.Mono<Void> delete(String path)

Description copied from interface: ReactiveVaultOperations

Delete a path.

Specified by:

delete in interface ReactiveVaultOperations

Parameters:

path - must not be null.

doWithVault

public <V,T extends org.reactivestreams.Publisher<V>> T doWithVault(Function<WebClient,? extends T> clientCallback)
                                                             throws VaultException,
                                                                    WebClientException

Description copied from interface: ReactiveVaultOperations

Executes a Vault RestOperationsCallback. Allows to interact with Vault using RestOperations without requiring a session.

Specified by:

doWithVault in interface ReactiveVaultOperations

Parameters:

clientCallback - the request.

Returns:

the RestOperationsCallback return value.

Throws:

VaultException - when a HttpStatusCodeException occurs.

WebClientException - exceptions from WebClient.

doWithSession

public <V,T extends org.reactivestreams.Publisher<V>> T doWithSession(Function<WebClient,? extends T> sessionCallback)
                                                               throws VaultException,
                                                                      WebClientException

Description copied from interface: ReactiveVaultOperations

Executes a Vault RestOperationsCallback. Allows to interact with Vault in an authenticated session.

Specified by:

doWithSession in interface ReactiveVaultOperations

Parameters:

sessionCallback - the request.

Returns:

the RestOperationsCallback return value.

Throws:

VaultException - when a HttpStatusCodeException occurs.

WebClientException - exceptions from WebClient.