@Stability.Internal public class HealthPinger extends Object
HealthPinger
allows to "ping" individual services with real operations for their health.
This can be used by up the stack code to assert the given state of a connected cluster and/or bucket.
Modifier and Type | Class and Description |
---|---|
static class |
HealthPinger.PingTarget |
Constructor and Description |
---|
HealthPinger() |
Modifier and Type | Method and Description |
---|---|
static Mono<PingResult> |
ping(Core core,
Optional<Duration> timeout,
RetryStrategy retryStrategy,
Set<ServiceType> serviceTypes,
Optional<String> reportId,
boolean clusterLevel)
Performs a service ping against all or (if given) the services provided.
|
@Stability.Internal public static Mono<PingResult> ping(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, boolean clusterLevel)
core
- the core instance against to check.timeout
- the timeout for each individual and total ping report.retryStrategy
- the retry strategy to use for each ping.serviceTypes
- if present, limits the queried services for the given types.Copyright © 2020 Couchbase, Inc.. All rights reserved.