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 org.springframework.web.reactive.function.client.WebClient	createWebClient(ReactiveVaultEndpointProvider endpointProvider, org.springframework.http.client.reactive.ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static org.springframework.web.reactive.function.client.WebClient	createWebClient(VaultEndpoint endpoint, org.springframework.http.client.reactive.ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static org.springframework.web.reactive.function.client.WebClient	createWebClient(VaultEndpointProvider endpointProvider, org.springframework.http.client.reactive.ClientHttpConnector connector) Create a WebClient configured with VaultEndpoint and ClientHttpConnector.
static org.springframework.web.reactive.function.client.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 org.springframework.web.reactive.function.client.WebClient createWebClient(VaultEndpoint endpoint,
                                                                                         org.springframework.http.client.reactive.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 org.springframework.web.reactive.function.client.WebClient createWebClient(VaultEndpointProvider endpointProvider,
                                                                                         org.springframework.http.client.reactive.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 org.springframework.web.reactive.function.client.WebClient createWebClient(ReactiveVaultEndpointProvider endpointProvider,
                                                                                         org.springframework.http.client.reactive.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 org.springframework.web.reactive.function.client.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