@Requires(beans=HealthEndpoint.class) @Requires(property="endpoints.health.postgres.reactive.enabled",notEquals="false") @Singleton public class PgPoolHealthIndicator extends Object implements HealthIndicator
HealthIndicator
for reactive Postgres client.Modifier and Type | Field and Description |
---|---|
static String |
NAME |
static String |
QUERY |
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
PgPoolHealthIndicator(io.reactiverse.reactivex.pgclient.PgPool client)
Constructor.
|
public static final String NAME
public static final String QUERY
public PgPoolHealthIndicator(io.reactiverse.reactivex.pgclient.PgPool client)
client
- A pool of connections.public Publisher<HealthResult> getResult()
getResult
in interface HealthIndicator
HealthResult
that provides the
information necessary to build a response.