Package io.micronaut.discovery.consul.client.v1.blockingqueries

Interface BlockedQueriesConsulClient

@BlockedQueries
@Requires(beans=BlockingQueriesConfiguration.class)
@Client(id="consul",
        path="/v1",
        configuration=BlockingQueriesConfiguration.class)
public interface BlockedQueriesConsulClient

A non-blocking HTTP client for Consul, using Blocking Queries feature to wait for potential changes using long polling.

Since:

4.6.0

Author:

LE GALL Benoît

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<List<KeyValue>>	watchValues(String key, @Nullable Boolean recurse, @Nullable Integer index)	Reads a Key from Consul.

Method Details

watchValues

@Get(uri="/kv/{+key}?{&recurse}{&index}",
     single=true)
reactor.core.publisher.Mono<List<KeyValue>> watchValues(String key,
 @Nullable @QueryValue
 @Nullable Boolean recurse,
 @Nullable @QueryValue
 @Nullable Integer index)

Reads a Key from Consul. See KV Store - ReadKey API.

Parameters:

key - The key to watch

recurse - Whether the lookup is recursive or not. When true, treat key as a prefix

index - The index value against which to wait for subsequent changes

Returns:

A Publisher that emits a list of KeyValue