Modifier and Type | Method and Description |
---|---|
Mono<Void> |
Core.ensureServiceAt(NodeIdentifier identifier,
ServiceType serviceType,
int port,
Optional<String> bucket,
Optional<String> alternateAddress)
This method can be used by a caller to make sure a certain service is enabled at the given
target node.
|
Optional<Flux<ServiceState>> |
Core.serviceState(NodeIdentifier nodeIdentifier,
ServiceType type,
Optional<String> bucket)
If present, returns a flux that allows to monitor the state changes of a specific service.
|
Modifier and Type | Method and Description |
---|---|
ServiceType |
ServiceReconfigurationFailedEvent.serviceType() |
Constructor and Description |
---|
ServiceReconfigurationFailedEvent(Context context,
String hostname,
ServiceType serviceType,
Throwable reason) |
Modifier and Type | Method and Description |
---|---|
ServiceType |
InvalidRequestDetectedEvent.serviceType() |
Constructor and Description |
---|
InvalidRequestDetectedEvent(IoContext context,
ServiceType serviceType,
Object message) |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,Set<ClusterCapabilities>> |
AbstractBucketConfig.clusterCapabilities() |
Map<ServiceType,Set<ClusterCapabilities>> |
ClusterConfig.clusterCapabilities()
Returns the current cluster capabilities.
|
Map<ServiceType,Set<ClusterCapabilities>> |
BucketConfig.clusterCapabilities()
Returns the cluster capabilities reported by the server.
|
Map<ServiceType,Set<ClusterCapabilities>> |
GlobalConfig.clusterCapabilities()
All global cluster capabilities.
|
Map<ServiceType,Integer> |
PortInfo.ports() |
Map<ServiceType,Integer> |
AlternateAddress.services() |
Map<ServiceType,Integer> |
NodeInfo.services() |
Map<ServiceType,Integer> |
PortInfo.sslPorts() |
Map<ServiceType,Integer> |
AlternateAddress.sslServices() |
Map<ServiceType,Integer> |
NodeInfo.sslServices() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractBucketConfig.serviceEnabled(ServiceType type) |
boolean |
BucketConfig.serviceEnabled(ServiceType type)
Check if the service is enabled on the bucket.
|
Constructor and Description |
---|
NodeInfo(String hostname,
Map<ServiceType,Integer> direct,
Map<ServiceType,Integer> ssl,
Map<String,AlternateAddress> alternateAddresses)
Creates a new
NodeInfo with SSL services. |
NodeInfo(String hostname,
Map<ServiceType,Integer> direct,
Map<ServiceType,Integer> ssl,
Map<String,AlternateAddress> alternateAddresses)
Creates a new
NodeInfo with SSL services. |
Modifier and Type | Method and Description |
---|---|
ServiceType |
HealthPinger.PingTarget.serviceType() |
ServiceType |
EndpointPingReport.type()
The service type for this endpoint.
|
ServiceType |
EndpointDiagnostics.type()
The service type for this endpoint.
|
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,List<EndpointDiagnostics>> |
DiagnosticsResult.endpoints()
Returns the diagnostic reports of each individual endpoint.
|
Map<ServiceType,List<EndpointPingReport>> |
PingResult.endpoints()
Returns the diagnostic reports of each individual endpoint.
|
Modifier and Type | Method and Description |
---|---|
static Mono<PingResult> |
HealthPinger.ping(Core core,
Optional<Duration> timeout,
RetryStrategy retryStrategy,
Set<ServiceType> serviceTypes,
Optional<String> reportId,
Optional<String> bucketName)
Performs a service ping against all or (if given) the services provided.
|
static CompletableFuture<Void> |
WaitUntilReadyHelper.waitUntilReady(Core core,
Set<ServiceType> serviceTypes,
Duration timeout,
ClusterState desiredState,
Optional<String> bucketName) |
Constructor and Description |
---|
EndpointDiagnostics(ServiceType type,
EndpointState state,
String local,
String remote,
Optional<String> namespace,
Optional<Long> lastActivityUs,
Optional<String> id) |
EndpointPingReport(ServiceType type,
String id,
String local,
String remote,
PingState state,
Optional<String> namespace,
Duration latency,
Optional<String> error) |
Constructor and Description |
---|
DiagnosticsResult(Map<ServiceType,List<EndpointDiagnostics>> endpoints,
String sdk,
String id)
Creates the new diagnostics report.
|
PingResult(Map<ServiceType,List<EndpointPingReport>> endpoints,
String sdk,
String id)
Creates the new ping report.
|
Modifier and Type | Method and Description |
---|---|
ServiceType |
EndpointContext.serviceType() |
Constructor and Description |
---|
EndpointContext(CoreContext ctx,
HostAndPort remoteSocket,
CircuitBreaker circuitBreaker,
ServiceType serviceType,
Optional<HostAndPort> localSocket,
Optional<String> bucket,
Optional<String> channelId)
Creates a new
EndpointContext . |
Modifier and Type | Method and Description |
---|---|
Set<ServiceType> |
IoConfig.servicesToCapture()
Lists the services on which traffic should be captured.
|
Modifier and Type | Method and Description |
---|---|
void |
PasswordAuthenticator.authHttpRequest(ServiceType serviceType,
com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpRequest request) |
default void |
Authenticator.authHttpRequest(ServiceType serviceType,
com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpRequest request)
Allows to add authentication credentials to the http request for the given service.
|
static IoConfig.Builder |
IoConfig.captureTraffic(ServiceType... serviceTypes)
Captures the traffic for all services provided as an argument (all if empty).
|
IoConfig.Builder |
IoConfig.Builder.captureTraffic(ServiceType... serviceTypes)
Captures the traffic for all services provided as an argument (all if empty).
|
Modifier and Type | Method and Description |
---|---|
static FeatureNotAvailableException |
FeatureNotAvailableException.clusterLevelQuery(ServiceType serviceType) |
Constructor and Description |
---|
NonChunkedHttpMessageHandler(BaseEndpoint endpoint,
ServiceType serviceType) |
Modifier and Type | Method and Description |
---|---|
ServiceType |
Request.serviceType()
The service type of this request.
|
Modifier and Type | Method and Description |
---|---|
ServiceType |
AnalyticsRequest.serviceType() |
ServiceType |
GenericAnalyticsRequest.serviceType() |
ServiceType |
AnalyticsPingRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
ServiceType |
BaseKeyValueRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
ServiceType |
BaseManagerRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
ServiceType |
QueryPingRequest.serviceType() |
ServiceType |
QueryRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
ServiceType |
SearchRequest.serviceType() |
ServiceType |
SearchPingRequest.serviceType() |
ServiceType |
GenericSearchRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
ServiceType |
GenericViewRequest.serviceType() |
ServiceType |
ViewRequest.serviceType() |
ServiceType |
ViewPingRequest.serviceType() |
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
Node.addService(ServiceType type,
int port,
Optional<String> bucket)
|
protected Service |
Node.createService(ServiceType serviceType,
int port,
Optional<String> bucket)
Helper method to create the
Service based on the service type provided. |
Mono<Void> |
Node.removeService(ServiceType type,
Optional<String> bucket)
|
boolean |
Node.serviceEnabled(ServiceType type)
If a given
ServiceType is enabled on this node. |
Optional<Flux<ServiceState>> |
Node.serviceState(ServiceType type,
Optional<String> bucket)
If present, returns a flux that allows to monitor the state changes of a specific service.
|
Constructor and Description |
---|
RoundRobinLocator(ServiceType serviceType) |
Modifier and Type | Method and Description |
---|---|
ServiceType |
ServiceContext.serviceType() |
ServiceType |
ViewService.type() |
ServiceType |
Service.type()
Represents the service type for this service.
|
ServiceType |
ManagerService.type() |
ServiceType |
QueryService.type() |
ServiceType |
SearchService.type() |
ServiceType |
KeyValueService.type() |
ServiceType |
AnalyticsService.type() |
static ServiceType |
ServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ServiceType[] |
ServiceType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
ServiceContext(CoreContext ctx,
String remoteHostname,
int remotePort,
ServiceType serviceType,
Optional<String> bucket) |
Copyright © 2020 Couchbase, Inc.. All rights reserved.