Class ProtostellarEndpoint

java.lang.Object
com.couchbase.client.core.endpoint.ProtostellarEndpoint

public class ProtostellarEndpoint extends Object
Wraps a GRPC ManagedChannel.
  • Field Details

  • Constructor Details

  • Method Details

    • diagnostics

      public EndpointDiagnostics diagnostics()
    • shutdown

      public void shutdown(Duration timeout)
    • kvStub

      public com.couchbase.client.protostellar.kv.v1.KvServiceGrpc.KvServiceFutureStub kvStub()
    • kvBlockingStub

      public com.couchbase.client.protostellar.kv.v1.KvServiceGrpc.KvServiceBlockingStub kvBlockingStub()
    • analyticsStub

      public com.couchbase.client.protostellar.analytics.v1.AnalyticsServiceGrpc.AnalyticsServiceStub analyticsStub()
    • queryStub

      public com.couchbase.client.protostellar.query.v1.QueryServiceGrpc.QueryServiceStub queryStub()
    • searchStub

      public com.couchbase.client.protostellar.search.v1.SearchServiceGrpc.SearchServiceStub searchStub()
    • hooksBlockingStub

      public com.couchbase.client.protostellar.internal.hooks.v1.HooksServiceGrpc.HooksServiceBlockingStub hooksBlockingStub()
    • collectionAdminStub

      public com.couchbase.client.protostellar.admin.collection.v1.CollectionAdminServiceGrpc.CollectionAdminServiceFutureStub collectionAdminStub()
    • bucketAdminStub

      public com.couchbase.client.protostellar.admin.bucket.v1.BucketAdminServiceGrpc.BucketAdminServiceFutureStub bucketAdminStub()
    • searchAdminStub

      public com.couchbase.client.protostellar.admin.search.v1.SearchAdminServiceGrpc.SearchAdminServiceFutureStub searchAdminStub()
    • isShutdown

      public boolean isShutdown()
      Note that this is synchronized against something that could block for some time - but only during shutdown.

      It's synchronized to make the shutdown process atomic.

    • hostAndPort

      public HostAndPort hostAndPort()
    • waitUntilReady

      @Internal public CompletableFuture<Void> waitUntilReady(Deadline deadline, boolean waitingForReady)
      Waits until the ManagedChannel is in READY state. Will also initialise trying to make that connection if it's not already.
      Returns:
      a CompletableFuture, as that's what CoreCouchbaseOps.waitUntilReady(Set, Duration, ClusterState, String) uses.