org.springframework.vault.client

Class ReactiveVaultClients

java.lang.Object

org.springframework.vault.client.ReactiveVaultClients

public class ReactiveVaultClients
extends Object

Vault Client factory to create WebClient configured to the needs of accessing Vault.

Since:

2.0

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor and Description
ReactiveVaultClients()

Method Summary

Modifier and Type	Method and Description
static WebClient	createWebClient(ReactiveVaultEndpointProvider endpointProvider, ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static WebClient	createWebClient(VaultEndpoint endpoint, ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static WebClient	createWebClient(VaultEndpointProvider endpointProvider, ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static ExchangeFilterFunction	namespace(String namespace) Create a ExchangeFilterFunction that associates each request with a X-Vault-Namespace header if the header is not present.
static ReactiveVaultEndpointProvider	wrap(VaultEndpointProvider endpointProvider) Wrap a VaultEndpointProvider into a ReactiveVaultEndpointProvider to invoke VaultEndpointProvider.getVaultEndpoint() on a dedicated scheduler.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveVaultClients

public ReactiveVaultClients()

Method Detail

createWebClient

public static WebClient createWebClient(VaultEndpoint endpoint,
                                        ClientHttpConnector connector)

Create a WebClient configured with VaultEndpoint and ClientHttpConnector. The client accepts relative URIs without a leading slash that are expanded to use VaultEndpoint.

Requires Jackson 2 for Object-to-JSON mapping.

Parameters:

endpoint - must not be null.

connector - must not be null.

Returns:

the configured WebClient.

createWebClient

public static WebClient createWebClient(VaultEndpointProvider endpointProvider,
                                        ClientHttpConnector connector)

Create a WebClient configured with VaultEndpoint and ClientHttpConnector. The client accepts relative URIs without a leading slash that are expanded to use VaultEndpoint.

Requires Jackson 2 for Object-to-JSON mapping. VaultEndpointProvider is called on Schedulers.boundedElastic() to ensure that I/O threads are never blocked.

Parameters:

endpointProvider - must not be null.

connector - must not be null.

Returns:

the configured WebClient.

createWebClient

public static WebClient createWebClient(ReactiveVaultEndpointProvider endpointProvider,
                                        ClientHttpConnector connector)

Create a WebClient configured with VaultEndpoint and ClientHttpConnector. The client accepts relative URIs without a leading slash that are expanded to use VaultEndpoint.

Requires Jackson 2 for Object-to-JSON mapping.

Parameters:

endpointProvider - must not be null.

connector - must not be null.

Returns:

the configured WebClient.

Since:

2.3

namespace

public static ExchangeFilterFunction namespace(String namespace)

Create a ExchangeFilterFunction that associates each request with a X-Vault-Namespace header if the header is not present.

Parameters:

namespace - the Vault namespace to use. Must not be null or empty.

Returns:

the ExchangeFilterFunction to register with WebClient.

Since:

2.2

See Also:

VaultHttpHeaders.VAULT_NAMESPACE

wrap

public static ReactiveVaultEndpointProvider wrap(VaultEndpointProvider endpointProvider)

Wrap a VaultEndpointProvider into a ReactiveVaultEndpointProvider to invoke VaultEndpointProvider.getVaultEndpoint() on a dedicated scheduler.

Parameters:

endpointProvider - must not be null.

Returns:

ReactiveVaultEndpointProvider wrapping VaultEndpointProvider.

Since:

2.3