Package com.couchbase.client.core.endpoint

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.