Package com.couchbase.client.core

Class CoreProtostellar

java.lang.Object

com.couchbase.client.core.CoreProtostellar

All Implemented Interfaces:

CoreCouchbaseOps

@Internal
public class CoreProtostellar
extends Object
implements CoreCouchbaseOps

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_PROTOSTELLAR_TLS_PORT

Constructor Summary

Constructors

Constructor	Description
CoreProtostellar(CoreEnvironment env, Authenticator authenticator, ConnectionString connectionString)

Method Summary

Modifier and Type	Method	Description
CoreBucketManagerOps	bucketManager()
CoreSearchIndexManager	clusterSearchIndexManager()
CoreCollectionManager	collectionManager(String bucketName)
ProtostellarContext	context()
CoreResources	coreResources()
ProtostellarEndpoint	endpoint()
CoreEnvironment	environment()
CoreKvBinaryOps	kvBinaryOps(CoreKeyspace keyspace)
CoreKvOps	kvOps(CoreKeyspace keyspace)
ProtostellarPool	pool()
CoreQueryOps	queryOps()
ValueRecorder	responseMetric(ResponseMetricIdentifier rmi)
CoreSearchIndexManager	scopeSearchIndexManager(CoreBucketAndScope scope)
CoreSearchOps	searchOps(CoreBucketAndScope scope)
reactor.core.publisher.Mono<Void>	shutdown(Duration timeout)
CompletableFuture<Void>	waitUntilReady(Set<ServiceType> serviceTypes, Duration timeout, ClusterState desiredState, String bucketName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.couchbase.client.core.api.CoreCouchbaseOps

asCore

Field Details

DEFAULT_PROTOSTELLAR_TLS_PORT

public static final int DEFAULT_PROTOSTELLAR_TLS_PORT

See Also:

• Constant Field Values

Constructor Details

CoreProtostellar

public CoreProtostellar(CoreEnvironment env,
 Authenticator authenticator,
 ConnectionString connectionString)

Method Details

context

public ProtostellarContext context()

shutdown

public reactor.core.publisher.Mono<Void> shutdown(Duration timeout)

Specified by:

shutdown in interface CoreCouchbaseOps

endpoint

public ProtostellarEndpoint endpoint()

pool

public ProtostellarPool pool()

responseMetric

@Internal
public ValueRecorder responseMetric(ResponseMetricIdentifier rmi)

kvOps

public CoreKvOps kvOps(CoreKeyspace keyspace)

Specified by:

kvOps in interface CoreCouchbaseOps

queryOps

public CoreQueryOps queryOps()

Specified by:

queryOps in interface CoreCouchbaseOps

searchOps

public CoreSearchOps searchOps(@Nullable
 CoreBucketAndScope scope)

Specified by:

searchOps in interface CoreCouchbaseOps

kvBinaryOps

public CoreKvBinaryOps kvBinaryOps(CoreKeyspace keyspace)

Specified by:

kvBinaryOps in interface CoreCouchbaseOps

bucketManager

public CoreBucketManagerOps bucketManager()

Specified by:

bucketManager in interface CoreCouchbaseOps

collectionManager

public CoreCollectionManager collectionManager(String bucketName)

Specified by:

collectionManager in interface CoreCouchbaseOps

clusterSearchIndexManager

public CoreSearchIndexManager clusterSearchIndexManager()

Specified by:

clusterSearchIndexManager in interface CoreCouchbaseOps

scopeSearchIndexManager

public CoreSearchIndexManager scopeSearchIndexManager(CoreBucketAndScope scope)

Specified by:

scopeSearchIndexManager in interface CoreCouchbaseOps

environment

public CoreEnvironment environment()

Specified by:

environment in interface CoreCouchbaseOps

coreResources

public CoreResources coreResources()

Specified by:

coreResources in interface CoreCouchbaseOps

waitUntilReady

public CompletableFuture<Void> waitUntilReady(Set<ServiceType> serviceTypes,
 Duration timeout,
 ClusterState desiredState,
 @Nullable
 String bucketName)

Specified by:

waitUntilReady in interface CoreCouchbaseOps